springboot工程基于netty-socketio的web推送消息简单代码

共112个文件

xml：76个

class：11个

java：9个

springboot

netty-socket

web

5星 · 超过95%的资源需积分: 50 30 浏览量 2018-08-02 17:10:35 上传评论 3 收藏 115KB RAR 举报

在本文中，我们将深入探讨如何在Spring Boot工程中利用Netty和Socket.IO构建一个Web消息推送服务。Spring Boot以其简洁的配置和强大的功能，成为Java开发者构建微服务的首选框架。而Netty作为高性能的异步事件驱动网络应用框架，常用于创建服务器和客户端应用程序，尤其适合实时通信。Socket.IO则是一种在浏览器和服务器之间实现实时双向通信的库，它兼容多种传输协议，如WebSocket、Long Polling等。我们需要在Spring Boot项目中引入Netty-Socket.IO的相关依赖。在`pom.xml`文件中添加如下Maven依赖： ```xml <dependency> <groupId>com.corundumstudio.socketio</groupId> <artifactId>netty-socketio</artifactId> <version>1.7.13</version> </dependency> ``` 接下来，我们创建一个配置类`SocketIoConfig.java`，用于配置Socket.IO服务器： ```java @Configuration public class SocketIoConfig { @Value("${socketio.port:9000}") private int port; @Bean public ServerSocketIOServer serverSocketIOServer() { ServerSocketIOServer server = new ServerSocketIOServer(new InetSocketAddress(port)); server.setUpgradeProtocol(UpgradeProtocol.WEBSOCKET); return server; } } ``` 然后，我们需要创建一个处理客户端连接和消息的`SocketIOController.java`类： ```java @Controller public class SocketIOController { @Autowired private ServerSocketIOServer serverSocketIOServer; @OnConnect public void onConnect(SocketIOClient client) { System.out.println("Client connected: " + client.getSessionId()); serverSocketIOServer.addBroadcastEventListener(new MessageEventListener()); } @OnEvent(value = "message") public String onMessage(SocketIOClient client, String message) { System.out.println("Received message from client: " + message); // 广播消息到所有连接的客户端 serverSocketIOServer.getBroadcastOperations().sendEvent("response", message); return "Message received"; } @OnDisconnect public void onDisconnect(SocketIOClient client) { System.out.println("Client disconnected: " + client.getSessionId()); } } ``` 在这个控制器中，我们定义了`@OnConnect`、`@OnEvent`和`@OnDisconnect`注解的方法，分别对应客户端连接、接收到消息和断开连接时的处理逻辑。对于前端部分，可以使用JavaScript的Socket.IO客户端库与后端进行通信。创建一个`index.html`文件，并引入Socket.IO的JavaScript库： ```html <!DOCTYPE html> <html> <head> <title>Socket.IO Test</title> <script src="https://cdn.socket.io/socket.io-1.4.5.js"></script> <script> var socket = io('http://localhost:9000'); socket.on('connect', function () { console.log('Connected!'); socket.emit('message', 'Hello from client'); }); socket.on('response', function (msg) { console.log('Server response:', msg); }); </script> </head> <body> <h1>Socket.IO Test</h1> </body> </html> ``` 这个简单的HTML页面在连接成功后向服务器发送一条消息，并监听服务器的响应。启动Spring Boot应用，访问`index.html`，你将看到客户端和服务器之间的交互。这个例子展示了如何在Spring Boot项目中集成Netty-Socket.IO实现Web消息推送，以及如何处理连接、接收和发送消息。通过这个基础，你可以进一步扩展这个服务，比如添加用户认证、实现更复杂的业务逻辑，或者为多个房间提供不同类型的推送消息。Spring Boot结合Netty-Socket.IO为开发实时Web应用提供了强大且灵活的工具。

资源推荐

资源详情

资源评论

收起资源包目录

springboot工程基于netty-socketio的 web推送消息简单代码（112个子文件）

Socketio.class 3KB

CharteventListener.class 2KB

App.class 1KB

SocketioTestApplication.class 1KB

