基于workerman的实时推送，摒弃ajax轮询

原文

先扯些这些内容：


TCP/IP
TCP/IP是个协议组，可分为三个层次：网络层、传输层和应用层。
在网络层有IP协议、ICMP协议、ARP协议、RARP协议和BOOTP协议。
在传输层中有TCP协议与UDP协议。
在应用层有:TCP包括FTP、HTTP、TELNET、SMTP等协议
UDP包括DNS、TFTP等协议
短连接连接->传输数据->关闭连接
HTTP是无状态的，浏览器和服务器每进行一次HTTP操作，就建立一次连接，但任务结束就中断连接。
也可以这样说：短连接是指SOCKET连接后发送后接收完数据后马上断开连接。
长连接连接->传输数据->保持连接 -> 传输数据-> 。。。 ->关闭连接。
长连接指建立SOCKET连接后不管是否使用都保持连接，但安全性较差。
http的长连接HTTP也可以建立长连接的，使用Connection:keep-alive，HTTP 1.1默认进行持久连接。HTTP1.1和HTTP1.0相比较而言，最大的区别就是增加了持久连接支持(貌似最新的 http1.0 可以显示的指定 keep-alive),但还是无状态的，或者说是不可以信任的。
什么时候用长连接，短连接？长连接多用于操作频繁，点对点的通讯，而且连接数不能太多情况，。每个TCP连接都需要三步握手，这需要时间，如果每个操作都是先连接，再操作的话那么处理速度会降低很多，所以每个操作完后都不断开，次处理时直接发送数据包就OK了，不用建立TCP连接。例如：数据库的连接用长连接， 如果用短连接频繁的通信会造成socket错误，而且频繁的socket 创建也是对资源的浪费。
而像WEB网站的http服务一般都用短链接，因为长连接对于服务端来说会耗费一定的资源，而像WEB网站这么频繁的成千上万甚至上亿客户端的连接用短连接会更省一些资源，如果用长连接，而且同时有成千上万的用户，如果每个用户都占用一个连接的话，那可想而知吧。所以并发量大，但每个用户无需频繁操作情况下需用短连好。


workerman是啥子？Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。被广泛的用于手机app、移动通讯，微信小程序，手游服务端、网络游戏、PHP聊天室、硬件通讯、智能家居、车联网、物联网等领域的开发。 支持TCP长连接，支持Websocket、HTTP等协议，支持自定义协议。拥有异步MySQL、异步Redis、异步Http、异步消息队列等众多高性能组件。


开始步入正题：为了达到实时通讯，很多时候我们采用了ajax轮询机制，如图：



后面可以采用workerman方式来实现，项目也是tp写的，官方手册这么说到

与其它mvc框架结合建议以上图的方式(ThinkPHP为例)：

1、ThinkPHP与Workerman是两个独立的系统，独立部署(可部署在不同服务器)，互不干扰。

2、ThinkPHP以HTTP协议提供网页页面在浏览器渲染展示。

3、ThinkPHP提供的页面的js发起websocket连接，连接workerman

4、连接后给Workerman发送一个数据包(包含用户名密码或者某种token串)用于验证websocket连接属于哪个用户。

5、仅在ThinkPHP需要向浏览器推送数据时，才调用workerman的socket接口推送数据。

6、其余请求还是按照原本ThinkPHP的HTTP方式调用处理。

总结：

把Workerman作为一个可以向浏览器推送的通道，仅仅在需要向浏览器推送数据时才调用Workerman接口完成推送。业务逻辑全部在ThinkPHP中完成。

ok，到这里，把workerman容器跑起来，注意这里是CLI模式运行

然后再我们项目接收信息中这么玩，附上代码

