springboot-websocket-netty

介绍

本项目是对springboot官方提供的websocket进行的netty版本封装，api与原版的完全一致，让广大springboot用户更方便的使用netty版本的websocket。netty与tomcat的相比，占用内存更小，效率更高，在特殊环境下，netty的效率是tomcat的20倍，想更轻松的使用netty版本的websocket，那么现在就来使用它吧！~~

使用说明

添加maven库

 <dependency><groupId>com.simon</groupId><artifactId>spring-boot-starter-websocket-netty</artifactId><version>0.0.1</version></dependency>

代码示例

    import com.simon.annotation.*;import com.simon.model.Session;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import org.springframework.stereotype.Component;import java.io.IOException;import java.util.concurrent.CopyOnWriteArraySet;@ServerEndpoint(port = 8081,path = "/websocket/{sid}")@Componentpublic class NettyServer {static Log log= LogFactory.getLog(NettyServer.class);//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。private static int onlineCount = 0;//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。private static CopyOnWriteArraySet<NettyServer> webSocketSet = new CopyOnWriteArraySet<NettyServer>();//与某个客户端的连接会话，需要通过它来给客户端发送数据private Session session;//接收sidprivate String sid="";/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session,@PathParam("sid") String sid) {this.session = session;webSocketSet.add(this);     //加入set中addOnlineCount();           //在线数加1log.info("有新窗口开始监听:"+sid+",当前在线人数为" + getOnlineCount());this.sid=sid;try {sendMessage("连接成功");} catch (IOException e) {log.error("websocket IO异常");}}/*** 连接关闭调用的方法*/@OnClosepublic void onClose() {webSocketSet.remove(this);  //从set中删除subOnlineCount();           //在线数减1log.info("有一连接关闭！当前在线人数为" + getOnlineCount());}/*** 收到客户端消息后调用的方法** @param message 客户端发送过来的消息*/@OnMessagepublic void onMessage(String message, Session session) throws IOException {log.info("收到来自窗口"+sid+"的信息:"+message);this.sendMessage(message);}/**** @param session* @param error*/@OnErrorpublic void onError(Session session, Throwable error) {log.error("发生错误");error.printStackTrace();}/*** 实现服务器主动推送*/public void sendMessage(String message) throws IOException {this.session.sendText(message);}/*** 群发自定义消息* */public static void sendInfo(String message,String sid) throws IOException {log.info("推送消息到窗口"+sid+"，推送内容:"+message);for (NettyServer item : webSocketSet) {try {//这里可以设定只推送给这个sid的，为null则全部推送if(sid==null) {item.sendMessage(message);}else if(item.sid.equals(sid)){item.sendMessage(message);}} catch (IOException e) {continue;}}}public static synchronized int getOnlineCount() {return onlineCount;}public static synchronized void addOnlineCount() {NettyServer.onlineCount++;}public static synchronized void subOnlineCount() {NettyServer.onlineCount--;}

springboot-websocket-netty相关推荐

springboot整合netty
前面介绍了netty的基本使用以及和websocket的整合,下面就说说如何用springboot整合netty,毕竟我们是要把netty作为一个服务端的框架整合到我们的项目中去的,总不能用main函 ...
SpringBoot +WebSocket实现简单聊天室功能实例
SpringBoot +WebSocket实现简单聊天室功能实例) 一.代码来源二.依赖下载三.数据库准备(sql) 数据库建表并插入sql 四.resources文件配置 application ...
SpringBoot2+Netty+WebSocket(netty实现websocket）
##### 一.SpringBoot2+Netty+WebSocket(netty实现websocket,支持URL参数) 原文链接: https://zhengkai.blog.csdn.net/a ...
SpringBoot WebSocket Stomp
关注 "弋凡"(YiFan)微信公众号吧记录简单笔记做你的最爱 websocket 是什么? 是一种网络通信协议,很多高级功能都需要它为什么要使用websocket? 已经有 ...
springboot websocket
大家好,我是烤鸭: 今天想分享一下springboot+websocket. 之前接到一个需求,需要在页面监听后台的数据(输入邮箱后,需要用户打开邮箱,页面监听用户是否点击激活邮件).之前的实现方式, ...
Springboot 整合 Netty 实战(附源码)
作者:pjmike_pj juejin.im/post/5bd584bc518825292865395d 前言这一篇文章主要介绍如何用Springboot 整合 Netty,由于本人尚处于学习Net ...
Springboot整合Netty，实现Socket通信
文章目录 *Springboot整合Netty,实现Socket通信* 1.模拟单客户端 2.模拟单服务端总结 Springboot整合Netty,实现Socket通信 1.模拟单客户端引入Net ...
SpringBoot使用Netty实现远程调用
SpringBoot使用Netty实现远程调用前言众所周知我们在进行网络连接的时候,建立套接字连接是一个非常消耗性能的事情,特别是在分布式的情况下,用线程池去保持多个客户端连接,是一种非常消耗线程 ...
springboot websocket 传递头信息协议头 token 的前后端解决方案
文章目录一.前言二.js websocket 传递token 2.1 基于协议头三.后台取出websocket协议头的参数 3.1 取出token 3.2 注意大坑四.结尾一.前言关于sp ...
Springboot + WebSocket 实现在线聊天
一.后端 1.在Springboot项目的pom.xml中添加依赖  <dependency><groupId>org.spri ...

springboot-websocket-netty

springboot-websocket-netty相关推荐

最新文章

热门文章