NettyController.class 1KB

Socketio$1.class 976B

SocketListener.class 937B

ChatObject.class 915B

Socketio$2.class 865B

SocketioTestApplicationTests.class 660B

IndexController.class 629B

mvnw.cmd 5KB

.gitignore 268B

socketio-test.iml 9KB

maven-wrapper.jar 46KB

Socketio.java 3KB

App.java 850B

SocketioTestApplication.java 847B

CharteventListener.java 823B

SocketListener.java 757B

ChatObject.java 717B

NettyController.java 662B

IndexController.java 429B

SocketioTestApplicationTests.java 346B

socket.io.js 59KB

test.jsp 2KB

oschina.jsp 1KB

netty.jsp 1011B

inputFiles.lst 353B

inputFiles.lst 99B

createdFiles.lst 0B

mvnw 6KB

maven-wrapper.properties 110B

application.properties 67B

workspace.xml 50KB

pom.xml 2KB

Project_Default.xml 2KB

Maven__org_springframework_boot_spring_boot_test_autoconfigure_1_5_15_RELEASE.xml 776B

Maven__org_springframework_boot_spring_boot_starter_logging_1_5_15_RELEASE.xml 755B

Maven__org_springframework_boot_spring_boot_starter_tomcat_1_5_15_RELEASE.xml 748B

Maven__org_springframework_boot_spring_boot_autoconfigure_1_5_15_RELEASE.xml 741B

Maven__org_springframework_boot_spring_boot_starter_test_1_5_15_RELEASE.xml 734B

Maven__org_springframework_boot_spring_boot_starter_web_1_5_15_RELEASE.xml 727B

Maven__io_netty_netty_transport_native_unix_common_4_1_22_Final.xml 726B

Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml 700B

Maven__org_springframework_boot_spring_boot_starter_1_5_15_RELEASE.xml 699B

Maven__io_netty_netty_transport_native_epoll_4_1_22_Final.xml 684B

Maven__org_springframework_boot_spring_boot_test_1_5_15_RELEASE.xml 678B

Maven__org_springframework_spring_expression_4_3_18_RELEASE.xml 665B

Maven__org_apache_tomcat_embed_tomcat_embed_websocket_8_5_32.xml 660B

Maven__com_fasterxml_jackson_core_jackson_annotations_2_8_0.xml 644B

Maven__org_springframework_spring_context_4_3_18_RELEASE.xml 644B

Maven__com_fasterxml_jackson_core_jackson_databind_2_8_11_2.xml 644B

Maven__org_springframework_boot_spring_boot_1_5_15_RELEASE.xml 643B

Maven__org_apache_tomcat_embed_tomcat_embed_jasper_8_5_32.xml 639B

compiler.xml 638B

Maven__org_springframework_spring_webmvc_4_3_18_RELEASE.xml 637B

Maven__org_apache_tomcat_tomcat_annotations_api_8_5_32.xml 636B

Maven__org_hibernate_hibernate_validator_5_3_6_Final.xml 634B

Maven__org_springframework_spring_beans_4_3_18_RELEASE.xml 630B

Maven__org_apache_tomcat_embed_tomcat_embed_core_8_5_32.xml 625B

Maven__org_springframework_spring_core_4_3_18_RELEASE.xml 623B

Maven__org_springframework_spring_test_4_3_18_RELEASE.xml 623B

Maven__com_corundumstudio_socketio_netty_socketio_1_7_14.xml 620B

Maven__org_springframework_spring_aop_4_3_18_RELEASE.xml 616B

Maven__org_springframework_spring_web_4_3_18_RELEASE.xml 616B

Maven__javax_validation_validation_api_1_1_0_Final.xml 611B

Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_32.xml 611B

Maven__org_jboss_logging_jboss_logging_3_3_2_Final.xml 608B

Maven__com_fasterxml_jackson_core_jackson_core_2_8_11.xml 602B

Maven__io_netty_netty_codec_http_4_1_22_Final.xml 600B

Maven__io_netty_netty_transport_4_1_22_Final.xml 593B

