这篇文章主要讲解了“Netty功能怎么实现”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Netty功能怎么实现”吧！
Netty是年初最先学习的框架，近期的图书租借系统想要用上聊天功能，实现一对一对话聊天,在用户登录服务端时，获取用户ip与id绑定，放入channelgroup，每次循环遍历这个ip对应的channel，否则返回false，在用户状态取到是否在线，在线状态属于handler消息功能。
1.一对一聊天
2.展示在线人数
3.登录验证
4.输入框优化
5.可支持表情
开源万岁
当寻找Netty一对一聊天功能实现的时候，除了重温下功能点，还能发现新的东西，一个小小的demo，别人却不是这么做的，细化到验证，还考虑到性能，看下实现效果页面
需要昵称输入，登录后不是简单的数据新增
private static ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock(true); private static ConcurrentMap<Channel, UserInfo> userInfos = new ConcurrentHashMap<>(); private static AtomicInteger userCount = new AtomicInteger(0);
读写锁；
并发包；
原子计数；
因为最终实现用户的在线人数统计，用了原子类的AtomicInteger
private static AtomicInteger uidGener = new AtomicInteger(1000);private boolean isAuth = false; // 是否认证private long time = 0; // 登录时间private int userId; // UIDprivate String nick; // 昵称private String addr; // 地址private Channel channel;// 通道
登录用户信息，确定昵称，获取ip，每一个用户ip，channel一一对应放入channelGroup。
如何发送消息？
在消息处理Handler中，重写channelread0方法
1.获取是否存在此用户信息的channel
2.存在将用户id，昵称，接收到的消息广播到页面显示
3.消息不为null，读写锁加锁，找到当前用户的channel
4.遍历用户信息，通过netty写入回调返回
if (msg instanceof FullHttpRequest) { handleHttpRequest(ctx, (FullHttpRequest) msg); } else if (msg instanceof WebSocketFrame) { handleWebSocket(ctx, (WebSocketFrame) msg); }
将Handler接受接入到Server
1.定时关闭失效的channel
2.定时向客户端ping消息
Netty的消息处理流程
定义好父子线程组–>在childInitializer定义好相关处理通道处理器-->自己提供处理器在回调
现在开始回调
.childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {将group放入消息管道ch.pipeline().addLast(defLoopGroup,//请求解码器new HttpServerCodec(),//将多个消息转换成单一的消息对象new HttpObjectAggregator(65536),//支持异步发送大的码流，一般用于发送文件流new ChunkedWriteHandler(),//检测链路是否读空闲new IdleStateHandler(60, 0, 0),//处理握手和认证new UserAuthHandler(),//处理消息的发送new MessageHandler());}});
定时处理失效消息
// 定时扫描所有的Channel，关闭失效的ChannelexecutorService.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {logger.info("scanNotActiveChannel --------");UserInfoManager.scanNotActiveChannel();}}, 3, 60, TimeUnit.SECONDS);// 定时向所有客户端发送Ping消息executorService.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {UserInfoManager.broadCastPing();}}, 3, 50, TimeUnit.SECONDS);
前端页面没有什么变化。
1.绑定websocket
2.websocket调用onmessage处理消息
window.socket = new WebSocket("ws://localhost:9688/websocket")
处理技术：
1.线程池
2.Lambad表达式
3.读写锁提高性能
4.原子引用保证原子性，线程安全
debug
用户登录，判断是否是给定的消息类型
获取昵称，用户信息，code码
==success，保存用户信息
第一次登陆没有此用户id与channel，不广播消息
用户计数0 broadCastPing userCount: 0
当发送消息到页面时
触发定时消息广播，遍历size
处理消息ctx.fireChannelRead(frame.retain());
此时广播用户计数broadCastPing userCount: 1
websocket实现了真正意义上的客户端与服务器端的长连接，节省带宽，而关注内容本身
websocket：1--：双向数据传递；
2--：基于Http
3--：非浏览器场合
感谢各位的阅读，以上就是“Netty功能怎么实现”的内容了，经过本文的学习后，相信大家对Netty功能怎么实现这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
