pom依赖

     <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.36.Final</version></dependency>

Server端

package com.kc.monitor.core.utils.netty;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;import java.net.InetSocketAddress;
import java.util.concurrent.ConcurrentHashMap;public class NettyServer{/** 记录所有客户端连接, key=用户id, value=ChannelHandlerContext */public static ConcurrentHashMap<String, ChannelHandlerContext> userIdMap = new ConcurrentHashMap();/** 记录所有客户端连接, key=客户端地址和端口, value=ChannelHandlerContext */public static ConcurrentHashMap<String, ChannelHandlerContext> remoteAddressMap = new ConcurrentHashMap();/*** netty启动端口号*/public static int port = 8081;public void initServer() {/***  客户端创建两个线程池组分别为 boss线程组和工作线程组*/// boss线程池,用于接受客户端连接的请求 （并没有处理请求）NioEventLoopGroup bossGroup = new NioEventLoopGroup();// work线程池,用于处理客户端连接的读写操作，三个线程NioEventLoopGroup workGroup = new NioEventLoopGroup(3);// 用于创建我们的ServerBootstrapServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {// LineBasedFrameDecoder解决粘包-解包问题，设置我们分割最大长度为1024// 原理就是自动帮我们把带有\n或\r\n的数据进行换行//socketChannel.pipeline().addLast(new LineBasedFrameDecoder(1024));socketChannel.pipeline().addLast(new StringEncoder());// String编码器socketChannel.pipeline().addLast(new StringDecoder());// String解码器socketChannel.pipeline().addLast(new ServerHandler());// 管道类-接收发送消息}});try {// 绑定端口号，同步等待成功ChannelFuture future = serverBootstrap.bind(port).sync();System.out.println("服务器启动成功：" + port);// 等待服务器监听端口future.channel().closeFuture().sync();System.out.println("关闭服务器");} catch (Exception e) {e.printStackTrace();} finally {// 优雅的关闭连接bossGroup.shutdownGracefully();workGroup.shutdownGracefully();}}}class ServerHandler extends SimpleChannelInboundHandler<String> {@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, String msg) throws Exception {// msg消息协议格式：id/消息内容String[] split = msg.split("/");NettyServer.userIdMap.put(split[0], channelHandlerContext);System.out.println("接收客户端消息：" + msg);// 响应客户端内容:channelHandlerContext.writeAndFlush("00");InetSocketAddress ipSocket = (InetSocketAddress)channelHandlerContext.channel().remoteAddress();System.out.println("获取客户端ip：" + ipSocket.getAddress().toString());}@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {// remoteAddress = /192.168.52.1:59807String remoteAddress = ctx.channel().remoteAddress().toString();System.out.println("有客户端连接... 客户端地址" + remoteAddress);NettyServer.remoteAddressMap.put(remoteAddress, ctx);super.channelActive(ctx);}@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {String remoteAddress = ctx.channel().remoteAddress().toString();System.out.println("有客户端断开连接... " + remoteAddress);NettyServer.remoteAddressMap.remove(remoteAddress);super.channelInactive(ctx);}
}

main方法初始化netty

@SpringBootApplication
@MapperScan(basePackages = "com.kc.monitor.mapper")
public class MonitorApplication {public static void main(String[] args) {SpringApplication.run(MonitorApplication.class, args);// 初始化Netty服务器NettyServer nettyServer = new NettyServer();nettyServer.initServer();}}

服务端端主动给客户端发送消息

发送前提是以有客户端连接了服务器端。

注意：修改address客户端地址，也可以直接从remoteAddressMap中读取客户端地址。

    /*** 两种发送模式：* 1.根据远程客户端ip端口发送消息* 2.根据用户id发送消息** 目前版本使用方式1比较完善，已经实现客户端断开连接从map中删除该连接，第2种方式还没实现断开连接删除；按照需求可以两种方式结合一下。*/@GetMapping("/test")public void add(String msg){System.out.println(NettyServer.remoteAddressMap.size());System.out.println(NettyServer.userIdMap.size());// 1.根据客户端ip地址发送，发送消息到“/192.168.52.1:59807”客户端String address = "/192.168.52.1:59807";if (NettyServer.remoteAddressMap.containsKey(address)){NettyServer.remoteAddressMap.get(address).writeAndFlush(msg);}// 2.给用户id为1的客户端发送消息String userId = "1";if (NettyServer.userIdMap.containsKey(userId)){NettyServer.userIdMap.get(userId).writeAndFlush(msg);}}

Nerry实现服务器端指定客户端发送消息。相关推荐

Socket服务端向指定客户端发送消息
Socket服务端向指定客户端发送消息解决思想 1.项目背景 2.如何上传与下发指令 3.解决方法 4.流程解决思想 I.指定客户端远程地址是存起来的. II.服务端直接主动发信息给客户端,问题在 ...
服务器怎么向指定客户端发送信息,WebSocket 如何实现服务端向客户端发送消息？...
我们都知道, Websocket 是一个双向的通讯方式,一般情况下,我们都是根据 Client 的情况返回信息,但是在一个更加健壮的系统,我们可能需要主动的向客户端发送消息.我试图在中文网络去搜索,查 ...
ssm配置socket_ssm框架中集成websocket实现服务端主动向客户端发送消息
找了很多配置文档及实例说明,也还是没能成功,最终在csdn博客中发现了基于stomp的消息推送的文章, 下面整理自csdn博客,https://blog.csdn.net/u013627689/art ...
【源码篇】Kafka客户端发送消息
在上一篇文章中,已经介绍了初始化 KafkaProducer 基本流程.当客户端对 KafkaProducer 完成完成后,可以调用 send() 方法将数据发送至kafka broker集群. 图中 ...
python企业微信回调_python 微信企业号-回调模式接收微信端客户端发送消息并被动返回消息...
说明:此代码用于接收手机微信端发送的消息 #-*- coding:utf-8 -*- from flask import Flask,request from WXBizMsgCrypt import ...
云服务器怎么给客户端发送消息,服务器怎样向客户端发送消息
服务器怎样向客户端发送消息内容精选换一换使用SSH方式登录CentOS 6.5操作系统的弹性云服务器时,过一段时间就会自动断开连接.本节操作介绍如何保持SSH会话持续连接不断开该文档适用于Cen ...
【.net】通过企业微信web api给指定用户发送消息
前言在很多业务场景中经常会遇到与微博微信进行通信的需求,今天就和大家一起研究一下如果通过企业微信web api给指定用户发送消息一.创建应用 1.打开企业微信并登录 https://work.we ...
python企业微信回调_Python微信企业号开发之回调模式接收微信端客户端发送消息及被动返回消息示例...
本文实例讲述了Python微信企业号开发之回调模式接收微信端客户端发送消息及被动返回消息.分享给大家供大家参考,具体如下: 说明:此代码用于接收手机微信端发送的消息 #-*- coding:utf-8 ...
Qt Remote Object（QtRO)给指定的客户端发送消息
概述前面写了两篇文章介绍QtRO的使用方法,在这里: Qt Remote Object(QtRO)实现进程间通信 Qt Remote Object(QtRO)动态Replica实现进程间通信然后会 ...

Nerry实现服务器端指定客户端发送消息。

pom依赖

Server端

main方法初始化netty

服务端端主动给客户端发送消息

Nerry实现服务器端指定客户端发送消息。相关推荐

最新文章

热门文章