脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring Boot WebSocket整合及nginx配置

关于Spring Boot WebSocket整合以及nginx配置详解

 更新时间：2017年09月07日 11:40:40   作者：西夏一品堂  
这篇文章主要给大家介绍了关于Spring Boot WebSocket整合以及nginx配置的相关资料，文中通过示例代码给大家介绍的非常详细，相信对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习下吧。

前言

本文主要给大家介绍了关于Spring Boot WebSocket整合及nginx配置的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧。

一：Spring Boot WebSocket整合

创建一个maven项目，加入如下依赖

<dependencyManagement> 
 <dependencies> 
  <dependency> 
   <groupId>org.springframework.boot</groupId> 
   <artifactId>spring-boot-dependencies</artifactId> 
   <version>1.4.0.RELEASE</version> 
   <scope>import</scope> 
   <type>pom</type> 
  </dependency> 
 </dependencies> 
</dependencyManagement> 
 
<dependencies> 
 <dependency> 
  <groupId>org.springframework.boot</groupId> 
  <artifactId>spring-boot-starter-web</artifactId> 
 </dependency> 
 <dependency> 
  <groupId>org.springframework.boot</groupId> 
  <artifactId>spring-boot-starter-websocket</artifactId> 
 </dependency> 
</dependencies>

代码如下：

package com.wh.web; 
 
import org.springframework.web.socket.TextMessage; 
import org.springframework.web.socket.WebSocketSession; 
import org.springframework.web.socket.handler.TextWebSocketHandler; 
 
public class CountWebSocketHandler extends TextWebSocketHandler { 
 
 private static long count = 0; 
 protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { 
  session.sendMessage(new TextMessage("你是第" + (++count) + "位访客")); 
 } 
} 
package com.wh.web; 
 
import org.springframework.context.annotation.Configuration; 
import org.springframework.web.socket.config.annotation.WebSocketConfigurer; 
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; 
 
@Configuration 
public class WebsocketConfiguration implements WebSocketConfigurer { 
 public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { 
  registry.addHandler(new CountWebSocketHandler(), "/web/count"); 
 } 
} 
package com.wh.web; 
 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
import org.springframework.web.socket.config.annotation.EnableWebSocket; 
 
@EnableWebSocket 
@SpringBootApplication 
public class ServerApp { 
 public static void main(String[] args) { 
  SpringApplication.run(ServerApp.class, args); 
 } 
}

application.properties 内容如下：

server.port=9080 
spring.resources.static-locations=classpath:/webapp/html/

src/main/resources/webapp/html/index.html  内容如下：

<!DOCTYPE html> 
<html> 
<head> 
<meta charset="UTF-8" /> 
<title>web socket</title> 
</head> 
<body> 
<h1>web socket</h1> 
<script type="text/javascript"> 
 var url = 'ws://'+window.location.hostname+':9080/web/count'; 
 var ws = new WebSocket(url); 
 ws.onopen = function(event) 
 { 
  ws.send('hello'); 
 }; 
  
 ws.onmessage = function(event) { 
  alert(event.data); 
 }; 
  
 ws.onerror = function(event) { 
  alert(event); 
 } 
</script> 
</body> 
</html>

最后，启动main方法，访问http://127.0.0.1:9080/index.html即可看到输出

二：nginx配置

nginx 通过在客户端和后端服务器之间建立起一条隧道来支持WebSocket。

为了使nginx可以将来自客户端的Upgrade请求发送给后端服务器，Upgrade和Connection的头信息必须被显式的设置。如下所示：

location /web/count { 
  proxy_pass http://tomcat-server; 
  proxy_redirect off; 
  proxy_http_version 1.1; 
  proxy_set_header Upgrade $http_upgrade; 
  proxy_set_header Connection "upgrade"; 
  proxy_set_header Host $host:$server_port; 
  proxy_set_header X-Real-IP $remote_addr; 
  proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;  
}

一旦我们完成以上设置，nginx就可以处理WebSocket连接了。

注意：必须要有  proxy_set_header Host $host:$server_port;   这个配置

否则，会报：WebSocket connection to 'ws://192.168.1.104:9080/web/count' failed: Error during WebSocket handshake: Unexpected response code: 403的错误

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

您可能感兴趣的文章:

相关文章

  • Java排序算法三之归并排序的递归与非递归的实现示例解析

    Java排序算法三之归并排序的递归与非递归的实现示例解析

    这篇文章主要介绍了Java排序算法三之归并排序的递归与非递归的实现示例解析，文章通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • Java中线程用法总结

    Java中线程用法总结

    这篇文章主要介绍了Java中线程用法,实例总结了java中线程的常见使用技巧,需要的朋友可以参考下
    2015-06-06
  • 配合Swagger使用绝佳的两款直观易用JSON可视化工具

    配合Swagger使用绝佳的两款直观易用JSON可视化工具

    这篇文章主要为大家介绍了配合Swagger使用绝佳的两款直观易用JSON可视化工具图文详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-06-06
  • SpringBoot实现列表数据导出为Excel文件

    SpringBoot实现列表数据导出为Excel文件

    这篇文章主要为大家详细介绍了在Spring Boot框架中如何将列表数据导出为Excel文件,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下
    2024-02-02
  • java实现将数字转换成人民币大写

    java实现将数字转换成人民币大写

    前面给大家介绍过使用javascript，php，c#,python等语言实现人民币大写格式化，这篇文章主要介绍了java实现将数字转换成人民币大写的代码，非常的简单实用，分享给大家,需要的朋友可以参考下
    2015-04-04
  • SpringBoot程序的打包与运行的实现

    SpringBoot程序的打包与运行的实现

    本文主要介绍了SpringBoot程序的打包与运行的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-06-06
  • 解密Spring Boot深入理解条件装配与条件注解

    解密Spring Boot深入理解条件装配与条件注解

    条件注解是一种特殊的注解,用于标记在配置类、组件类或方法上,它们根据某些条件的结果来决定是否应用相应的配置或组件,这篇文章主要介绍了解密Spring Boot深入理解条件装配与条件注解,需要的朋友可以参考下
    2024-06-06
  • Java/Android 获取网络重定向文件的真实URL的示例代码

    Java/Android 获取网络重定向文件的真实URL的示例代码

    本篇文章主要介绍了Java/Android 获取网络重定向文件的真实URL的示例代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2017-11-11
  • 解读nacos获取配置文件的大致过程

    解读nacos获取配置文件的大致过程

    这篇文章主要介绍了nacos获取配置文件的大致过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-07-07
  • Hystrix Turbine聚合监控的实现详解

    Hystrix Turbine聚合监控的实现详解

    微服务架构下，⼀个微服务往往部署多个实例，如果每次只能查看单个实例的监控，就需要经常切换很不⽅便，在这样的场景下，我们可以使⽤ Hystrix Turbine 进⾏聚合监控，它可以把相关微服务的监控数据聚合在⼀起，便于查看
    2022-09-09

最新评论