java netty and html 实现点对点 即时通讯 点对群及时通讯 实例代码 和jvm设置

java netty and html 实现点对点 即时通讯 点对群及时通讯 实例代码 和jvm设置

目录

​​点对点​​

​​点对点反向​​

​​群发​​

​​maven 引入依赖​​

​​java netty 主启动类 代码​​

​​java netty 初始化类 代码​​

​​java netty 通道类 代码​​

​​java netty 通讯上下文管理类​​

​​html 网页代码​​

​​实例代码和jar包​​

​​附上一个netty 启动jar  jvm ​​

​​jvm常见配置汇总介绍​​

点对点

点对点反向

群发

maven 引入依赖

io.netty netty-all 4.1.32.Final

java netty 主启动类 代码

package com.superman.testnetty;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.Channel;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.nio.NioServerSocketChannel;/** * 程序的入口，负责启动应用 *Timely communication */public class TCNettyServer { private int port; public TCNettyServer(int port) { this.port = port; } public void run() { // 启用两个Reactor线程池【netty是基于NIO的，基于线程处理的】 // 用于接收Client端连接的 EventLoopGroup bossGroup = new NioEventLoopGroup(); // 进行网络通信读写 EventLoopGroup workGroup = new NioEventLoopGroup(); try { // 创建一个辅助类Bootstrap，就是对我们的Server进行一系列的配置 ServerBootstrap b = new ServerBootstrap(); b.group(bossGroup, workGroup); // 指定使用NioServerSocketChannel这种类型的通道 b.channel(NioServerSocketChannel.class); /* * 使用 childHandler 去初始化服务器 添加handler，用来监听已经连接的客户端的Channel的动作和状态。 * * 被绑定的MyWebSocketChannelHandler()里面设置了服务端初始化参数以及 */ b.childHandler(new TCWebSocketChannelHandler()); System.out.println("netty服务端开启等待客户端连接...."); Channel ch = b.bind(port).sync().channel(); ch.closeFuture().sync(); } catch (Exception e) { e.printStackTrace(); } finally { // 优雅的退出程序 bossGroup.shutdownGracefully(); workGroup.shutdownGracefully(); } } public static void main(String[] args) { new TCNettyServer(8888).run(); }}

springboot 类启动的时候调用 new TCNettyServer(8888).run();

java netty 初始化类 代码

package com.superman.testnetty;import io.netty.channel.Channel;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelPipeline;import io.netty.channel.socket.SocketChannel;import io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.stream.ChunkedWriteHandler;import io.netty.handler.timeout.IdleStateHandler;import java.util.concurrent.TimeUnit;/** * 初始化连接时候的各个组件 * Timely communication * */public class TCWebSocketChannelHandler extends ChannelInitializer { @Override protected void initChannel(SocketChannel e) throws Exception { e.pipeline().addLast("new HttpServerCodec()); e.pipeline().addLast("aggregator", new HttpObjectAggregator(65536)); e.pipeline().addLast("new ChunkedWriteHandler()); // 添加具体的处理器。可以addLast（或者addFirst）多个handler， // 第一个参数是名字，无具体要求，如果填写null，系统会自动命名。 e.pipeline().addLast("handler", new TCWebSocketHandler()); /**通过使用管道的ChannelPipeline方式来处理请求 * 第一个配置的管道先处理，然后移交给下一个管道来处理，在每个管道处理中 * 各个handler可以决定是否继续或中断 * ChannelPipeline和ChannelHandler机制类似于Servlet和Filter过滤器{@link ChannelPipeline} * Netty中的事件分为inbound事件和outbound事件。 * inbound事件通常由I/O线程触发，例如TCP链路建立事件、链路关闭事件、读事件、异常通知事件等。方法名以file开始{@link ChannelHandlerContext} * outbound事件类似于发送、刷新、断开连接、绑定本地地址等关闭channel */ }}

java netty 通道类 代码

package com.superman.testnetty;import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.*;import io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.handler.codec.io.netty.util.CharsetUtil;import java.io.IOException;import java.util.HashMap;import java.util.List;import java.util.Map;/** * 接收/处理/响应客户端websocket请求的核心业务处理类 * 通过添加hanlder，我们可以监听Channel的各种动作以及状态的改变，包括连接，绑定，接收消息等。 * * Timely communication */public class TCWebSocketHandler extends SimpleChannelInboundHandler