解决sockjs、stomp在uni-app端使用的坑


  我们项目之前前后端使用的是Stomp + SockJs实现的在线直播的实时聊天,现在需要搬到app上,所以要在uni-app上面也实现一次,结果就很自然的出问题了。下面整理一下在uniapp整合WebSocket中遇到的bug。

1、第一次尝试

  先像web开发一样去写:先引入stomjs和sockjs包,然后用 new SockJS(url) 的方式去实例化SockJs,然后通过创建StompClient去连接订阅。

  H5时连接没有任何问题,但换到uni-app的时候问题就来了,sockjs.js里面用了一点操作DOM元素的方法,比如document.getElementsByTagName,uni-app是解析不了的,原生的微信小程序好像也解析不了。

2、第二次尝试

  这次放弃了使用外部的js,采用原生的uni.connectSocket()的方式创建连接。

SocketTask = uni.connectSocket({
  url: 'http://***:8081/socket',   //url: 'ws://localhost:8081/socket',
  data: 'data',   header: {     'content-type': 'application/json'   },   method: 'post',   success: function(res) {     console.log('WebSocket连接创建', res)   },   fail: function(err) {     uni.showToast({       title: '网络异常!',     })     console.log(err)   }, })

  代码中显示的就很清楚了,uni-app连接websocket的时候要是用ws或者wss,相当于http和https,不然就会报无效的url这种异常,但是这个时候还是会抛异常:Error during WebSocket handshake: Unexpected response code: 200

  其中遇到的问题就是使用原生websocket怎么也连不上的问题,后来就查看服务端是如何处理sockjs的。然后我就拉取了后端代码,去后端代码里最好找到了问题的关键,先贴一下服务端配置:

 @Override //用来注册Endpoint,“/event-websocket”即为客户端尝试建立连接的地址。
    public void registerStompEndpoints(StompEndpointRegistry registry) { registry .addEndpoint("/event-websocket") .setAllowedOrigins("*") .withSockJS(); }

  可以看到服务端是开启了sockjs模式的,将此处的withSockJS()去除,就可以通过原生方式连接了。因为sockjs在浏览器不支持wobsoket请求是会自动切换为http请求轮训方式。

  但是去除withSockJS(),那么web就无法连接了,怎么办呢?可以注册建立2个链接地址,一个给web使用sockjs模式,另一个给app使用,不使用sockjs模式。

 @Override //用来注册Endpoint,“/event-websocket”即为客户端尝试建立连接的地址。
    public void registerStompEndpoints(StompEndpointRegistry registry) { registry .addEndpoint("/event-websocket") .setAllowedOrigins("*") .withSockJS(); registry .addEndpoint("/event-websocket-app") .setAllowedOrigins("*"); }

3、第3次尝试

  经过上述处理,以为万事大吉了,但是结果在安卓app上是可以正常建立链接的,但是在ios app上却不行,百思不得解,最后解决方式是将域名模式改成ip模式就可以了

// 连接后台
initSocket () {   let that = this   let _unitoken = uni.getStorageSync('token')   let _token = _unitoken ? _unitoken.substring(7) : ''
  // 当未登录或登录失效时后台根据_randomUserId模拟匿名用户
  let _randomUserId = (-generateRandom(100000))   let _eventId = this.params.eventId   let sockUrl = wsdomain + `event-websocket-app?eventId=${_eventId}&token=${_token}&userId=${_randomUserId}`   let socket = new UniWebSocket(sockUrl)   this.stompClient = Stomp.over(socket)   this.stompClient.connect({}, (res) => {     // 订阅服务端提供的某个topic
    this.stompClient.subscribe(`/topic/event/${_eventId}`, (frame) => {       that.addBarage(JSON.parse(frame.body))     })     that.sentFirst()   }, (err) => {     console.log('失败:' + err)     if (this.infoCount > 5) {       let _speaker = this.event.currentAgendaSpeaker || {}       let _tip = {         headimgurl: _speaker.icon,         name: _speaker.name,         text: '温馨提示:您的连接已断开,将无法收到聊天信息,请退出直播间重新进入。'       }       this.infoFlow.push(_tip)       this.infoCount = 0     }     if (!this.timer) this.resetWebSocket()     else clearInterval(this.timer)   })   this.stompClient.debug = null },

  wsdomain由原域名形式换成ip形式就可以了。

wss://dev.modb.pro/ws/
 ws://服务器ip:8080/

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM