{"id":3948,"date":"2024-05-15T22:29:04","date_gmt":"2024-05-15T14:29:04","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-bootnettywebsocket%e5%ae%9e%e7%8e%b0%e5%90%8e%e5%8f%b0%e5%90%91%e5%89%8d%e7%ab%af%e6%8e%a8%e9%80%81%e4%bf%a1%e6%81%af\/"},"modified":"2024-08-02T17:34:16","modified_gmt":"2024-08-02T09:34:16","slug":"spring-bootnettywebsocket%e5%ae%9e%e7%8e%b0%e5%90%8e%e5%8f%b0%e5%90%91%e5%89%8d%e7%ab%af%e6%8e%a8%e9%80%81%e4%bf%a1%e6%81%af","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-bootnettywebsocket%e5%ae%9e%e7%8e%b0%e5%90%8e%e5%8f%b0%e5%90%91%e5%89%8d%e7%ab%af%e6%8e%a8%e9%80%81%e4%bf%a1%e6%81%af\/","title":{"rendered":"Spring Boot+Netty+Websocket\u5b9e\u73b0\u540e\u53f0\u5411\u524d\u7aef\u63a8\u9001\u4fe1\u606f"},"content":{"rendered":"
\n
\n
<\/section>\n

\u5b66\u8fc7 Netty \u7684\u90fd\u77e5\u9053\uff0cNetty \u5bf9 NIO \u8fdb\u884c\u4e86\u5f88\u597d\u7684\u5c01\u88c5\uff0c\u7b80\u5355\u7684 API\uff0c\u5e9e\u5927\u7684\u5f00\u6e90\u793e\u533a\u3002\u6df1\u53d7\u5e7f\u5927\u7a0b\u5e8f\u5458\u559c\u7231\u3002\u57fa\u4e8e\u6b64\u672c\u6587\u5206\u4eab\u4e00\u4e0b\u57fa\u7840\u7684 netty \u4f7f\u7528\u3002\u5b9e\u6218\u5236\u4f5c\u4e00\u4e2a Netty + websocket \u7684\u6d88\u606f\u63a8\u9001\u5c0f\u6817\u5b50\u3002<\/p>\n

netty\u670d\u52a1\u5668<\/span><\/h2>\n
<\/code><\/pre>\n
\n
public interface PushMsgService {\n    \/***\u63a8\u9001\u7ed9\u6307\u5b9a\u7528\u6237*\/\n    void pushMsgToOne(String userId, String msg);\n\n    \/***\u63a8\u9001\u7ed9\u6240\u6709\u7528\u6237*\/\n    void pushMsgToAll(String msg);\n}\n\n@Service\npublic class PushMsgServiceImplimplementsPushMsgService {\n    @Override\n    public void pushMsgToOne(String userId, String msg) {\n        Channelchannel = NettyConfig.getChannel(userId);\n        if (Objects.isNull(channel)) {\n            thrownewRuntimeException(\"\u672a\u8fde\u63a5socket\u670d\u52a1\u5668\");\n        }\n        channel.writeAndFlush(newTextWebSocketFrame(msg));\n    }\n\n    @Override\n    public void pushMsgToAll(String msg) {\n        NettyConfig.getChannelGroup().writeAndFlush(newTextWebSocketFrame(msg));\n    }\n}<\/pre>\n<\/div>\n
\u00a0<\/code><\/pre>\n
\u6d4b\u8bd5<\/span><\/h2>\n<\/section>\n