uniapp开发app框架在提升开发效率中的独特优势与应用探索
445
2023-11-14
如何利用微信小程序和php实现即时通讯聊天功能
−目录一、PHP7安装Swoole扩展1、自定义安装2、宝塔面板安装PHP swoole扩展二、配置nginx反向代理三、微信小程序socket合法域名配置四、效果演示和代码1、小程序端代码2、服务端代码（PHP代码）五、代码已经编写完了 总结
一、PHP7安装Swoole扩展
PHP swoole 扩展-
Github：https://github.com/swoole/swoole-src/tags
php官方扩展库：http://pecl.php-/package/swoole
开源中国：http://git.oschina-/swoole/swoole/tags
1、自定义安装
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
# -
wget https://pecl.php-/get/swoole-4.3.3.tgz
# 解压
tar zxf swoole-4.3.3.tgz
# 编译安装扩展
# 进入目录
cd swoole-4.3.3
# 执行phpize命令，产生出configure可执行文件
# 如果不知道phpize路径在哪里 可以使用which phpize查看相应路径
/usr/bin/phpize
# 进行配置 如果不知道php-config路径在哪里 可以使用which php-config 查看相应路径
./configure --with-php-config=/usr/bin/php-config
# 编译和安装
make && make install
vi /etc/php.ini
复制如下代码
extension=swoole.so
放到你所打开或新建的文件中即可，无需重启任何服务
# 查看扩展是否安装成功
php -m|grep swoole
2、宝塔面板安装PHP swoole扩展
如果感觉上述安装较为复杂，可以使用宝塔面板实现一键安装
二、配置nginx反向代理
1、使用xshell连接远程阿里云服务器
2、使用命令（find / -name nginx.conf）查找nginx.conf所在的配置文件
3、使用命令（vim /etc/nginx/nginx.conf）查找进入到vim编辑器
查看到可以引入/etc/nginx/conf.d/下的配置文件信息
4、使用命令（cd /etc/nginx/conf.d/）进入到该路径下，并新建配置文件：study.lishuo-.conf
5、配置nginx反向代理,实现访问study.lishuo-域名转发端口号到127.0.0.1:9511也就是转发到webscoket运行的端口号
三、微信小程序socket合法域名配置
1、登录到微信开放平台https://mp.weixin.qq.com/
2、开发=>开发管理=>开发设置，完成合法域名设置
3、到此配置已经完成了，接下来就是功能实现了，微信小程序+PHP代码
四、效果演示和代码
1、小程序端代码
小程序页面代码所在路径 /pages/contact/contact.wxml
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
<!--pages/contact/contact.wxml-->
<view>
<scroll-view scroll-y scroll-into-view={{toView}} style=height: {{scrollHeight}};>
<!-- <view class=scrollMsg> -->
<block wx:key wx:for={{msgList}} wx:for-index="index">
<!-- 单个消息1 客服发出（左） -->
<view wx:if={{item.speaker=="server"}} id=msg-{{index}} style=display: flex; padding: 2vw 11vw 2vw 2vw;>
<view style=width: 11vw; height: 11vw;>
<image style=width: 11vw; height: 11vw; border-radius: 10rpx; src=https://cdn.pixabay.com/photo/2020/02/10/12/47/girl-4836394__340.jpg></image>
</view>
<view style=width: 4vw; height: 11vw; margin-left: 0.5vw; display: flex; align-items: center; z-index: 9;>
<view class="triangle_border_left"></view>
</view>
<view class=leftMsg>{{item.content}}</view>
</view>
<!-- 单个消息2 用户发出（右） -->
<view wx:else id=msg-{{index}} style=display: flex; justify-content: flex-end; padding: 2vw 2vw 2vw 11vw;>
<view class=rightMsg>{{item.content}}</view>
<view style=width: 4vw; height: 11vw; margin-right: 0.5vw; display: flex; align-items: center; z-index: 9;>
<view class="triangle_border_right"></view>
</view>
<view style=width: 11vw; height: 11vw;>
<image style=width: 11vw; height: 11vw; border-radius: 10rpx; src=https://cdn.pixabay.com/photo/2021/09/24/10/00/chick-6652163__340.jpg></image>
</view>
</view>
</block>
<!-- </view> -->
<!-- 占位 -->
<view style=width: 100%; height: 18vw;></view>
</scroll-view>
<view class=inputRoom style=bottom: {{inputBottom}}>
<image style=width: 7vw; margin-left: 3.2vw; src=https://img95.699pic.com/element/40030/6429.png_300.png mode=widthFix></image>
<input bindconfirm=sendClick adjust-position={{false}} value={{inputVal}} confirm-type=send bindfocus=focus bindblur=blur></input>
</view>
</view>
2、小程序页面样式代码所在路径 /pages/contact/contact.wxss
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
/* pages/contact/contact.wxss */
page {
background-color: #f1f1f1;
}
.inputRoom {
width: 100vw;
height: 16vw;
border-top: 1px solid #cdcdcd;
background-color: #f1f1f1;
position: fixed;
bottom: 0;
display: flex;
align-items: center;
z-index: 20;
}
input {
width: 76vw;
height: 9.33vw;
background-color: #fff;
border-radius: 40rpx;
margin-left: 2vw;
padding: 0 3vw;
font-size: 28rpx;
color: #444;
}
.leftMsg {
font-size: 35rpx;
color: #444;
line-height: 7vw;
padding: 2vw 2.5vw;
background-color: #fff;
margin-left: -1.6vw;
border-radius: 10rpx;
z-index: 10;
}
.rightMsg {
font-size: 35rpx;
color: #444;
line-height: 7vw;
padding: 2vw 2.5vw;
background-color: #96EB6A;
margin-right: -1.6vw;
border-radius: 10rpx;
z-index: 10;
}
/*向左*/
.triangle_border_left {
width: 0;
height: 0;
border-width: 10px 30px 30px 0;
border-style: solid;
border-color: transparent #fff transparent transparent;
/*透明 黄 透明 透明 */
margin: 40px auto;
position: relative;
}
/*向右*/
.triangle_border_right {
width: 0;
height: 0;
border-width: 0px 30px 20px 13px;
border-style: solid;
border-color: transparent transparent transparent #96EB6A;
/*透明 透明 透明 黄*/
margin: 40px auto;
position: relative;
}
小程序配置文件代码所在路径 /pages/contact/contact.json
?
1
2
3
4
5
6
{
"navigationBarTitleText":"柯作客服",
"usingComponents": {
}
}
小程序业务逻辑代码所在路径 /pages/contact/contact.js
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
// pages/contact/contact.js
const app = getApp();
var inputVal = ;
var msgList = [];
var windowWidth = wx.getSystemInfoSync().windowWidth;
var windowHeight = wx.getSystemInfoSync().windowHeight;
var keyHeight = 0;
/**
* 初始化数据
*/
function initData(that) {
//输入框的内容
inputVal = ;
//消息列表，包含客服和用户的聊天内容
msgList = [{
speaker: server,
contentType: text,
content: Hi，亲爱的小主，终于等到您啦！欢迎来到柯作店铺，很荣幸为您服务。
},
{
speaker: customer,
contentType: text,
content: 你高兴的太早了
}
]
that.setData({
msgList,
inputVal
})
}
Page({
/**
* 页面的初始数据
*/
data: {
scrollHeight: 100vh,
inputBottom: 0
},
/**
* 生命周期函数--监听页面加载
*/
onLoad: function(options) {
//初始化websocket连接
this.chat();
//监听心跳的方法
this.webSocketXin();
//聊天方法
initData(this);
//监听消息
wx.onSocketMessage(res=>{
//追加到消息列表里
msgList.push(JSON.parse(res.data))
inputVal = ;
this.setData({
msgList,
inputVal
});
})
},
//页面卸载时间
onUnload(){
wx.closeSocket();
},
/**
* 获取聚焦
*/
focus: function(e) {
keyHeight = e.detail.height;
this.setData({
scrollHeight: (windowHeight - keyHeight) + px
});
this.setData({
toView: msg- + (msgList.length - 1),
inputBottom: keyHeight + px
})
//计算msg高度
// calScrollHeight(this, keyHeight);
},
//失去聚焦(软键盘消失)
blur: function(e) {
this.setData({
scrollHeight: 100vh,
inputBottom: 0
})
this.setData({
toView: msg- + (msgList.length - 1)
})
},
/**
* 发送点击监听
*/
sendClick: function(e) {
//客户发的信息
let customerMsg = {
uid: 10,
speaker: customer,
contentType: text,
content: e.detail.value
};
//关闭心跳包
this.webSocketXin(60000, false)
//发送给websocket
wx.sendSocketMessage({
data: JSON.stringify(customerMsg),
success:res=>{
//重启心跳包
this.webSocketXin(40000, true)
}
})
//追加到消息列表里
msgList.push(customerMsg)
inputVal = ;
this.setData({
msgList,
inputVal
});
},
/**
* 退回上一页
*/
toBackClick: function() {
wx.navigateBack({})
},
/**
* websocket
*/
chat(){
//进行连接php的socket
wx.connectSocket({
//wss 协议相当于你要有一个ssl证书，https
//ws 就相当于不实用证书 http
url: ws://study.lishuo-,
success: function () {
console.log(websocket连接成功~)
},
fail: function () {
console.log(websocket连接失败~)
}
})
},
/**
* 监听websocket心跳连接的方法
*/
webSocketXin(time=60000,status=true){
var timing;
if(status == true){
timing = setInterval(function () {
console.log("当前心跳已重新连接");
//循环执行代码
wx.sendSocketMessage({
data: JSON.stringify({
type: active
}),
fail(res) {
//关闭连接
wx.closeSocket();
//提示
wx.showToast({
title: 当前聊天已断开,
icon:none
})
clearInterval(timing);
console.log("当前心跳已关闭");
}
});
}, time) //循环时间，注意不要超过1分钟
} else {
//关闭定时器
clearInterval(timing);
console.log("当前心跳已关闭");
}
}
})
2、服务端代码（PHP代码）
wechat_websocket.php
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
<?php
//创建WebSocket Server对象，监听0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server(0.0.0.0, 9511);
//监听WebSocket连接打开事件
$ws->on(Open, function ($ws, $request) {
echo $request->fd . 我连接上了;
});
//监听WebSocket消息事件
$ws->on(Message, function ($ws, $frame) {
//把前台传过来的json字符串转成数组
$params = json_decode($frame->data, true);
//判断是否是心跳消息,如果是心跳消息
if (isset($params[type]) && isset($params[type])==active){
echo 这是心跳监听消息;
}else{
//先判断当前用户有没有正在连接
if (isset($params[uid]) && !empty($params[uid] == 666)) {
//去用户表查询当前用户 fd
$fd = 2;
} else {
$fd = 1;
}
//客服id
$ws->push($fd, json_encode($params, JSON_UNESCAPED_UNICODE));
}
});
//监听WebSocket连接关闭事件
$ws->on(Close, function ($ws, $fd) {
echo "client-{$fd} is closed\n";
});
$ws->start();
五、代码已经编写完了
1、把服务端代码上传到Linux操作系统里
2、然后切到该目录下进行运行php wechat_websocket.php
总结
您可能感兴趣的文章:PHP+jquery+ajax实现即时聊天功能实例值得分享的php+ajax实时聊天室如何用PHP websocket实现网页实时聊天微信小程序实现即时通信聊天功能的实例代码微信小程序websocket实现即时聊天功能使用node.js实现微信小程序实时聊天功能微信小程序实时聊天WebSocket详解微信小程序开发聊天室—实时聊天，支持图片预览
版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。
相关文章
发表评论
最近发表
推荐文章
热评文章
暂时没有评论，来抢沙发吧~