微信小程序实现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在IDEA中的第一个程序  # SpringMVC程序简单实例  # 分析讲解SpringMVC注解配置如何实现  # SpringMVC底层执行流程及原理解析  # 世界著名程序SpringMVC完整过程  # 发送消息  # 离线  # 是因为  # 出了  # 如有  # 希望能  # 此类  # 我了  # 请注意  # 要将  # 谢谢大家  # 转换成  # 错误信息  # 还有很多  # 连接到  # 需要用  # 大家多多  # 某个人  # 给谁  # 我这儿 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 如何快速生成高效建站系统源代码？  Laravel如何实现本地化和多语言支持_Laravel多语言配置与翻译文件管理  阿里云网站搭建费用解析：服务器价格与建站成本优化指南  Python文件异常处理策略_健壮性说明【指导】  Android实现代码画虚线边框背景效果  如何在浏览器中启用Flash_2025年继续使用Flash Player的方法【过时】  如何快速启动建站代理加盟业务？  Javascript中的事件循环是如何工作的_如何利用Javascript事件循环优化异步代码？  HTML 中如何正确使用模板变量为元素的 name 属性赋值  如何在阿里云虚拟机上搭建网站？步骤解析与避坑指南  如何用花生壳三步快速搭建专属网站？  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设？  郑州企业网站制作公司,郑州招聘网站有哪些？  JavaScript模板引擎Template.js使用详解  合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？  重庆市网站制作公司,重庆招聘网站哪个好？  成都网站制作公司哪家好,四川省职工服务网是做什么用？  Laravel如何使用Contracts（契约）进行编程_Laravel契约接口与依赖反转  EditPlus中的正则表达式 实战(4)  三星、SK海力士获美批准：可向中国出口芯片制造设备  香港服务器选型指南：免备案配置与高效建站方案解析  Laravel如何将应用部署到生产服务器_Laravel生产环境部署流程  Laravel中间件起什么作用_Laravel Middleware请求生命周期与自定义详解  网站制作价目表怎么做,珍爱网婚介费用多少？  怎么用AI帮你设计一套个性化的手机App图标？  Win11搜索不到蓝牙耳机怎么办 Win11蓝牙驱动更新修复【详解】  Linux系统命令中tree命令详解  品牌网站制作公司有哪些,买正品品牌一般去哪个网站买？  矢量图网站制作软件,用千图网的一张矢量图做公司app首页，该网站并未说明版权等问题，这样做算不算侵权？应该如何解决？  高防服务器：AI智能防御DDoS攻击与数据安全保障  如何在阿里云完成域名注册与建站？  Android GridView 滑动条设置一直显示状态(推荐)  晋江文学城电脑版官网 晋江文学城网页版直接进入  Laravel Asset编译怎么配置_Laravel Vite前端构建工具使用  Python进程池调度策略_任务分发说明【指导】  Linux网络带宽限制_tc配置实践解析【教程】  如何在IIS7上新建站点并设置安全权限？  Laravel如何使用Telescope进行调试？（安装和使用教程）  如何实现建站之星域名转发设置？  Laravel API资源类怎么用_Laravel API Resource数据转换  Laravel如何使用Laravel Vite编译前端_Laravel10以上版本前端静态资源管理【教程】  Laravel用户密码怎么加密_Laravel Hash门面使用教程  如何在IIS中新建站点并解决端口绑定冲突？  网站图片在线制作软件,怎么在图片上做链接？  今日头条微视频如何找选题 今日头条微视频找选题技巧【指南】  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办？  如何挑选高效建站主机与优质域名？  nodejs redis 发布订阅机制封装实现方法及实例代码  如何续费美橙建站之星域名及服务？  如何快速搭建高效可靠的建站解决方案？