Maven__io_netty_netty_resolver_4_1_22_Final.xml 586B

Maven__io_netty_netty_handler_4_1_22_Final.xml 579B

Maven__ch_qos_logback_logback_classic_1_1_11.xml 575B

Maven__io_netty_netty_buffer_4_1_22_Final.xml 572B

Maven__io_netty_netty_common_4_1_22_Final.xml 572B

Maven__io_netty_netty_codec_4_1_22_Final.xml 565B

Maven__org_slf4j_log4j_over_slf4j_1_7_25.xml 562B

Maven__io_socket_engine_io_client_0_8_2.xml 555B

Maven__io_socket_socket_io_client_0_8_2.xml 555B

Maven__ch_qos_logback_logback_core_1_1_11.xml 554B

Maven__org_hamcrest_hamcrest_library_1_3.xml 553B

Maven__com_squareup_okhttp3_okhttp_ws_3_4_1.xml 550B

Maven__org_mockito_mockito_core_1_10_19.xml 549B

Maven__org_slf4j_jcl_over_slf4j_1_7_25.xml 548B

Maven__com_jayway_jsonpath_json_path_2_2_0.xml 546B

Maven__net_minidev_accessors_smart_1_1.xml 542B

Maven__org_skyscreamer_jsonassert_1_4_0.xml 537B

Maven__org_assertj_assertj_core_2_6_0.xml 535B

Maven__org_slf4j_jul_to_slf4j_1_7_25.xml 534B

Maven__org_hamcrest_hamcrest_core_1_3.xml 532B

Maven__com_squareup_okhttp3_okhttp_3_4_1.xml 529B

Maven__com_fasterxml_classmate_1_3_4.xml 522B

Maven__net_minidev_json_smart_2_2_1.xml 521B

Maven__org_slf4j_slf4j_api_1_7_25.xml 513B

Maven__org_objenesis_objenesis_2_1.xml 508B

Maven__com_squareup_okio_okio_1_9_0.xml 503B

共 112 条

package com.zhoujw.socketiotest.test2; import com.corundumstudio.socketio.Configuration; import com.corundumstudio.socketio.SocketIOClient; import com.corundumstudio.socketio.SocketIOServer; import com.corundumstudio.socketio.listener.ConnectListener; import java.util.Collection; /** * SocketIo 执行工具类 * * @author: zhoujw * @Date: 2018-08-02 */ public class Socketio { static SocketIOServer socketIOServer; /** * 添加客户端 */ public void startSocketio() throws InterruptedException { //配置 Configuration config = new Configuration(); //指定要主机ip地址，与页面请求ip保持一致 config.setHostname("localhost"); //指定端口号 config.setPort(9092); //设置最大的webSocket帧内容长度限制 config.setMaxFramePayloadLength(1024*1024); //设置最大的Http内容长度限制 config.setMaxHttpContentLength(1024*1024); socketIOServer = new SocketIOServer(config); ConnectListener connect = new ConnectListener() { @Override public void onConnect(SocketIOClient socketIOClient) { //todo -> 客户端检验？客户端详操？ System.out.println("添加"); } }; //添加客户端 socketIOServer.addConnectListener(connect); socketIOServer.start(); //设置超时时间 Thread.sleep(Integer.MAX_VALUE); socketIOServer.stop(); } /** * 全体消息推送 * @param type 前台根据类型接收消息，所以接收的消息类型不同，收到儿都通知就不同 => 推送事件类型 /todo 类型可以设置成监听分组？ * @param content */ public void pushArr(String type,String content) throws InterruptedException { // if (socketIOServer == null){ // startSocketio(); // } //获取全部客户端 Collection<SocketIOClient> allClients = socketIOServer.getAllClients(); for (SocketIOClient clientSocket: allClients) { /* todo 客户端支持操作 void send(Packet var1); void disconnect(); void sendEvent(String var1, Object... var2); */ clientSocket.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 stopServer(){ if (socketIOServer != null) { socketIOServer.stop(); socketIOServer = null; } } }

评论收藏

内容反馈