一，netty-socketio消息推送
1）在项目中常常涉及到消息推送的情况，消息推送要求的实时性，使用传统的方式已经不能满足需求了
2）使用netty-socketio做消息推送，实现步骤，加入jar包----->写启动，添加，通知，关闭工具类 -----> 设置依靠监听器启动 ----->页面引入js----->编写请求获取消息；
二，实现
1）映入依赖于js文件
<!-- 消息推送 -->
<dependency>
<groupId>com.corundumstudio.socketio</groupId>
<artifactId>netty-socketio</artifactId>
<version>1.7.7</version>
</dependency>
2）实现工具类
/*
* netty-socketio工具类
* 启动、添加客户端
* 消息推送
* 关闭服务
*/
public class Socketio {
static SocketIOServer socketIOServer;
/*
* 添加客户端
*/
public void startSocketio() throws InterruptedException {
//配置
Configuration conf = new Configuration();
//指定要主机ip地址，这个和页面请求ip地址一致
conf.setHostname("192.168.1.2");
//指定端口号
conf.setPort(9092);
//设置最大的WebSocket帧内容长度限制
conf.setMaxFramePayloadLength(1024*1024);
//设置最大HTTP内容长度限制
conf.setMaxHttpContentLength(1024 * 1024);
socketIOServer = new SocketIOServer(conf);
ConnectListener connect = new ConnectListener() {
@Override
public void onConnect(SocketIOClient client) {
System.out.println("添加");
}
};
//添加客户端
socketIOServer.addConnectListener(connect);
socketIOServer.start();
//设置超时时间
Thread.sleep(Integer.MAX_VALUE);
socketIOServer.stop();
}
/*
* 全体消息推送
* @param type 前台根据类型接收消息，所以接收的消息类型不同，收到的通知就不同
* 推送的事件类型
* @param content
* 推送的内容
*/
public void pushArr(String type,String content) {
//获取全部客户端
Collection<SocketIOClient> allClients = socketIOServer.getAllClients();
for (SocketIOClient socket : allClients) {
socket.sendEvent(type, content);
}
}
/*
* 启动服务
*/
public void startServer() {
if (socketIOServer == null) {
new Thread(new Runnable() {
@Override
public void run() {
try {
startSocketio();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
}
/*
* 停止服务
*/
public void stopSocketio() {
if (socketIOServer != null) {
socketIOServer.stop();
socketIOServer = null;
}
}
}
3）监听器启动
public class SocketioLisener implements ServletContextListener{
@Override
public void contextInitialized(ServletContextEvent sce) {
//启动Socketio服务
Socketio socketio = new Socketio();
socketio.startServer();
}
@Override
public void contextDestroyed(ServletContextEvent sce) {
//关闭Socketio服务
Socketio socketio = new Socketio();
socketio.stopSocketio();
}
}
3.1）xml配置
<listener>
<listener-class>lisener.SocketioLisener</listener-class>
</listener>
三，页面
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>消息推送</title>
</head>
<body>
</body>
<script type="text/javascript" src="js/socket.io.js"></script>
<script type="text/javascript" src="jquery-easyui-1.5.3/jquery.min.js"></script>
<script type="text/javascript">
<!-- 实时从指定查看是否有消息 -->
var socket = io.connect(‘192.168.1.2:9092‘);
socket.on(‘connect_msg‘,function(data){
alert(data);
var personInfo = JSON.parse(data);
console.log(personInfo);
});
</script>
</html>
四，消息发布
@Controller
public class NettyController {
@RequestMapping("pushArr")
public void getsoc() {
System.out.println("给全部人员发送消息");
Socketio socketio = new Socketio();
socketio.pushArr("connect_msg", "今天下午2点开会");
}
}
五，效果
时间： 2024-10-29 19:42:42