Netty功能怎么实现

发布时间:2021-12-30 09:50:25 作者:iii
来源:亿速云 阅读:169

这篇文章主要讲解了“Netty功能怎么实现”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Netty功能怎么实现”吧!

Netty是年初最先学习的框架,近期的图书租借系统想要用上聊天功能,实现一对一对话聊天,在用户登录服务端时,获取用户ip与id绑定,放入channelgroup,每次循环遍历这个ip对应的channel,否则返回false,在用户状态取到是否在线,在线状态属于handler消息功能。

1.一对一聊天

2.展示在线人数

3.登录验证

4.输入框优化

5.可支持表情

开源万岁

当寻找Netty一对一聊天功能实现的时候,除了重温下功能点,还能发现新的东西,一个小小的demo,别人却不是这么做的,细化到验证,还考虑到性能,看下实现效果页面

Netty功能怎么实现

需要昵称输入,登录后不是简单的数据新增

 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;     // UID    private String nick;    // 昵称    private String addr;    // 地址    private Channel channel;// 通道

登录用户信息,确定昵称,获取ip,每一个用户ip,channel一一对应放入channelGroup。

Netty功能怎么实现

如何发送消息?

在消息处理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>() {
                   @Override                    protected 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,关闭失效的Channel            executorService.scheduleAtFixedRate(new Runnable() {                @Override                public void run() {                    logger.info("scanNotActiveChannel --------");                    UserInfoManager.scanNotActiveChannel();                }            }, 3, 60, TimeUnit.SECONDS);
           // 定时向所有客户端发送Ping消息            executorService.scheduleAtFixedRate(new Runnable() {                @Override                public 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

Netty功能怎么实现

用户登录,判断是否是给定的消息类型

获取昵称,用户信息,code码

==success,保存用户信息

第一次登陆没有此用户id与channel,不广播消息

 用户计数0  broadCastPing userCount: 0

当发送消息到页面时

Netty功能怎么实现

触发定时消息广播,遍历size

处理消息ctx.fireChannelRead(frame.retain());

此时广播用户计数broadCastPing userCount: 1

 websocket实现了真正意义上的客户端与服务器端的长连接,节省带宽,而关注内容本身

          websocket:1--:双向数据传递;

                               2--:基于Http

                               3--:非浏览器场合

Netty功能怎么实现

感谢各位的阅读,以上就是“Netty功能怎么实现”的内容了,经过本文的学习后,相信大家对Netty功能怎么实现这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!

推荐阅读:
  1. Netty RPC的实现流程
  2. Netty与Spring Boot的整合实现

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

netty

上一篇:如何进行Serverless Framework一键扫码部署

下一篇:Serverless中火绒使用云函数SCF快速部署验证码识别接口

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》