首页 / JAVASCRIPT / 微信小程序websocket实现即时聊天功能

微信小程序websocket实现即时聊天功能

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了微信小程序websocket实现即时聊天功能，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9377字，纯文字阅读大概需要14分钟。

内容图文

今天给大家分享一下本人做小程序使用websocket的一点小经验，希望对大家有所帮助。

使用之前肯定首先要了解一下websocket是什么，简单来讲websocket就是客户端与服务器之间专门建立的一条特殊通道，请求只需要请求一次，而且还可以从通道实时获取服务器数据，非常适合应用到实时应用上。

因为这里本人是分享小程序，所以就不去深究websocket的底层和协议了，感兴趣的朋友可以去看下websocket协议

建议大家在做之前先看看微信小程序官方提供的api关于websocket的文档，因为微信的websocket接口虽然和HTML5的websocket基本一样但是语法上还是有少许偏差，了解一下还是很有必要的。

话不多说上代码（css代码就不贴了，就是一些简单的聊天样式排版）

wxml

<view>
 <scroll-view scroll-y="true" scroll-with-animation="true" scroll-x="false" scroll-into-view="list-{{idx}}" class="twnav">
 <view class='twChild'>
 <!-- <text>视频聊天室</text> -->
 <view class='tellRoom' wx:for="{{tellData}}" wx:for-index="idx" wx:for-item="li" wx:key="li" id='list-{{li.id}}'>
 <view class='myHead'>
 <image class='sayHead' wx-if='{{li.type=="question"||li.type=="message"}}' src='{{li.avatarurl}}'></image>
 <image class='sayHead' wx-if='{{li.type=="answer"}}' src='{{li.content.orgLogo}}'></image>
 </view>
 <view class='tellDetail'>
 <text class='name' wx-if='{{li.type=="question"||li.type=="message"}}'>{{li.displayName}}:</text>
 <text class='name' wx-if='{{li.type=="answer"}}'>{{li.content.orgName}}回复{{li.displayName}}:</text>
 <view wx-if='{{li.type=="answer"}}' class='answer'>
 <view class='anQue'>{{li.content.question}}</view>
 <view class='anAn'>{{li.content.answer}}</view>
 </view>
 <image wx-if='{{li.type=="question"}}' class='question' src='../../image/icon_quiz@2x.png' mode='widthFix'></image>
 <text class='sayDetail' wx-if='{{li.type=="question"}}'>{{li.content.content}}</text>
 <text class='sayDetail' wx-if='{{li.type=="message"}}'>{{li.content}}</text>
 </view>
 </view>
 <view class='ccds'></view>
 </view>
 </scroll-view>
 
 <view class='btn' wx-if='{{tell==true&&promodal==false}}'>
 <form bindreset="foo">
 <input class="myinput" placeholder="说点什么吧" bindinput="sayValue" focus='{{myinputing}}'/>
 <button form-type="reset" class='sub' wx-if='{{isSend=="send"||isSend=="sureAsk"}}' bindtap='sendMes'>发送</button>
 <button form-type="reset" class='sub' wx-if='{{isSend=="ask"}}' bindtap='ask'>问</button>
 </form>
 </view>
</view>

