Springboot下使用WebSocket和浏览器进行长连接通信

Springboot下使用WebSocket和浏览器进行长连接通信
强烈推介IDEA2021.1.3破解激活,IntelliJ IDEA 注册码,2021.1.3IDEA 激活码  

大家好,我是架构君,一个会写代码吟诗的架构师。今天说一说Springboot下使用WebSocket和浏览器进行长连接通信,希望能够帮助大家进步!!!

WebSocket是Html5里面的一个东西。

WebSocket有别于从前的Http协议,http是无状态的。请求了一次服务器,下一次请求连自己都不知道自己上一次请求了什么内容,

然而,webSocket是长连接,只要进行一次连接,即可服务器和客户端进行双向通信,可以服务器向客户端推送信息。以前还没有websocket这个技术的时候是

通过ajax轮询来完成操作的。但是,隔一段时间就去问服务器,这样对服务器的压力是可想而知的。websocket就没有这样的问题。可以十分方便的实现长连接,

而且开销还不大。

 

注意,websocket是一个底层协议,可以理解为跟http是一个级别的。 STOMP则是基于websocket的上层协议。

还有一点需要注意的是,客户端浏览器有的还不支持websocket,此时可以用Sockjs来作为Websocket的备选方案。

sockjs一样可以作为STOMP的客户端。

那么现在来看Springboot环境下的代码。

 

代码摘自官网demo

 

 
  1. package hello;

  2.  
  3. import org.springframework.context.annotation.Configuration;

  4. import org.springframework.messaging.simp.config.MessageBrokerRegistry;

  5. import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;

  6. import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;

  7. import org.springframework.web.socket.config.annotation.StompEndpointRegistry;

  8.  
  9. @Configuration

  10. @EnableWebSocketMessageBroker

  11. public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer

  12. {

  13.  
  14. @Override

  15. public void configureMessageBroker(MessageBrokerRegistry config)

  16. {

  17.  
  18. <span style="white-space:pre"> </span>//这行代码是配置中间人的 url 一会儿服务器会将产生的信息发送到这个地址,由订阅该地址的websocket客户端消费掉。<span style="white-space:pre"> </span>

  19. config.enableSimpleBroker( "/topic" );



 
  1. <span style="white-space:pre"> </span>//websocket客户端将要发送到websocket服务端的信息地址,个人觉得是为了区别于像其他servlet地址

  2. config.setApplicationDestinationPrefixes( "/app" );

  3. }

  4.  
  5. @Override

  6. public void registerStompEndpoints(StompEndpointRegistry registry)

  7. {

  8.  
  9.  
  10. //这个方法是产生了一个endpoint,参数为websocket的客户端要对服务器端进行连接的地址

  11. registry.addEndpoint( "/gs-guide-websocket" ).withSockJS();

  12. }

  13.  
  14. }

第一个java代码是启动WebSocket配置。不知读者朋友们是否写过tomcat下的websocket代码。

 

那会儿一个类实现了一个ServerApplicationConfig接口, 该接口位于 javax.websocket.server这个包下。

并且在tomcat容器启动时,寻找并注册开发者用@ServerEndPoint注解修饰的类

 

这里的代码也是一个意思
 

 

 

 

 
  1. package hello;

  2.  
  3. import org.springframework.messaging.handler.annotation.MessageMapping;

  4. import org.springframework.messaging.handler.annotation.SendTo;

  5. import org.springframework.stereotype.Controller;

  6.  
  7. @Controller

  8. public class GreetingController

  9. {

  10.  
 
  1. <span style="white-space:pre"> </span>//这个地址也是让用户用户发送websocket客户端数据的地址 ,与上一个java代码 拼接起来 ,所有websocket客户端应该发送的地址是 -----> /app/hello

  2. @MessageMapping("/hello")

 
  1. <span style="white-space:pre"> </span>//这个地址是websocket服务器端要把服务器回送的消息发送的地址,消息内容会由订阅了这个地址的websocket客户端消费掉

  2. @SendTo("/topic/greetings")

  3. public Greeting greeting(HelloMessage message) throws Exception

  4. {

  5.  
  6.  
  7. System.out.println("欢迎得到调用........");

  8.  
  9. System.out.println(message.getName());

  10.  
  11. Thread.sleep( 1000 ); // simulated delay

  12. return new Greeting( "Hello, " + message.getName() + "!" );

  13. }

  14.  
  15. }

 

 

 

 

 
  1. /**

  2. * 连接

  3. *

  4. * subscribe '/topic/greetings'

  5. */

  6. function connect()

  7. {

  8. var socket = new SockJS('/gs-guide-websocket');

  9. stompClient = Stomp.over(socket);

  10. stompClient.connect({}, function (frame)

  11. {

  12. setConnected(true);

  13. console.log('Connected: ' + frame);

  14. stompClient.subscribe('/topic/greetings', function (greeting)

  15. {

  16. showGreeting(JSON.parse(greeting.body).content);

  17. });

  18. });

  19. }

这段代码是用于进行websocket连接用的.

 

 

 var socket = new SockJS('/gs-guide-websocket');

这行代码里写的参数即为endpoint的地址。

 

 

 
  1. stompClient.subscribe('/topic/greetings', function (greeting)

  2. {

  3. showGreeting(JSON.parse(greeting.body).content);

  4. });

subscribe方法则是写的订阅的地址,订阅的地址一旦有了消息,就将其消费掉。得到信息后,在web浏览器内显示数据

 

 
  1. /**

  2. * 发送自己的信息

  3. */

  4. function sendName()

  5. {

  6. stompClient.send("/app/hello", {}, JSON.stringify({'name': $("#name").val()}));

  7. }

send方法里的参数就是websocket要发送的地址,上面的java代码里已经有了说明.

 

完整的代码在Spring的官网上有。

http://spring.io/guides/gs/messaging-stomp-websocket/

本文来源huayang183,由架构君转载发布,观点不代表Java架构师必看的立场,转载请标明来源出处:https://javajgs.com/archives/18198

发表评论