[PHP] view plain copy
print ?
  1. <script>
  2. //连接服务端
  3. varsocket=io('http://127.0.0.1:2120');
  4. //uid可以是自己网站的用户id，以便针对uid推送
  5. uid=123;
  6. //socket连接后以uid登录
  7. socket.on('connect',function(){
  8. socket.emit('login',uid);
  9. });
  10. //后端推送来消息时
  11. socket.on('new_msg',function(msg){
  12. console.log("收到消息："+msg);//自己业务逻辑处理
  14. </script>


接着，我们在用户向用户发送信息的时候添加

copy

//指明给谁推送，为空表示向所有在线用户推送
  • $to_uid="123";
  • //推送的url地址
    •
  • $push_api_url="http://127.0.0.1:2121/";
  • $post_data=array(
  • "type"=>"publish",
  • "content"=>"数据",
  • "to"=>$to_uid,226); color:inherit; line-height:18px; list-style-position:outside!important"> );
  • $ch=curl_init();
  • curl_setopt($ch,CURLOPT_URL,$push_api_url);
  • curl_setopt($post_data);
  • array("Expect:"));
  • $return=curl_exec($ch);
  • curl_close($ch);
  • var_export($return);

    • 基于workerman的实时推送，摒弃ajax轮询的更多相关文章

    1. html5 http的轮询和Websocket原理

      这篇文章主要介绍了html5 http的轮询和Websocket原理的相关资料,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

    2. ios – Swift：使用GCDAsyncUdpSocket接收UDP

      开始：接收：发送：编辑：添加了忘记的代码行.解决方法我终于得到它使用这个套接字设置：

    3. 应用程序关闭时的iOS任务

      我正在构建一个应用程序,通过ajax将文件上传到服务器.问题是用户很可能有时不会有互联网连接,并且客户希望在用户重新连接时安排ajax调用.这可能是用户在离线时安排文件上传并关闭应用程序.应用程序关闭时可以进行ajax调用吗？

    4. Swift Socket 实例 两份资料不错

      Swift-使用vaporsocks库进行socket通信（基于TCP、UDP协议）http://www.hangge.com/blog/cache/detail_1588.htmlSwift-使用socket进行通信（附聊天室样例）http://www.hangge.com/blog/cache/detail_756.htmlIBM-Swift/BlueSockethttps://github.

    5. Android从服务器套接字侦听消息

      解决方法您可以在服务中创建一个线程来监听服务器.第二个线程用于发送命令.然后,对于您的服务,您应该创建一个带有处理程序的主线程.此处理程序将处理来自这两个线程的消息.

    6. Android BluetoothSocket.isConnected始终返回false

      解决方法我相信jkane001已经解决了他的问题,所以我希望这个答案可以帮助别人.首先在套接字创建之后你应该通过初始连接之后,您将能够使用socket.isConnected()检查连接状态由于connect()方法没有阻塞,所以socket之后可能还没有连接.我建议使用这样的东西顺便说一句,我发现在一些Android设备上isConnected()总是返回false.在这种情况下,只是尝试写一些东西到socket并检查是否没有异常.

    7. android – Phonegap本地构建 – jquery ajax错误：readystate 0 responsetext status 0 statustext error

      解决方法您是否在索引文件中包含了内容安全元标记？

    8. Android：流式摄像机数据并将其写入服务器

      我测试看它是否真的捕获了视频输出：这是以下用于设置mediaRecorder的Android代码解决方法有一些开源项目可以解决这个问题,例如Spydroid和AndroidIPCamera.你的实现类似于Spydroid,所以也许你可以调整它的一些代码.中心问题是MediaRecorder正在将原始视频帧写入套接字.它需要等到视频完成才能写入标题,但它们需要出现在文件的开头.由于套接字不可搜索,因此无法在正确的位置写入标头.上面链接的项目通过将流打包成RTSP或将一系列静态图像“流式传输”到浏览器来解决这

    9. Android应用程序：SocketException权限被拒绝(没有这样的文件或目录)

      我试图使用Fedor在这个帖子中发布的代码和上传的代码LazyloadofimagesinListView(源码：http://open-pim.com/tmp/LazyList.zip)Fedor的项目运行良好,但是当我尝试将代码调整到我的项目时,由于我碰到了这个异常(SocketException),所以事情运行得不好.不知何故,即使在清单中设置权限以获得Internet权限之后,我仍然继续获

    10. 如何从蓝牙条码扫描器读取数据符号CS3070到Android设备

      在我的项目中,我必须使用条形码扫描器SymbolCS3070通过蓝牙阅读条形码.即;我必须通过蓝牙建立Android设备和条码扫描器之间的连接.任何人都可以告诉我如何从条形码阅读器读取值,以及如何设置通信？>>首先,您必须扫描手册中的“串行端口配置文件”中的条形码.这是我工作代码的不完整版本,但你应该得到要点.我希望这个解决方案也适合你！

    随机推荐

    1. xe-ajax-mock 前端虚拟服务

      最新版本见Github，点击查看历史版本基于XEAjax扩展的Mock虚拟服务插件；对于前后端分离的开发模式，ajax+mock使前端不再依赖后端接口开发效率更高。CDN使用script方式安装，XEAjaxMock会定义为全局变量生产环境请使用xe-ajax-mock.min.js，更小的压缩版本，可以带来更快的速度体验。

    2. vue 使用 xe-ajax

      安装完成后自动挂载在vue实例this.$ajaxCDN安装使用script方式安装，VXEAjax会定义为全局变量生产环境请使用vxe-ajax.min.js，更小的压缩版本，可以带来更快的速度体验。cdnjs获取最新版本点击浏览已发布的所有npm包源码unpkg获取最新版本点击浏览已发布的所有npm包源码AMD安装require.js安装示例ES6Module安装通过Vue.use()来全局安装示例./Home.vue

    3. AJAX POST数据中文乱码解决

      前端使用encodeURI进行编码后台java.net.URLDecoder进行解码编解码工具

    4. Koa2框架利用CORS完成跨域ajax请求

      实现跨域ajax请求的方式有很多，其中一个是利用CORS，而这个方法关键是在服务器端进行配置。本文仅对能够完成正常跨域ajax响应的，最基本的配置进行说明。这样OPTIONS请求就能够通过了。至此为止，相当于仅仅完成了预检，还没发送真正的请求呢。

    5. form提交时，ajax上传文件并更新到&lt;input&gt;中的value字段

    6. ajax的cache作用

      filePath="+escape;},error:{alert;}});解决方案：1.加cache:false2.url加随机数正常代码：网上高人解读：cache的作用就是第一次请求完毕之后，如果再次去请求，可以直接从缓存里面读取而不是再到服务器端读取。

    7. 浅谈ajax上传文件属性contentType = false

      默认值为contentType="application/x-www-form-urlencoded".在默认情况下，内容编码类型满足大多数情况。在这里，我们主要谈谈contentType=false.在使用ajax上传文件时：在其中先封装了一个formData对象，然后使用post方法将文件传给服务器。说到这，我们发现在JQueryajax()方法中我们使contentType=false,这不是冲突了吗？这就是因为当我们在form标签中设置了enctype=“multipart/form-data”,

    8. 909422229_ajaxFileUpload上传文件

      ajaxFileUpload.js很多同名的，因为做出来一个很容易。我上github搜AjaxFileUpload出来很多类似js。ajaxFileUpload是一个异步上传文件的jQuery插件传一个不知道什么版本的上来，以后不用到处找了。语法：$.ajaxFileUploadoptions参数说明：1、url上传处理程序地址。2，fileElementId需要上传的文件域的ID，即的ID。3，secureuri是否启用安全提交，默认为false。4，dataType服务器返回的数据类型。6，error

    9. AJAX-Cache：一款好用的Ajax缓存插件

      原文链接AJAX-Cache是什么Ajax是前端开发必不可少的数据获取手段，在频繁的异步请求业务中，我们往往需要利用“缓存”提升界面响应速度，减少网络资源占用。AJAX-Cache是一款jQuery缓存插件，可以为$.ajax()方法扩展缓存功能。

    10. jsf – Ajax update/render在已渲染属性的组件上不起作用

      我试图ajax更新一个有条件渲染的组件。我可以确保#{user}实际上是可用的。这是怎么引起的，我该如何解决呢？必须始终在ajax可以重新呈现之前呈现组件。Ajax正在使用JavaScriptdocument.getElementById()来查找需要更新的组件。但是如果JSF没有将组件放在第一位，那么JavaScript找不到要更新的内容。解决方案是简单地引用总是渲染的父组件。

    返回
    顶部