电脑做网站服务器需要什么软件,中国建设银行怎么查询余额,太原百度seo排名软件,怎么做网站原型之前在做站内信时#xff0c;用到了 WebSocket #xff0c;整理了一些笔记分享如下。 本文基于 SpringBoot 2.1.5#xff0c;本文不涉及环境搭建。 引入依赖
在 Spring 中要使用 WebSocket 功能#xff0c;需要在pom中引入依赖#xff1a;
dependencygroupI… 之前在做站内信时用到了 WebSocket 整理了一些笔记分享如下。 本文基于 SpringBoot 2.1.5本文不涉及环境搭建。 引入依赖
在 Spring 中要使用 WebSocket 功能需要在pom中引入依赖
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId
/dependency配置类
增加一个配置类用于定义 WebSocket 全局配置信息
Configuration
EnableWebSocketMessageBroker
public class WebSocketStompConfig implements WebSocketMessageBrokerConfigurer {/*** 注册stomp端点* param registry*/Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {## 允许使用socketJs方式访问 即可通过http://IP:PORT/xboot/ws来和服务端websocket连接registry.addEndpoint(/tmax/ws).setAllowedOrigins(*).withSockJS();}/*** 配置信息代理* param registry*/Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {## 订阅Broker名称 user点对点 topic广播即群发registry.enableSimpleBroker(/user,/topic);## 全局(客户端)使用的消息前缀registry.setApplicationDestinationPrefixes(/app);## 点对点使用的前缀 无需配置 默认/userregistry.setUserDestinationPrefix(/user);}
}
来看一下这两个方法
1、registerStompEndpoints(StompEndpointRegistry registry)
注册stomp端点。起到的作用就是添加一个服务端点来接收客户端的连接 registry.addEndpoint(/tmax/ws) 表示添加了一个 /tmax/ws 端点客户端可以通过这个端点来进行连接。withSockJS() 的作用是开启 SockJS 访问支持即可通过http://IP:PORT/tmax/ws 来和服务端 websocket 连接。
2、configureMessageBroker(MessageBrokerRegistry registry)
配置信息代理。定义消息代理设置消息连接请求的各种规范信息。 registry.enableSimpleBroker(/user,/topic) 表示客户端订阅地址的前缀信息也就是客户端接收服务端消息的地址的前缀信息比较绕看完整个例子大概就能明白了registry.setApplicationDestinationPrefixes(/app) 指服务端接收地址的前缀意思就是说客户端给服务端发消息的地址的前缀。 registry.setUserDestinationPrefix(/user) 指推送用户前缀。
我不不难发现setApplicationDestinationPrefixes 与 setUserDestinationPrefix 起到的效果敲好相反一个定义了客户端接收的地址前缀一个定义了客户端发送地址的前缀。
开始业务代码的编写
先了解几个知识点下方会用到。
1、MessageMapping
接收客户端请求连接注解。Spring 对于 WebSocket 封装的特别简单提供了一个 MessageMapping 注解功能类似 RequestMapping它是存在于Controller中的定义一个消息的基本请求功能也跟 RequestMapping类似包括支持通配符 的url定义等等。
2、SimpMessagingTemplate
SimpMessagingTemplate 是 Spring-WebSocket 内置的一个消息发送工具可以将消息发送到指定的客户端。
3、SendTo
SendTo 可以把消息广播到路径上去例如下面可以把消息广播到 /topic/greetings”,如果客户端在这个路径订阅消息则可以接收到消息
接下来看一下后台代码实现HelloController
/*** author niceyoo*/
Slf4j
Controller
Api(description hello接口)
Transactional
public class HelloController {Autowiredprivate SimpMessagingTemplate messagingTemplate;/*** 跳转至hello.html界面* return*/RequestMapping(/hello)public String hello(){return hello;}/*** 接收然后转发至客户端消息* param message* return* throws Exception*/MessageMapping(/top)SendTo(/topic/greetings)public String greeting(String message) throws Exception {System.out.println(receiving message);System.out.println(connecting successfully.);return AAA:message;}/*** 推送消息* return*/ResponseBodyRequestMapping(/hello/addMessage)public ResultObject addMessage(){messagingTemplate.convertAndSend(/topic/greetings, 您收到了新的系统消息);return new ResultUtilObject().setSuccessMsg(添加成功);}}hello.html 代码:
!doctype html
html
headscript srchttp://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js/scriptscript srchttps://cdn.bootcss.com/sockjs-client/1.3.0/sockjs.js/scriptscript srchttps://cdn.bootcss.com/stomp.js/2.3.3/stomp.js/scriptstyle.box {width: 300px;float: left;margin: 0 20px 0 20px;}.box div, .box input {border: 1px solid;-moz-border-radius: 4px;border-radius: 4px;width: 100%;padding: 0px;margin: 5px;}.box div {border-color: grey;height: 300px;overflow: auto;}.box input {height: 30px;}h1 {margin-left: 30px;}body {background-color: #F0F0F0;font-family: Arial;}/style
/head
body langen
h1Index/h1
div idfirst classboxdiv/divinput autocompleteoff valueType here.../inputbutton onclickconnect()登陆客户端/buttonbutton onclicksend()发送消息/button
/div
scriptvar stompClient null;var sockjs_url /tmax/ws;function connect() {var sockjs new SockJS(sockjs_url);stompClient Stomp.over(sockjs);stompClient.connect({}, function(frame) {console.log(Connected: frame);stompClient.subscribe(/topic/greetings, function(greeting){console.log(返回内容greeting.body);print(服务器, greeting.body);});});}function send() {if(stompClient null){print(系统提示, 请先点击客户端登陆);return false;}print(客户端, inp.val());stompClient.send(/app/top, {}, inp.val());inp.val();}$(#first input).focus();var div $(#first div);var inp $(#first input);var print function(m, p) {p (p undefined) ? : p;div.append($(code).text(m p));div.append($(br));div.scrollTop(div.scrollTop()10000);};/script
/body
/html操作流程 点击“登录客户端”输入框内输入内容点击发送消息。
消息推送
关于消息的推送借助 postman调用 http://127.0.0.1:8888/hello/addMessage实现后端推送至客户端。 额外补充关于消息推送往往会用到推送至指定用户则messagingTemplate.convertAndSendToUser(id,/queue/subscribe, “您收到了新的消息”); 其中id为系统用户id。
详细可搜索 SimpMessagingTemplate 的一些用法。 如果文章有错的地方欢迎指正大家互相留言交流。习惯在微信看技术文章想要获取更多的Java资源的同学可以关注微信公众号niceyoo 参考地址https://www.jianshu.com/p/60799f1356c5
