{"id":10006452,"date":"2022-09-09T09:46:57","date_gmt":"2022-09-09T01:46:57","guid":{"rendered":"https:\/\/ityet.com\/?p=10006452"},"modified":"2022-09-09T09:46:57","modified_gmt":"2022-09-09T01:46:57","slug":"spring-boot-web-socket-%e6%89%93%e9%80%a0%e5%ae%9e%e6%97%b6%e7%9b%91%e6%8e%a7%e5%bc%82%e5%b8%b8%ef%bc%8c%e5%86%99%e5%be%97%e5%a4%aa%e5%a5%bd%e4%ba%86%ef%bc%81","status":"publish","type":"post","link":"https:\/\/itmax.cn\/?p=10006452","title":{"rendered":"Spring Boot + Web Socket \u6253\u9020\u5b9e\u65f6\u76d1\u63a7\u5f02\u5e38\uff0c\u5199\u5f97\u592a\u597d\u4e86\uff01"},"content":{"rendered":"

\u6765\u6e90\uff1acnblogs.com\/jae-tech\/p\/15409340.html<\/p>\n

\u5199\u5728\u524d\u9762<\/strong><\/h2>\n

\u6b64\u5f02\u5e38\u975e\u5f7c\u5f02\u5e38\uff0c\u6807\u9898\u6240\u8bf4\u7684\u5f02\u5e38\u662f\u4e1a\u52a1\u4e0a\u7684\u5f02\u5e38\u3002<\/p>\n

\u6700\u8fd1\u505a\u4e86\u4e00\u4e2a\u9700\u6c42\uff0c\u6d88\u9632\u7684\u8bbe\u5907\u5de1\u68c0\uff0c\u5982\u679c\u5de1\u68c0\u53d1\u73b0\u5f02\u5e38\uff0c\u901a\u8fc7\u624b\u673a\u7aef\u63d0\u4ea4\uff0c\u540e\u53f0\u7684\u5b9e\u65f6\u76d1\u63a7\u9875\u9762\u5b9e\u65f6\u83b7\u53d6\u5230\u8be5\u8bbe\u5907\u7684\u4fe1\u606f\u53ca\u4f4d\u7f6e\uff0c\u7136\u540e\u5b89\u6392\u5458\u5de5\u53bb\u5904\u7406\u3002<\/p>\n

\u56e0\u4e3a\u9700\u8981\u670d\u52a1\u7aef\u4e3b\u52a8\u5411\u5ba2\u6237\u7aef\u53d1\u9001\u6d88\u606f\uff0c\u6240\u4ee5\u5f88\u5bb9\u6613\u7684\u5c31\u60f3\u5230\u4e86\u7528WebSocket\u6765\u5b9e\u73b0\u8fd9\u4e00\u529f\u80fd\u3002<\/p>\n

WebSocket\u5c31\u4e0d\u505a\u4ecb\u7ecd\u4e86\uff0c\u4e0a\u94fe\u63a5\uff1a<\/p>\n

https:\/\/developer.mozilla.org…<\/a><\/p><\/blockquote>\n

\u524d\u7aef\u7565\u5fae\u590d\u6742\uff0c\u9700\u8981\u5728\u4e00\u5f20\u4f4d\u7f6e\u5206\u5e03\u56fe\u4e0a\u8fdb\u884c\u9f20\u6807\u63cf\u70b9\u5b9a\u4f4d\u5404\u4e2a\u8bbe\u5907\u548c\u6839\u636e\u4e0d\u540c\u5c4f\u5e55\u5927\u5c0f\u6e32\u67d3\uff0c\u672c\u6587\u4e0d\u505a\u4ecb\u7ecd\uff0c\u53ea\u662f\u7b80\u5355\u5730\u7528\u9875\u9762\u6837\u5f0f\u8fdb\u884c\u6548\u679c\u5448\u73b0\u3002<\/p>\n

\u7eff\u8272\u4ee3\u8868\u6b63\u5e38\uff0c\u7ea2\u8272\u4ee3\u8868\u5f02\u5e38<\/strong><\/p>\n

\u9884\u671f\u6548\u679c\uff0c\u672a\u63a5\u6536\u5230\u8bf7\u6c42\u524d—–>id\u4e3a3\u7684\u63d0\u4ea4\u4e86\u5f02\u5e38\uff0cid\u4e3a3\u7684\u738b\u4e94\u53d8\u6210\u4e86\u7ea2\u8272<\/p>\n

\"\"<\/p>\n

\u5b9e\u73b0<\/strong><\/h2>\n

\u524d\u7aef\uff1a<\/h4>\n

\u76f4\u63a5\u8d34\u4ee3\u7801<\/p>\n

<!DOCTYPE html>\n<html>\n    <head>\n        <meta charset="utf-8" \/>\n        <title>\u5b9e\u65f6\u76d1\u63a7<\/title>\n    <\/head>\n    <style>\n        .item {\n            display: flex;\n            border-bottom: 1px solid #000000;\n            justify-content: space-between;\n            width: 30%;\n            line-height: 50px;\n            height: 50px;\n        }\n\n        .item span:nth-child(2){\n            margin-right: 10px;\n            margin-top: 15px;\n            width: 20px;\n            height: 20px;\n            border-radius: 50%;\n            background: #55ff00;\n        }\n        .nowI{\n            background: #ff0000 !important;\n        }\n    <\/style>\n    <body>\n        <div id="app">\n            <div v-for="item in list" class="item">\n                <span>{{item.id}}.{{item.name}}<\/span>\n                <span :class='item.state==-1?"nowI":""'><\/span>\n            <\/div>\n        <\/div>\n    <\/body>\n    <script src=".\/js\/vue.min.js"><\/script>\n    <script type="text\/javascript">\n        var vm = new Vue({\n            el: "#app",\n            data: {\n                list: [{\n                        id: 1,\n                        name: '\u5f20\u4e09',\n                        state: 1\n                    },\n                    {\n                        id: 2,\n                        name: '\u674e\u56db',\n                        state: 1\n                    },\n                    {\n                        id: 3,\n                        name: '\u738b\u4e94',\n                        state: 1\n                    },\n                    {\n                        id: 4,\n                        name: '\u97e9\u6885\u6885',\n                        state: 1\n                    },\n                    {\n                        id: 5,\n                        name: '\u674e\u78ca',\n                        state: 1\n                    },\n                ]\n            }\n        })\n\n        var webSocket = null;\n        if ('WebSocket' in window) {\n            \/\/\u521b\u5efaWebSocket\u5bf9\u8c61\n            webSocket = new WebSocket("ws:\/\/localhost:18801\/webSocket\/" + getUUID());\n\n            \/\/\u8fde\u63a5\u6210\u529f\n            webSocket.onopen = function() {\n                console.log("\u5df2\u8fde\u63a5");\n                webSocket.send("\u6d88\u606f\u53d1\u9001\u6d4b\u8bd5")\n            }\n            \/\/\u63a5\u6536\u5230\u6d88\u606f\n            webSocket.onmessage = function(msg) {\n                \/\/\u5904\u7406\u6d88\u606f\n                var serverMsg = msg.data;\n                var t_id = parseInt(serverMsg) \/\/\u670d\u52a1\u7aef\u53d1\u8fc7\u6765\u7684\u6d88\u606f\uff0cID\uff0cstring\u9700\u8f6c\u5316\u4e3aint\u7c7b\u578b\u624d\u80fd\u6bd4\u8f83\n                for (var i = 0; i < vm.list.length; i++) {\n                    var item = vm.list[i];\n                    if(item.id == t_id){\n                        item.state = -1;\n                        vm.list.splice(i,1,item)\n                        break;\n                    }\n                }\n            };\n\n            \/\/\u5173\u95ed\u4e8b\u4ef6\n            webSocket.onclose = function() {\n                console.log("websocket\u5df2\u5173\u95ed");\n            };\n            \/\/\u53d1\u751f\u4e86\u9519\u8bef\u4e8b\u4ef6\n            webSocket.onerror = function() {\n                console.log("websocket\u53d1\u751f\u4e86\u9519\u8bef");\n            }\n        } else {\n            alert("\u5f88\u9057\u61be\uff0c\u60a8\u7684\u6d4f\u89c8\u5668\u4e0d\u652f\u6301WebSocket\uff01")\n        }\n\n        function getUUID() { \/\/\u83b7\u53d6\u552f\u4e00\u7684UUID\n            return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(\/[xy]\/g, function(c) {\n\n                var r = Math.random() * 16 | 0,\n                    v = c == 'x' ? r : (r & 0x3 | 0x8);\n                return v.toString(16);\n            });\n        }\n    <\/script>\n<\/html><\/code><\/pre>\n
\u540e\u7aef\uff1a<\/h4>\n
\u9879\u76ee\u7ed3\u6784\u662f\u8fd9\u6837\u5b50\u7684\uff0c\u540e\u9762\u7684\u4ee3\u7801\u5173\u952e\u6ce8\u91ca\u90fd\u6709\uff0c\u5c31\u4e0d\u91cd\u590d\u63cf\u8ff0\u4e86<\/p>\n
\"\"<\/p>\n
1\u3001\u65b0\u5efaSpringBoot\u5de5\u7a0b\uff0c\u9009\u62e9web\u548cWebSocket\u4f9d\u8d56<\/p>\n
Spring Boot \u57fa\u7840\u5c31\u4e0d\u4ecb\u7ecd\u4e86\uff0c\u63a8\u8350\u4e0b\u8fd9\u4e2a\u5b9e\u6218\u6559\u7a0b\uff1a<\/p>\n
https:\/\/github.com\/javastacks…<\/a><\/p><\/blockquote>\n
\"\"<\/p>\n
2\u3001\u914d\u7f6eapplication.yml<\/p>\n
#\u7aef\u53e3\nserver:\n  port: 18801\n\n#\u5bc6\u7801\uff0c\u56e0\u4e3a\u63a5\u53e3\u4e0d\u9700\u8981\u6743\u9650\uff0c\u6240\u4ee5\u52a0\u4e86\u4e2a\u5bc6\u7801\u505a\u6821\u9a8c\nmySocket:\n  myPwd: jae_123<\/code><\/pre>\n
3\u3001WebSocketConfig\u914d\u7f6e\u7c7b<\/p>\n
@Configuration\npublic class WebSocketConfig {\n\n    \/**\n     * \u6ce8\u5165\u4e00\u4e2aServerEndpointExporter,\u8be5Bean\u4f1a\u81ea\u52a8\u6ce8\u518c\u4f7f\u7528@ServerEndpoint\u6ce8\u89e3\u7533\u660e\u7684websocket endpoint\n     *\/\n    @Bean\n    public ServerEndpointExporter serverEndpointExporter(){\n        return new ServerEndpointExporter();\n    }\n}<\/code><\/pre>\n
4\u3001WebSocketServer\u7c7b\uff0c\u7528\u6765\u8fdb\u884c\u670d\u52a1\u7aef\u548c\u5ba2\u6237\u7aef\u4e4b\u95f4\u7684\u4ea4\u4e92<\/p>\n
\/**\n * @author jae\n * @ServerEndpoint("\/webSocket\/{uid}") \u524d\u7aef\u901a\u8fc7\u6b64URI\u4e0e\u540e\u7aef\u5efa\u7acb\u94fe\u63a5\n *\/\n\n@ServerEndpoint("\/webSocket\/{uid}")\n@Component\npublic class WebSocketServer {\n\n    private static Logger log = LoggerFactory.getLogger(WebSocketServer.class);\n\n    \/\/\u9759\u6001\u53d8\u91cf\uff0c\u7528\u6765\u8bb0\u5f55\u5f53\u524d\u5728\u7ebf\u8fde\u63a5\u6570\u3002\u5e94\u8be5\u628a\u5b83\u8bbe\u8ba1\u6210\u7ebf\u7a0b\u5b89\u5168\u7684\u3002\n    private static final AtomicInteger onlineNum = new AtomicInteger(0);\n\n    \/\/concurrent\u5305\u7684\u7ebf\u7a0b\u5b89\u5168Set\uff0c\u7528\u6765\u5b58\u653e\u6bcf\u4e2a\u5ba2\u6237\u7aef\u5bf9\u5e94\u7684WebSocketServer\u5bf9\u8c61\u3002\n    private static CopyOnWriteArraySet<Session> sessionPools = new CopyOnWriteArraySet<Session>();\n\n    \/**\n     * \u6709\u5ba2\u6237\u7aef\u8fde\u63a5\u6210\u529f\n     *\/\n    @OnOpen\n    public void onOpen(Session session, @PathParam(value = "uid") String uid){\n        sessionPools.add(session);\n        onlineNum.incrementAndGet();\n        log.info(uid + "\u52a0\u5165webSocket\uff01\u5f53\u524d\u4eba\u6570\u4e3a" + onlineNum);\n    }\n\n    \/**\n     * \u8fde\u63a5\u5173\u95ed\u8c03\u7528\u7684\u65b9\u6cd5\n     *\/\n    @OnClose\n    public void onClose(Session session) {\n        sessionPools.remove(session);\n        int cnt = onlineNum.decrementAndGet();\n        log.info("\u6709\u8fde\u63a5\u5173\u95ed\uff0c\u5f53\u524d\u8fde\u63a5\u6570\u4e3a\uff1a{}", cnt);\n    }\n\n    \/**\n     * \u53d1\u9001\u6d88\u606f\n     *\/\n    public void sendMessage(Session session, String message) throws IOException {\n        if(session != null){\n            synchronized (session) {\n                session.getBasicRemote().sendText(message);\n            }\n        }\n    }\n\n    \/**\n     * \u7fa4\u53d1\u6d88\u606f\n     *\/\n    public void broadCastInfo(String message) throws IOException {\n        for (Session session : sessionPools) {\n            if(session.isOpen()){\n                sendMessage(session, message);\n            }\n        }\n    }\n\n    \/**\n     * \u53d1\u751f\u9519\u8bef\n     *\/\n    @OnError\n    public void onError(Session session, Throwable throwable){\n        log.error("\u53d1\u751f\u9519\u8bef");\n        throwable.printStackTrace();\n    }\n\n}<\/code><\/pre>\n
5\u3001WebSocketController\u7c7b\uff0c\u7528\u4e8e\u8fdb\u884c\u63a5\u53e3\u6d4b\u8bd5<\/p>\n
@RestController\n@RequestMapping("\/open\/socket")\npublic class WebSocketController {\n\n    @Value("${mySocket.myPwd}")\n    public String myPwd;\n\n    @Autowired\n    private WebSocketServer webSocketServer;\n\n    \/**\n     * \u624b\u673a\u5ba2\u6237\u7aef\u8bf7\u6c42\u63a5\u53e3\n     * @param id \u53d1\u751f\u5f02\u5e38\u7684\u8bbe\u5907ID\n     * @param pwd \u5bc6\u7801\uff08\u5b9e\u9645\u5f00\u53d1\u8bb0\u5f97\u52a0\u5bc6\uff09\n     * @throws IOException\n     *\/\n    @PostMapping(value = "\/onReceive")\n    public void onReceive(String id,String pwd) throws IOException {\n        if(pwd.equals(myPwd)){ \/\/\u5bc6\u7801\u6821\u9a8c\u4e00\u81f4\uff08\u8fd9\u91cc\u4e3e\u4f8b\uff0c\u5b9e\u9645\u5f00\u53d1\u8fd8\u8981\u6709\u4e2a\u5bc6\u7801\u52a0\u5bc6\u7684\u6821\u9a8c\u7684\uff09\uff0c\u5219\u8fdb\u884c\u7fa4\u53d1\n            webSocketServer.broadCastInfo(id);\n        }\n    }\n\n}<\/code><\/pre>\n
\u6d4b\u8bd5<\/strong><\/h2>\n
1\u3001\u6253\u5f00\u524d\u7aef\u9875\u9762\uff0c\u8fdb\u884cWebSocket\u8fde\u63a5<\/p>\n
\u63a7\u5236\u53f0\u8f93\u51fa\uff0c\u8fde\u63a5\u6210\u529f<\/p>\n
\"\"<\/p>\n
2\u3001\u56e0\u4e3a\u662f\u6a21\u62df\u6570\u636e\uff0c\u6240\u4ee5\u5168\u90e8\u663e\u793a\u6b63\u5e38\uff0c\u6ca1\u6709\u5f02\u5e38\u63d0\u4ea4\u65f6\u7684\u9875\u9762\u5448\u73b0<\/p>\n
\"\"<\/p>\n
3\u3001\u63a5\u4e0b\u6765\uff0c\u6211\u4eec\u7528\u63a5\u53e3\u6d4b\u8bd5\u5de5\u5177Postman\u63d0\u4ea4\u4e00\u4e2a\u5f02\u5e38<\/p>\n
\"\"<\/p>\n
\u6ce8\u610fid\u4e3a3\u7684\u8fd9\u4e2a\u6570\u636e\u7684\u72b6\u6001\u53d8\u5316<\/p>\n
\"\"<\/p>\n
\u6211\u4eec\u53ef\u4ee5\u770b\u5230\uff0cid\u4e3a3\u7684\u738b\u4e94\u72b6\u6001\u5df2\u7ecf\u53d8\u6210\u5f02\u5e38\u7684\u4e86\uff0c\u5b9e\u65f6\u901a\u8baf\u6210\u529f\u3002<\/p>\n
\u53c2\u8003\uff1a<\/p>\n
https:\/\/developer.mozilla.org…<\/a><\/p><\/blockquote>\n
\u6700\u540e<\/strong><\/h2>\n
\u5de5\u4f5c\u4e2d\u6709\u8fd9\u65b9\u9762\u5173\u4e8e\u5b9e\u65f6\u76d1\u63a7\u7684\u9700\u6c42\uff0c\u53ef\u4ee5\u53c2\u8003\u4e00\u4e0b\u54e6\u3002<\/p>\n
\u4e0d\u8db3\u4e4b\u5904\u6b22\u8fce\u6307\u51fa\uff0c\u89c9\u5f97\u6709\u7528\u7684\u8bdd\u5c31\u70b9\u4e2a\u63a8\u8350\u5427\uff01<\/p>\n
\u8fd1\u671f\u70ed\u6587\u63a8\u8350\uff1a<\/strong><\/p>\n
1.1,000+ \u9053 Java\u9762\u8bd5\u9898\u53ca\u7b54\u6848\u6574\u7406(2022\u6700\u65b0\u7248)<\/a><\/p>\n
2.\u52b2\u7206\uff01Java \u534f\u7a0b\u8981\u6765\u4e86\u3002\u3002\u3002<\/a><\/p>\n
3.Spring Boot 2.x \u6559\u7a0b\uff0c\u592a\u5168\u4e86\uff01<\/a><\/p>\n
4.\u522b\u518d\u5199\u6ee1\u5c4f\u7684\u7206\u7206\u7206\u70b8\u7c7b\u4e86\uff0c\u8bd5\u8bd5\u88c5\u9970\u5668\u6a21\u5f0f\uff0c\u8fd9\u624d\u662f\u4f18\u96c5\u7684\u65b9\u5f0f\uff01\uff01<\/a><\/p>\n
5.\u300aJava\u5f00\u53d1\u624b\u518c\uff08\u5d69\u5c71\u7248\uff09\u300b\u6700\u65b0\u53d1\u5e03\uff0c\u901f\u901f\u4e0b\u8f7d\uff01<\/a><\/p>\n
\u89c9\u5f97\u4e0d\u9519\uff0c\u522b\u5fd8\u4e86\u968f\u624b\u70b9\u8d5e+\u8f6c\u53d1\u54e6\uff01<\/p>\n
https:\/\/segmentfault.com\/a\/1190000042453379<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
\u6765\u6e90\uff1acnblogs.com\/jae-tech\/p\/15409340.html \u5199\u5728\u524d\u9762 \u6b64\u5f02\u5e38\u975e\u5f7c\u5f02\u5e38\uff0c\u6807\u9898 […]<\/p>\n","protected":false},"author":0,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[],"tags":[],"class_list":["post-10006452","post","type-post","status-publish","format-standard","hentry"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10006452","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"replies":[{"embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=10006452"}],"version-history":[{"count":0,"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10006452\/revisions"}],"wp:attachment":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=10006452"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=10006452"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=10006452"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}