利用php websocket实现小程序消息推送或即时通信功能 wss的实现
小程序没有消息推送功能,要想实现可以通过php的websocket来实现
一.配置服务器.
1.上传web-msg-sender目录到服务器
(官方地址https://www.workerman.net/web-sender 下载地址:https://www.workerman.net/download/senderzip)
2.修改start_io.php文件修改证书路径(nginx证书)小程序跳过此步小程序需要使用反向代理下面会有介绍
$sender_io = new SocketIO(2120);
修改成
$context = array( 'ssl' => array( 'local_cert' => '/ssl/cn_bundle.crt', 'local_pk' => '/ssl/pk.key', 'verify_peer' => false, ) ); // PHPSocketIO服务 $sender_io = new SocketIO(2120,$context);
证书可以通过腾讯云申请,下载后选择里面的nginx证书即可
3.参考http://doc.workerman.net/faq/disable-function-check.html检查环境
如有禁用函数vi /usr/local/php/etc/php.ini 找到disable_functions 删除禁用项
4.进入web-msg-sender目录 后执行启动命令 windows系统进入到框架目录里双击start_for_win.bat文件启动
php start.php start -d
5.将2120 2121 端口开放权限 并加入云服务器安全组
可以在cmd中执行 telnet 域名 2120 测试是否已经连通
6.别忘了把域名或ip添加到微信小程序授权域名的wss域名中,否则是无法访问的
二.配置客户端
1小程序客户端(前提必须事先配置好https域名证书及授权域名)
weapp.socket.io.js文件下载
http://fourpan.com/fs/exi6ao0gg6vi9pdf04/
https://github.com/10cella/weapp.socket.io
const io = require('../../utils/weapp.socket.io.js') Page({ /** * 页面的初始数据 */ data: {}, /** * 生命周期函数--监听页面加载 */ onLoad: function () { var that = this; var uid='bitefu1'; const socket = io('https://域名');//此处必须是域名 小程序不支持ip socket.on('connect', () => { console.log(socket.connected); // true socket.emit('login', uid); }); socket.on('new_msg', d => { console.log('received news: ', d);//在这里接收消息并自行处理提醒 }) } })
注:小程序不能设置端口所以必须进行反向代理.设置方法如下.并且 workerman原生和nginx代理 两种https 不能共存 否则会报错
https://github.com/walkor/phpsocket.io/tree/master/docs/zh#%E6%94%AF%E6%8C%81sslhttps-wss
apache反向代理:https://www.cnblogs.com/skyfeng/articles/6628903.html
iis反射代理:https://www.cnblogs.com/pengcc/p/4329207.html
2.网页客户端
便于发送测试特意发个web端方便测试用.
<!DOCTYPE html> <html> <head> <meta http-equiv="content-type" content="text/html;charset=utf-8"> <script src='https://cdn.bootcss.com/socket.io/2.0.3/socket.io.js'></script> <script src='//cdn.bootcss.com/jquery/1.11.3/jquery.js'></script> <script> var domain='域名或ip'; </script> </head> <body> <div style="width:850px;"> <h3>测试:</h3> 当前用户uid:<b class="uid"></b><br> 可以通过url:<a id="send_to_one" href="" target="_blank"><font style="color:#91BD09">http://<font class="domain"></font>:2121?type=publish&to=<b class="uid"></b>&content=消息内容</font></a> 向当前用户发送消息<br> 可以通过url:<a href="" target="_blank" id="send_to_all" ><font style="color:#91BD09">http://<font class="domain"></font>:2121?type=publish&to=&content=消息内容</font></a> 向所有在线用户推送消息<br> <script> // 使用时替换成真实的uid,这里方便演示使用时间戳 var uid = Date.parse(new Date()); $('#send_to_one').attr('href', 'http://'+domain+':2121/?type=publish&content=%E6%B6%88%E6%81%AF%E5%86%85%E5%AE%B9&to='+uid); $('.uid').html(uid); $('#send_to_all').attr('href', 'http://'+domain+':2121/?type=publish&content=%E6%B6%88%E6%81%AF%E5%86%85%E5%AE%B9'); $('.domain').html(domain); </script> </div> <script> $(document).ready(function () { // 连接服务端 var socket = io('https://'+domain+':2120'); // 连接后登录 socket.on('connect', function(){ socket.emit('login', uid); }); // 后端推送来消息时 socket.on('new_msg', function(msg){ $('#content').append('收到消息:'+msg+'<br>'); }); // 后端推送来在线数据时 socket.on('update_online_count', function(online_stat){ $('#online_box').html(online_stat); }); }); </script> <div id="online_box"></div> <div id="content"></div> </body> </html>
三服务端发消息
<?php // 指明给谁推送,为空表示向所有在线用户推送 $to_uid = 'bitefu1'; // 推送的url地址,使用自己的服务器地址 $push_api_url = "http://域名或ip:2121/"; $content='大家好啊'; $post_data = array( "type" => "publish", "content" =>$content , "to" => $to_uid, ); $res=curlget($push_api_url,$post_data,'POST',array(),true); var_export($res); function curlget($url, $params='', $method = 'GET', $header = array(), $multi = false,$debug=false,$optsother='') { $opts = array(CURLOPT_TIMEOUT => 10,CURLOPT_RETURNTRANSFER=> 1,CURLOPT_SSL_VERIFYPEER=> false,CURLOPT_SSL_VERIFYHOST=> false,CURLOPT_HTTPHEADER => $header); switch (strtoupper($method)) {/* 根据请求类型设置特定参数 */ case 'GET':$opts[CURLOPT_URL] = $params?$url.'?'.http_build_query($params):$url;break; case 'POST':$params = $multi ? $params : http_build_query($params);//判断是否传输文件 $opts[CURLOPT_URL] = $url;$opts[CURLOPT_POST] = 1;$opts[CURLOPT_POSTFIELDS] = $params;break; default:if($debug)E('不支持的请求方式!');break; }$ch = curl_init();if($optsother && is_array($optsother))$opts=$opts+$optsother;curl_setopt_array($ch, $opts);$data = curl_exec($ch);$error = curl_error($ch);curl_close($ch);/* 初始化并执行curl请求 */ if($error && $debug){E('请求发生错误:'.$error);} return $data; }
![](/img/my/wx.png)
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
手把手教程:用Python开发一个自然语言处理模型,并用Flask进行部署
截住到目前为止,我们已经开发了许多机器学习模型,对测试数据进行了数值预测,并测试了结果。实际上,生成预测只是机器学习项目的一部分,尽管它是我认为最重要的部分。今天我们来创建一个用于文档分类、垃圾过滤的自然语言处理模型,使用机器学习来检测垃圾短信文本消息。我们的ML系统工作流程如下:离线训练->将模型作为服务提供->在线预测。 1、通过垃圾邮件和非垃圾邮件训练离线分类器。 2、经过训练的模型被部署为服务用户的服务。 当我们开发机器学习模型时,我们需要考虑如何部署它,即如何使这个模型可供其他用户使用。Kaggle和数据科学训练营非常适合学习如何构建和优化模型,但他们并没有教会工程师如何将它们带给其他用户使用,建立模型与实际为人们提供产品和服务之间存在重大差异。 在本文中,我们将重点关注:构建垃圾短信分类的机器学习模型,然后使用Flask(用于构建Web应用程序的Python微框架)为模型创建API。此API允许用户通过HTTP请求利用预测功能。让我们开始吧! 构建ML模型 数据是标记为垃圾邮件或正常邮件的SMS消息的集合,可在此处找到。首先,我们将使用此数据集构建预测模型,以准...
- 下一篇
且听我一个故事讲透一个锁原理之synchronized
微信公众号:IT一刻钟。 大型现实非严肃主义现场, 一刻钟与你分享优质技术架构与见闻,做一个有剧情的程序员。 关注可第一时间了解更多精彩内容,定期有福利相送哟。 故事从这里展开 蜀国有一个皇帝叫蜀道难,他比较难伺候,别的皇帝早朝都是在大殿上同时接见所有大臣,共商国是。 他不一样,他说早朝你们不要有事没事都跑过来叽叽喳喳,有事则来,无事则该干啥干啥去,然后安排太监每天早上在大门口守着,每次只允许一个大臣进来汇报情况。 “你敢多放进来一个就砍脑袋的干活。“ 太监赶紧下跪,说“谪!“。 第一天,太监传话钦天监求见,皇帝允了,钦天监上殿报曰:”臣禀报,昨日我司夜观星象,西方忽现王星忽明忽暗,恐戎狄那边有乱。“ “朕知道了,退下吧”。一日无事。 第二天,太监传话钦天监求见,皇帝允了。一日无事。 第三天,太监传话钦天监求见......一日无事。 第四天,钦天监......一日无事。 第五天,皇帝不耐烦了,和贾太监说,钦天监这老家伙整天是不是闲着没事,以后他来了不用给我禀报,直接放他上殿讲,讲完让他走吧。 国泰民安的日子依旧过着,每天只有钦天监一个人来报告,贾太监每次看到是钦天监来了,也懒得搭理了,...
相关文章
文章评论
共有0条评论来说两句吧...