netty-socketio -夜幕思年华

有问题欢迎讨论，群聊广播

架构图

https://blog.csdn.net/qq_24137609/article/details/90693558

1、启动类注入Bean

public class IMApplication extends WebMvcConfigurerAdapter {static Logger logger = Logger.getLogger(IMApplication.class);@Autowiredprivate ChatConfig chatConfig;public static void main(String[] args) {SpringApplication.run(IMApplication.class, args);}@Beanpublic SocketIOServer socketIOServer() {Configuration config = new Configuration();config.setPort(chatConfig.getSocketRamPort());/*** 修复地址占用*/SocketConfig socketConfig = config.getSocketConfig();socketConfig.setReuseAddress(true);/*** 超时处理*/config.setTransports(Transport.WEBSOCKET, Transport.POLLING);config.setPingTimeout(11000);config.setPingInterval(3000);/*** 身份验证*/config.setAuthorizationListener(new AuthorizationListener() {@Overridepublic boolean isAuthorized(HandshakeData data) {String[] params = SymmetricEncoderUtils.AESDncode("AES", data.getSingleUrlParam("token")).split("\\_");if (params[params.length - 1] != null) {return true;}return false;}});final SocketIOServer server = new SocketIOServer(config);return server;}//扫描socket的方法@Beanpublic SpringAnnotationScanner springAnnotationScanner(SocketIOServer socketIOServer) {return new SpringAnnotationScanner(socketIOServer);}
}

2、写一个启动类，并且实现CommandLineRunner方法

@Component
@Order(value = 1)
public class ServerRunner implements CommandLineRunner {private final SocketIOServer server;@Autowiredpublic ServerRunner(SocketIOServer server, MessageDispatcher messageDispatcher, ClientRunner clientRunner, ClientRunnerD clientRunnerD) {this.server = server;}@Overridepublic void run(String... strings) {server.start(); }
}

3、socket业务类（启动类有扫描器）

@Component
public class MessageEventHandler {/*** 建立长连接** @param client*/@OnConnectpublic void onConnect(SocketIOClient client) {//获取用户id参数//建立hashMap//把用户id作为key，client作为value存入}/*** 消息处理** @param client* @param data* @param ackRequest*/@OnEvent(value = "chat")public void onEvent(SocketIOClient client, ImMessageDetail data, AckRequest ackRequest) {chat 需要和前端对应//实体data接收前端数据//放入队列（点对点模式，结合routingKey,实现集群形式）//}/*** 断开连接** @param client*/@OnDisconnectpublic void onDisconnect(SocketIOClient client) {//下线清除，hashMap中这个client的记录（单条）}
}

4、队列取出数据，获取到目标人的client进行消息推送

5、可根据队列实现单聊的集群形式，横向扩展

netty-socketio -夜幕思年华相关推荐

hive静态分区,动态分区 -夜幕思年华
脚本数据 person.txt 夜幕1,china 夜幕2,china 夜幕3,china 夜幕4,china 年华1,India 年华2,India 年华3,India 年华4,India - 静态 ...
rabbitmq安装 -夜幕思年华
环境centos7 1.安装 socat yum install socat 2.更新erlang 2.1.卸载旧版本 yum remove erlang 2.2.下载新版本erl wget http ...
java解决跨域 -夜幕思年华
@CrossOrigin 1.指定类跨域 @CrossOrigin @RestController public class UserController {@RequestMapping(" ...
mysql行转列 -夜幕思年华
员工姓名(name) 排班日期(calendar_date) 排班内容(calss_name) 张三 2005-05-01 00:00:00 日班张三 2005-05-02 00:00:00 日班 ...
mapreduce-全局排序 -夜幕思年华
脚本数据生成随机数到文件 for k in $(seq 1 10000)doecho $RANDOM>>test_data.txt;done 创建目录 hdfs dfs -mkdir / ...
Eureka高可用部署 -夜幕思年华
Eureka 高可用 spring:application:name: EUREKA-HA --- 服务1 server:port: 8761 spring:profiles: peer1 eurek ...
zookeeper傻瓜式集群搭建-夜幕思年华
机器如下序号机器类型 1 192.168.33.111 centos7 2 192.168.33.112 centos7 下载 http://mirror.bit.edu.cn/apache/z ...
IM架构方案设计 -夜幕思年华
最近做了一份IM整套体系,分享下整体架构方案,欢迎交流
Netty SocketIO如何在客户端发起链接时验证token是否合法？
直接上代码: socketIOServer.addConnectListener(new ConnectListener() {public void onConnect(SocketIOClient ...

netty-socketio -夜幕思年华

netty-socketio -夜幕思年华相关推荐

最新文章

热门文章