const app = getApp()
var server = app.globalData.myUrl//这是自己的服务端接口地址设置于app.js
var WxParse = require('../../wxParse/wxParse.js');
var tellPage = 1
var myurl='ws://+"你自己的链接地址"'
var ws // socket发送的消息队列
var socketMsgQueue = []
var socketOpen = true // 判断心跳变量
var heart = ''  // 心跳失败次数
var heartBeatFailCount = 0 // 终止心跳
var heartBeatTimeOut = null; // 终止重新连接
var connectSocketTimeOut = null;
Page({
 
 /**
 * 页面的初始数据
 */
 data: {
 sayValue:'',
 tellData:[],//聊天消息
 idx:'',
 id:'',
 fjh:'',//房间号
 myinputing:'',
 isSend: 'ask',
 },
 /**
 * 生命周期函数--监听页面加载
 */
 onLoad: function (options) {
 this.setData({
 id: options.id,
 fjh:options.roomNum,
 })
 this.history(1)
 this.connectStart()
 },
 /**
 * 生命周期函数--监听页面初次渲染完成
 */
 onReady: function () {
 //监听websocket连接状态
 this.deal()
 },
 /**
 * 生命周期函数--监听页面显示
 */
 onShow: function () {
 console.log()
 },
 /**
 * 生命周期函数--监听页面隐藏
 */
 onHide: function () {
 
 },
 /**
 * 生命周期函数--监听页面卸载
 */
 onUnload: function () {
 var that = this
 //离开页面销毁websocket并恢复初始数据
 wx.closeSocket()
 twice = 0
 socketOpen = true
 heart = ''  // 心跳失败次数
 heartBeatFailCount = 0 // 终止心跳
 heartBeatTimeOut = null; // 终止重新连接
 connectSocketTimeOut = null;
 },
 
 /**
 * 页面相关事件处理函数--监听用户下拉动作
 */
 onPullDownRefresh: function () {
 
 },
 /**
 * 页面上拉触底事件的处理函数
 */
 onReachBottom: function () {
 
 },
 /**
 * 用户点击右上角分享
 */
 onShareAppMessage: function () {
 console.log('点击分享')
 },
 //获取聊天室历史记录
 history: function (a) {
 var that = this
 wx.request({
 url: server + 'api/message/chatmsg',
 header: {
 "Authorization": app.globalData.token,
 },
 data: {
 page: a,
 type: '',
 resultsPerPage: 1000,
 stream: that.data.id
 },
 success: (res) => {
 var h = res.data.data.items
 if (h.length > 0) {
 var myArr = []
 var c = 0
 h.forEach(i => {
 c++
 i.id = c
 if (i.type == 'question' || i.type == 'answer') {
 i.content = JSON.parse(i.content)
 }
 myArr.push(i)
 })
 var j = h.length - 1
 var idx = h[j].id
 // console.log(h, idx)
 that.setData({
 tellData: h,
 idx: idx,
 })
 }
 
 }
 })
 },
 //与socket建立连接
 connectStart: function () {
 var that = this
 ws = wx.connectSocket({
 url: myurl,
 header: {
 "Authorization": app.globalData.token,
 'content-type': 'application/json'
 },
 data: JSON.stringify({
 token: app.globalData.token,
 type: 3,
 payLoad: {
 topic: that.data.fjh
 }
 }),
 success: (res) => {
 // console.log("进入聊天", res)
 },
 fail: (err) => {
 wx.showToast({
 title: '网络异常！',
 })
 console.log(err)
 },
 })
 
 // 连接成功
 wx.onSocketOpen((res) => {
 console.log('WebSocket 成功连接', res)
 that.resMes()
 // 开始心跳
 that.startHeartBeat()
 })
 //连接失败
 wx.onSocketError((err) => {
 console.log('websocket连接失败', err);
 twice=0
 that.connectStart()
 })
 },
 // 开始心跳
 startHeartBeat: function () {
 // console.log('socket开始心跳')
 var that = this;
 heart = 'heart';
 that.heartBeat();
 },
 // 心跳检测
 heartBeat: function () {
 var that = this;
 if (!heart) {
 return;
 }
 var xtData = {
 token: app.globalData.token,
 type: 1,
 payLoad: ""
 }
 // console.log(JSON.stringify({ xtData }))
 that.sendSocketMessage({
 msg: JSON.stringify(xtData),
 data: JSON.stringify(xtData),
 success: function (res) {
 // console.log('socket心跳成功',res);
 if (heart) {
 heartBeatTimeOut = setTimeout(() => {
 that.heartBeat();
 }, 5000);
 }
 },
 fail: function (res) {
 console.log('socket心跳失败');
 if (heartBeatFailCount > 2) {
 // 重连
 console.log('socket心跳失败')
 that.connectStart();
 }
 if (heart) {
 heartBeatTimeOut = setTimeout(() => {
 that.heartBeat();
 }, 5000);
 }
 heartBeatFailCount++;
 },
 });
 },
 // 进入聊天
 resMes: function () {
 var that = this
 var joinData = {
 token: app.globalData.token,
 type: 3,
 payLoad: JSON.stringify({
 topic: that.data.fjh
 }),
 }
 // console.log(joinData)
 that.sendSocketMessage({
 msg: JSON.stringify(joinData),
 data: JSON.stringify(joinData),
 success: function (res) {
 // console.log('进入房间成功', res);
 that.deal()
 },
 fail: function (err) {
 console.log('进入房间失败');
 },
 })
 },
 // 结束心跳
 stopHeartBeat: function () {
 // console.log('socket结束心跳')
 var that = this;
 heart = '';
 if (heartBeatTimeOut) {
 clearTimeout(heartBeatTimeOut);
 heartBeatTimeOut = null;
 }
 if (connectSocketTimeOut) {
 clearTimeout(connectSocketTimeOut);
 connectSocketTimeOut = null;
 }
 },
 // 消息发送
 foo: function () {
 if (this.data.inputValue) {
 //Do Something
 } else {
 //Catch Error
 }
 this.setData({
 inputValue: ''//将data的inputValue清空
 });
 return;
 },
 sayValue: function (e) {
 var that = this
 // console.log(this.data.isSend)
 if (that.data.isSend == 'ask') {
 that.setData({
 isSend: 'send'
 })
 }
 that.setData({
 sayValue: e.detail.value
 })
 },
 sendMes: function (e) {
 var that = this
 // console.log(this.data.sayValue, 111)
 var myInput = this.data.sayValue
 var token = app.globalData.token
 if (that.data.isSend == 'sureAsk') {
 wx.request({
 url: server + 'api/question/add',
 method: 'POST',
 header: {
 "Authorization": app.globalData.token,
 'content-type': 'application/json'
 },
 data: {
 content: myInput,
 streamId: that.data.id
 },
 success: (res) => {
 console.log(res, '我的提问')
 }
 })
 } else {
 // console.log(app.globalData.userInfo)
 var chatInfo = {
 user: app.globalData.userInfo.id,
 displayName: app.globalData.userInfo.displayName,
 avatarurl: app.globalData.userInfo.avatarUrl,
 stream: that.data.id,
 content: myInput,
 type: "message",
 createdat: "2018-10-8 14:30"
 }
 var sendData = {
 token: token,
 type: 2,
 payLoad: JSON.stringify({
 topic: that.data.fjh,
 chatInfo: JSON.stringify(chatInfo)
 })
 }
 // console.log(JSON.stringify(sendData))
 that.sendSocketMessage({
 msg: JSON.stringify(sendData)
 })
 }
 that.setData({
 sayValue: '',
 isSend: 'ask'
 })
 
 
 
 },
 // 通过 WebSocket 连接发送数据
 sendSocketMessage: function (options) {
 var that = this
 if (socketOpen) {
 wx.sendSocketMessage({
 data: options.msg,
 success: function (res) {
 if (options) {
 options.success && options.success(res);
 }
 },
 fail: function (res) {
 if (options) {
 options.fail && options.fail(res);
 }
 }
 })
 } else {
 socketMsgQueue.push(options.msg)
 }
 // ws.closeSocket();
 // that.deal()
 },
 // 监听socket
 deal: function () {
 var that = this
 ws.onOpen(res => {
 socketOpen = true;
 console.log('监听 WebSocket 连接打开事件。', res)
 })
 ws.onClose(onClose => {
 console.log('监听 WebSocket 连接关闭事件。', onClose)
 // socketOpen = false;
 // that.connectStart()
 })
 ws.onError(onError => {
 console.log('监听 WebSocket 错误。错误信息', onError)
 socketOpen = false
 })
 ws.onMessage(onMessage => {
 var res = JSON.parse(onMessage.data)
 // console.log(res,"接收到了消息")
 if (res.code == 200) {
 // console.log('服务器返回的消息', res.data)
 var resData = JSON.parse(res.data)
 var arr = that.data.tellData
 resData.id = arr.length + 1
 if (resData.type == 'question' || resData.type == 'answer') {
 resData.content = JSON.parse(resData.content)
 
 console.log('这是提问', resData.type, resData.content.content)
 }
 arr.push(resData)
 console.log(resData, arr.length)
 that.setData({
 tellData: arr,
 idx: resData.id
 })
 } else {
 }
 })
 
 },
 time: function (a) {
 var data = new Date(a)
 var year = data.getFullYear();
 var month = data.getMonth() + 1;
 var day1 = data.getDate();
 var hh = data.getHours(); //截取小时
 var mm = data.getMinutes(); //截取分钟
 if (month < 10) {
 month = '0' + month
 }
 if (day1 < 10) {
 day1 = '0' + day1
 }
 if (hh < 10) {
 hh = '0' + hh
 }
 if (mm < 10) {
 mm = '0' + mm
 }
 
 var newday = month + "月" + day1 + ' ' + hh + ':' + mm
 return newday
 },
 inputing: function () {
 console.log('获取焦点')
 this.setData({
 isSend: 'send'
 })
 },
 inputed: function () {
 // console.log('失去焦点')
 this.setData({
 isSend: 'ask',
 
 })
 },
 ask: function () {
 // console.log('提问')
 this.setData({
 myinputing: true,
 isSend: 'sureAsk'
 })
 },
 
})

