netty 服务端主动向客户端发信息

在使用netty时，有时候会和客户端保持长链接，这个时候服务端既可以接受客户端消息也可以主动发送消息给服务端。我们只需要在服务端保存客户端的ChannelHandlerContext对象，必要的时候通过write和flush方法即可实现服务端和客户端的通信。以下为handler的代码，其他代码和普通的netty一样。

public class AcceptServerChannelHandler extends ChannelInboundHandlerAdapter  {public static Map<String, ChannelHandlerContext> ctxMap = new ConcurrentHashMap<String, ChannelHandlerContext>(16);@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {ctx.write("test");ctxMap.put(keyId,ctx);ctx.flush();}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {ctx.flush();ctx.close();}@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {super.channelActive(ctx);}/*** 服务端接收客户端发送过来的数据结束之后调用*/@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception {super.channelReadComplete(ctx);}/*** 客户端主动断开服务端的连接* @param ctx* @throws Exception*/@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {removeChannelMap(ctx);super.channelInactive(ctx);}/*** 移除已经失效的链接* @param ctx*/private void removeChannelMap(ChannelHandlerContext ctx) {for( String key :ctxMap.keySet()){if(ctxMap.get(key)!=null && ctxMap.get(key).equals(ctx)){ctxMap.remove(key);}}}public void sendMessage(String keyid){ChannelHandlerContext ctx = ctxMap.get(keyid);ctx.write("test");ctx.flush();//writeAndFlush在这里没生效，没找到原因}
}

netty 服务端主动向客户端发信息相关推荐

ssm配置socket_ssm框架中集成websocket实现服务端主动向客户端发送消息
找了很多配置文档及实例说明,也还是没能成功,最终在csdn博客中发现了基于stomp的消息推送的文章, 下面整理自csdn博客,https://blog.csdn.net/u013627689/art ...
netty tcp服务端主动断开客户端_「Netty核心技术」6-ChannelPipeline源码
ChannelPipeline是Channelhandler的容器,它负责ChannelHandler的管理和事件拦截与调度. 土话: ChannelPipeline就是用来管理Channelhand ...
netty tcp服务端主动断开客户端_【Netty】服务端和客户端
欢迎关注公众号:[爱编程] 如果有需要后台回复2019赠送1T的学习资料哦!! 本文是基于Netty4.1.36进行分析服务端 Netty服务端的启动代码基本都是如下: private void s ...
springboot实现SSE服务端主动向客户端推送数据，java服务端向客户端推送数据，kotlin模拟客户端向服务端推送数据
SSE服务端推送服务器向浏览器推送信息,除了 WebSocket,还有一种方法:Server-Sent Events(以下简称 SSE).本文介绍它的用法. 在很多业务场景中,会涉及到服务端向客户端 ...
ps：Netty服务端主动关闭问题
之前主动关闭nettyserver是在serverhandler中通过ctx.channel().parent().close();直接关闭serversocketchannel,触发关闭事件,使得s ...
php守护进程内存溢出,$serv-close($fd); 服务端主动断开客户端有问题！
'core' => array( 'reactor_num' => 2, // 线程数. 一般设置为CPU核数的1-4倍 'worker_num' => 16, // 工作进程数量. ...
服务器向客户机发信息,服务器如何主动给客户端发消息
服务器如何主动给客户端发消息内容精选换一换当出现以下问题时,可以参考本章节排查解决.可以直接访问后端业务,但是无法通过负载均衡访问后端业务.通过私网IP可以访问负载均衡,但是公网IP无法访问负载 ...
http协议与https协议+UDP协议和TCP协议+WebSocket协议下服务端主动去发送信息+对称加密与非对称加密+get和post请求方式区别详解+浏览器内核以及jsj解析引擎
TCP和UDP协议是TCP/IP协议的核心. 在TCP/IP网络体系结构中,TCP(传输控制协议,Transport Control Protocol).UDP(用户数据报协议,User Data P ...
二、Netty服务端/客户端启动整体流程
一.综述 Netty 的整体流程相对来说还是比较复杂的,初学者往往会被绕晕.所以这里总结了一下整体的流程,从而对 Netty 的整体服务流程有一个大致的了解.从功能上,流程可以分为服务启动.建立连接. ...

netty 服务端主动向客户端发信息

netty 服务端主动向客户端发信息相关推荐

最新文章

热门文章