使用netty自定义协议

@Component public class RabbitmqConfig { private final static String message = "web.socket.message"; private final static String messages = "send.socket.message"; @Bean public Queue queueMessage() { return new Queue(RabbitmqConfig.message); } @Bean public Queue queueMessages() { return new Queue(RabbitmqConfig.messages); } @Bean TopicExchange exchange() { return new TopicExchange("exchange"); } @Bean Binding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange) { return BindingBuilder.bind(queueMessage).to(exchange).with("web.#"); } @Bean Binding bindingExchangeMessages(Queue queueMessages, TopicExchange exchange) { return BindingBuilder.bind(queueMessages).to(exchange).with("send.#"); } } ServerBootstrap bootstrap = new ServerBootstrap() .group(bossGroup, workGroup) .channel(NioServerSocketChannel.class) .childHandler(new ServerChannelInitializer()) .localAddress(socketAddress) //设置队列大小 .option(ChannelOption.SO_BACKLOG, 1024) // 两小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文 .childOption(ChannelOption.SO_KEEPALIVE, true); //绑定端口,开始接收进来的连接 完整代码，下载有详细说明，使用于长报文通讯，将报文长度截取一定字节发送，便于网速传输中丢包

SpringBoot基于netty-socketio的简易聊天室

Netty 入门与实战：仿写微信 IM 即时通讯系统

springboot继承netty ,使用框架springboot+netty+redis+quartz+mybatisplus+mysql

鲲鹏解决方案成功移植的jar包

鲲鹏结局方案成功移植的netty-all-4.0.23.Final驱动jar包

netty代码demo

我们要编写一个webSocket服务器，支持WebSocket的浏览器通过webSocket协议发送请求给我们编写的webSocket服务器，服务器对请求消息进行判断，如果是合法的webSocket请求，则获取请求消息体，并在后面追加字符串：“欢迎使用Netty WebSocket 服务，现在时刻：系统时间”。

当我们谈论Netty的线程模型时，首先会想到的是经典的ReactorIO多路复用线程模型。从这篇文章中，大家可以学习到如下知识：什么是I/O多路复用Reactor三种线程模型Netty线程模型NioEventLoop源码分析JDKepollbug学习I/O多路复用之前，我们先来了解如下几个概念：阻塞I/O：客户端从socket中读取数据或写入数据时，如果读取时流中没有数据，写入时缓冲区已满，就需要block，知道流中有数据或者缓冲区的数据被排空。非阻塞I/O：客户端从流中读取数据，如果流中没有数据，则立即返回，不发生block。同步I/O：同步I/O将导致请求的I/O操作一直被block，直到