微信小程序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 {@Overridepublic 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;}@Overridepublic 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<>();// 用户进入系统监听@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {System.out.println("成功进入了系统。。。");users.add(session);sendMessagesToUsers(new TextMessage("今天晚上服务器维护,请注意"));}//@Overridepublic 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);}// 后台错误信息处理方法@Overridepublic void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {}// 用户退出后的处理，不如退出之后，要将用户信息从websocket的session中remove掉，这样用户就处于离线状态了，也不会占用系统资源@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {if (session.isOpen()) {session.close();}users.remove(session);System.out.println("安全退出了系统");}@Overridepublic 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@EnableWebSocketpublic class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(WebSocketPushHandler(), "/webSocketServer.action").addInterceptors(new MyWebSocketInterceptor()).setAllowedOrigins("*");registry.addHandler(WebSocketPushHandler(), "/sockjs/webSocketServer.action").addInterceptors(new MyWebSocketInterceptor()).withSockJS();}@Beanpublic 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>2.websocket.js// pages/websocket/websocket.jsPage({ /*** 页面的初始数据*/ 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的实例的详细内容，更多请关注小潘博客其它相关文章！