小程序websocket人实现SpringMVC+Spring+Mybatis的方法

小编给大家分享一下小程序websocket人实现SpringMVC+Spring+Mybatis的方法，希望大家阅读完这篇文章后大所收获，下面让我们一起去探讨吧！

微信小程序实现websocket步骤:

后台:

 1. 添加maven依赖  2. 创建握手  3. 创建处理器  4. spring配置(xml配置或javabean方式配置任选一种)

微信小程序:

 1. 书写连接

java后台

1.添加maven依赖

 <!-- websocket -->   <dependency>     <groupId>org.springframework</groupId>     <artifactId>spring-websocket</artifactId>     <version>${spring.version}</version>   </dependency>   <dependency>     <groupId>org.springframework</groupId>     <artifactId>spring-messaging</artifactId>     <version>${spring.version}</version>   </dependency>   <!-- 其中spring版本 -->   <!-- 注意spring版本一定要为4以上版本 -->   <spring.version>4.3.7.RELEASE</spring.version>

2.创建握手

package com.ahutshop.websocket; import java.util.Map; import javax.servlet.http.HttpServletRequest; import org.springframework.http.server.ServerHttpRequest; import org.springframework.http.server.ServerHttpResponse; import org.springframework.http.server.ServletServerHttpRequest; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.server.HandshakeInterceptor; /**  * 此类用来获取登录用户信息并交由websocket管理  */ public class MyWebSocketInterceptor implements HandshakeInterceptor {   @Override   public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse arg1, WebSocketHandler arg2,       Map<String, Object> arg3) throws Exception {     // 将ServerHttpRequest转换成request请求相关的类，用来获取request域中的用户信息     if (request instanceof ServletServerHttpRequest) {       ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;       HttpServletRequest httpRequest = servletRequest.getServletRequest();     }     System.out.println("连接到我了");     return true;   }   @Override   public void afterHandshake(ServerHttpRequest arg0, ServerHttpResponse arg1, WebSocketHandler arg2, Exception arg3) {     // TODO Auto-generated method stub   } }

3.创建处理器

package com.ahutshop.websocket; import java.io.IOException; import java.util.ArrayList; import java.util.List; import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.WebSocketMessage; import org.springframework.web.socket.WebSocketSession; public class WebSocketPushHandler implements WebSocketHandler {   private static final List<WebSocketSession> users = new ArrayList<>();   // 用户进入系统监听   @Override   public void afterConnectionEstablished(WebSocketSession session) throws Exception {     System.out.println("成功进入了系统。。。");     users.add(session);     sendMessagesToUsers(new TextMessage("今天晚上服务器维护,请注意"));   }   //   @Override   public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {     // 将消息进行转化，因为是消息是json数据，可能里面包含了发送给某个人的信息，所以需要用json相关的工具类处理之后再封装成TextMessage，     // 我这儿并没有做处理，消息的封装格式一般有{from:xxxx,to:xxxxx,msg:xxxxx}，来自哪里，发送给谁，什么消息等等     // TextMessage msg = (TextMessage)message.getPayload();     // 给所有用户群发消息     //sendMessagesToUsers(msg);     // 给指定用户群发消息     //sendMessageToUser(userId, msg);   }   // 后台错误信息处理方法   @Override   public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {   }   // 用户退出后的处理，不如退出之后，要将用户信息从websocket的session中remove掉，这样用户就处于离线状态了，也不会占用系统资源   @Override   public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {     if (session.isOpen()) {       session.close();     }     users.remove(session);     System.out.println("安全退出了系统");   }   @Override   public boolean supportsPartialMessages() {     return false;   }   /**    * 给所有的用户发送消息    */   public void sendMessagesToUsers(TextMessage message) {     for (WebSocketSession user : users) {       try {         // isOpen()在线就发送         if (user.isOpen()) {           user.sendMessage(message);         }       } catch (IOException e) {         e.printStackTrace();       }     }   }   /**    * 发送消息给指定的用户    */   public void sendMessageToUser(String userId, TextMessage message) {     for (WebSocketSession user : users) {       if (user.getAttributes().get("").equals(userId)) {         try {           // isOpen()在线就发送           if (user.isOpen()) {             user.sendMessage(message);           }         } catch (IOException e) {           e.printStackTrace();         }       }     }   } }

4.spring配置

javabean方式配置(推荐) package com.ahutshop.websocket; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; @Configuration @EnableWebSocket public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {   @Override   public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {     registry.addHandler(WebSocketPushHandler(), "/webSocketServer.action").addInterceptors(new MyWebSocketInterceptor()).setAllowedOrigins("*");     registry.addHandler(WebSocketPushHandler(), "/sockjs/webSocketServer.action")         .addInterceptors(new MyWebSocketInterceptor()).withSockJS();   }   @Bean   public WebSocketHandler WebSocketPushHandler() {     return new WebSocketPushHandler();   } } spring.xml中配置扫描包 <!-- 扫描包 --> <context:component-scan base-package="com.ahutshop.websocket" />

注意:

1. /webSocketServer.action之所以要加上.action的后缀,是因为web.xmlk中配置了拦截的后缀名为.action

<!-- springmvc模块 --> <servlet>   <servlet-name>DispatcherServlet</servlet-name>   <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>   <init-param>     <param-name>contextConfigLocation</param-name>     <param-value>classpath:springmvc.xml</param-value>   </init-param>   <load-on-startup>1</load-on-startup>   <!-- 支持异步 -->   <async-supported>true</async-supported> </servlet> <servlet-mapping>   <servlet-name>DispatcherServlet</servlet-name>   <url-pattern>*.action</url-pattern>  </servlet-mapping>

2 .setAllowedOrigins(“*”)中的*代表合法的请求域名,该方法接受一个可变数组作为参数,一定要配置,不然会请求时会出现403

xml方式配置(省略)

微信小程序

1.websocket.wxml

<!--pages/websocket/websocket.wxml--> <view class="page">  <view class="page__hd">  </view>  <view class="page__bd">  <button bindtap="connectWebsocket" type="primary">连接websocket</button>  </view> </view>

2.websocket.js

// pages/websocket/websocket.js Page({  /**   * 页面的初始数据   */  data: {  },  connectWebsocket: function () {   wx.connectSocket({    url: 'ws://localhost:8080/AhutShop/webSocketServer.action',    data: {    },    header: {     'content-type': 'application/json'    },    method: "GET"   })   wx.onSocketOpen(function (res) {    console.log('WebSocket连接已打开！')   })   wx.onSocketError(function (res) {    console.log('WebSocket连接打开失败，请检查！')   })   wx.onSocketMessage(function (res) {    console.log('收到服务器内容：' + res.data)   })  } })

运行效果

看完了这篇文章，相信你对小程序websocket人实现SpringMVC+Spring+Mybatis的方法有了一定的了解，想了解更多相关知识，欢迎关注亿速云行业资讯频道，感谢各位的阅读！