以上仅是前端部分本人小程序websocket的使用实例，具体的情况需要配合自己的服务端。希望对大家有所帮助，也欢迎大家互相讨论。

内容总结

以上是互联网集市为您收集整理的微信小程序websocket实现即时聊天功能全部内容，希望文章能够帮你解决微信小程序websocket实现即时聊天功能所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/331560.html

来源：【匿名】

【上一篇】微信小程序系列之自定义顶部导航功能【下一篇】javascript 怎么调用php方法

更多 ►

【微信小程序websocket实现即时聊天功能】教程文章相关的互联网学习教程文章

javascript中WebSocket用法【代码】【图】

一.概念websocket定义WebSocket是html5提供的一种在单个TCP连接上进行双向通信的协议，解决了客户端和服务端之间的实时通信问题。浏览器和服务器只需完成一次握手，两者之间就可以创建一个持久性的TCP连接，此后服务器和客户端通过此TCP连接进行双向实时通信。websocket优点很多网站为了实现数据推送，所用的技术都是ajax轮询。轮询是在特定的时间间隔，由浏览器主动发起请求，将服务器的数据拉回来。轮询需要不断的向服务器发送请...

实现 WebSocket 断开自动重连的 JavaScript 库【代码】

ReconnectingWebSocket 是一个小型的 JavaScript 库，封装了 WebSocket API 提供了在连接断开时自动重连的机制。只需要简单的将：ws = new WebSocket(‘ws://....‘);替换成：ws = new ReconnectingWebSocket(‘ws://....‘); 详见：https://github.com/fc653074701/reconnecting-websocket 或者： //间隔发送心跳包数据给服务器，服务器在一定时间内发回心跳包响应，对比超时限定，如果超过设定的超时时间，则认为当前与服务器的...

javascript-通过js用websocket连接打印机进行打印问题

通过js 用websocket 连接打印机进行打印，已知打印机的端口是默认开的，通过PHP代码 $s = fsockopen("192.168.1.122", 8081,$errno, $errstr, 30);fwrite($s,"abcjiuejseeeeeeeee2222222222ss"); 这样打印是可以的，但通过JS的websocket连接就只打印头信息，是什么情况？ js 代码是： ws = new WebSocket("ws://192.168.1.122:8081/"); console.log(ws); ws.onopen = function (e) {console.log(e);console.log("连接成功");ws.se...

javascript-Websocket服务器端用PHP怎么配置？

在网上搜了很多，有些不能用，有些看不懂。 websocket客户端代码没什么问题，问题就在服务器端php该怎么写？是像ajax那样就行还是需要php socket? 求解！回复内容：在网上搜了很多，有些不能用，有些看不懂。 websocket客户端代码没什么问题，问题就在服务器端php该怎么写？是像ajax那样就行还是需要php socket? 求解！不一定非要用php，php不擅长做这个,可以试一下 socket.io一个Redis的Web代理服务器Webdis? http://www.qixing...

javascript-浏览器中使用websocket有什么好的库？

要支持IE8以上的。网上一搜都是socket.io但是这个也好配合node.js使用。我的服务端使用的是php。回复内容：要支持IE8以上的。网上一搜都是socket.io但是这个也好配合node.js使用。我的服务端使用的是php。PHP写WebSocket需要自己处理原始数据，前端库本质上只是一种常用方法的封装，socket.io就可以。WebSocket是HTML5 API，是内置在浏览器内部的高级特性，IE8绝对不支持，而且客户端javascript也没有牛逼到可以自定义协议的地步...

javascript-websocket如何部署？

碰到的问题如下：静态页面地址192.168.8.79websocket server地址192.168.8.78:9876 于是静态页面想与websocket连接，却碰到浏览器chrome不能跨域访问websocket.回复内容：碰到的问题如下：静态页面地址192.168.8.79websocket server地址192.168.8.78:9876 于是静态页面想与websocket连接，却碰到浏览器chrome不能跨域访问websocket.可以让你的前端(比如nginx)做代理访问你的192.168.8.78:9876。nginx反代是实现跨域最简单的方法

javascript-websocket与EventSource的区别在哪里？作为wordpress主题使用，哪个更利好？

wordpress主题中需要一个消息通知服务，我就半吊子水平，各路大神来指点一二。websocket与EventSource的区别在哪里，在WP主题的场景中哪个更利用，比如PHP服务器的部署，比如json之类的数据格式？或者是jquery写个短轮询。回复内容：wordpress主题中需要一个消息通知服务，我就半吊子水平，各路大神来指点一二。websocket与EventSource的区别在哪里，在WP主题的场景中哪个更利用，比如PHP服务器的部署，比如json之类的数据格式？或...

javascript-怎么配置WebSocket服务器，用的SegmentFault

rt想用websocket代替轮询请问怎么配置websocket服务器回复内容：rt想用websocket代替轮询请问怎么配置websocket服务器PHP自身并没有提供WebSocket相关函数,这个你得用第三方扩展,比如峰哥的用C开发的PECL扩展Swoole,里面直接就封装有WebSocket Server,比如官网的示例:http://www.swoole.com/ on('Open', function($server, $req) {echo "connection open: ".$req->fd; }); $serv->on('Message', function($server, $frame) {echo "...

javascript-WebSocket如何向指定页面推送

已经把PHP的WebSocket框架Demo跑起来了(workerman -> web-msg-sender) 现在遇到个问题，就是如何像指定页面推送信息。比如每个用户的首页，和每个用户的收藏列表页，和一些公共的商品列表页，这些页面价格都是实时更新的。目前我想到的方法是： 1、当商品价格被执行更新后，从表中取出对应的商品信息 2、公共页：如首页，商品列表页；后台指定推送URL为这些页面，推送刚刚更新的商品ID和价格。JS获取后判断当前页面是否存在推送的...

javascript-php和websocket怎么建立连接

H5的WebSocket 怎么和服务端建立连接，网上找了几个例子都不好使，具体应该怎么做回复内容：H5的WebSocket 怎么和服务端建立连接，网上找了几个例子都不好使，具体应该怎么做个人理解的是1、了解websocket的协议和请求规范；2、使用PHP的socket函数库来处理websocket的请求；3、处理websocket的数据帧。下面是我写的一个小例子，里面的注释我觉得也挺详细的了，对帧的处理我没有完善，处理41字节以上的内容，要了解各种字处理。。。...

关于WebSocket的那些事儿

众所周知传统的http协议是客户端（浏览器）发送请求，浏览器响应请求的方式，一条请求对应一条响应。若浏览器不主动请求则服务端无法想客户端主动推数据。传统的方式是使用AJAX轮询（这个方式有它的问题）来解决这一问题后面展开讲。应用场景列举几个应用场景：网络聊天室多人在线游戏网站向页面实时推送广告、消息在线实现对控制设备的控制前面三个应用场景已经有很多大佬讲过了，我就不讲了，这里主要简单分析一下第四个应用场景...

WebSocket如何使用【图】

WebSocket是一种允许通过保持服务器端和用户端始终连接来进行双向通信的技术，这使得可以实时通信，例如聊天应用程序和多人可以同时玩的游戏。但是，由于还需要服务器端的程序，本篇文章我们将重点介绍前端的JavaScript中的WebSocket。我们先来看一下WebSocket的基本用法。为了能够使用带有JavaScript的WebSocket，首先要创建实例。var connection = new WebSocket(【进行通信的URL】);通过new一个WebSocket来创建实例。指定为参数...

如何使用WebSocket发送和接收数据【图】

WebSocket是一种允许通过保持服务器端和用户端始终连接来进行双向通信的技术，所以WebSocket既可以发送数据也可以接收数据，本篇文章我们就来看看如何使用WebSocket发送和接收数据。我们先来看一下如何发送文本数据？使用免费提供的echo.websocket.org作为样本具体示例如下var connection = new WebSocket(wss://echo.websocket.org);connection.send(样本数据);在此示例中，以看到正在创建WebSocket实例并使用send()方法发送数据。...

在nodejs中如何实现websocket通信功能

这篇文章主要介绍了nodejs结合socket.io实现websocket通信功能的方法,结合实例形式分析了nodejs结合socket.io实现websocket通信的具体步骤与相关操作技巧,需要的朋友可以参考下本文实例讲述了nodejs结合socket.io实现websocket通信功能的方法。分享给大家供大家参考，具体如下：因为项目中有需要实时获取后台数据的场景，之前一直是使用http心跳请求的方法。因为websocket与此模式相比有很大的性能提升，而且可以提高实时性，所以对...

nodejs+websocket案例分析（附代码）

这次给大家带来nodejs+websocket案例分析（附代码），nodejs+websocket案例分析的注意事项有哪些，下面就是实战案例，一起来看一下。服务端（nodejs）：var WebSocketServer = require(ws).Server, wss = new WebSocketServer({ port: 8080 }); wss.on(connection, function (ws) { console.log(client connected); ws.on(message, function (message) {console.log(message); }); });客户端：<script> var ws = new WebSocket("ws...

首页 / JAVASCRIPT / 微信小程序websocket实现即时聊天功能

微信小程序websocket实现即时聊天功能

内容导读

内容图文

内容总结

内容备注

内容手机端

【微信小程序websocket实现即时聊天功能】教程文章相关的互联网学习教程文章

WEBSOCKET - 相关标签

程序 - 相关标签

功能 - 相关标签

JAVASCRIPT - 技术教程分类

JAVASCRIPT - 最新教程

JAVASCRIPT - 最热教程