php多个用户推送数据,php百万数据推送

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

想用PHP做Socket服务器,不知道如何实现同时和多个不同客户端数据交互?

因为只有调用了accept客户端才能连上，你如果accept下面接一个循环，那么第二个用户不是说能不能进这个循环，而是连不进……此时只有第一个用户break出了循环，然后程序回头再调用accept，第二个用户才能连上。

用多进程来处理如何？因为accept一个客户端以后，应该是马上准备accept下一个客户端才对，而不是处理完现在这个客户端才accept下一个客户端。

socket_accept以后，直接调用

pcntl_fork()，此时进程会分裂为两个，其中一个的pnctl_fork返回值是0，另一个不是0。不是0的那个直接继续调用socket_accept即可，是0的那个处理客户端请求。

pnctl_fork不知道在windows下能不能用。

不过返回不是0的那个进程并不是这样就完事了，还要调用pcntl_wait防止子进程卡在那边没有完全结束。你可以在主进程里时不时就调用这个，配上WNOHANG作为option参数防止没有子进程需要wait的时候卡在那边。

这都是linux下常用的处理手段。说实话本来我想让你用多线程的，不过看了一圈不知道php里怎么用线程，倒是找到了用进程的方式，所以就

相关问答

Q1: ios推送消息用php推送怎么实现

php实现ios推送的方法：首先把要发送的消息以及iPhone标识打包，并发送给APNS；然后查找有相应标识的iPhone，并把消息发送到iPhone；最后把发来的消息传递给相应的应用程序，并且按照设定弹出Push通知即可。

可以分为三个阶段：

第一阶段：应用程序把要发送的消息、目的iPhone的标识打包，发给APNS。

第二阶段：APNS在自身的已注册Push服务的iPhone列表中，查找有相应标识的iPhone，并把消息发送到iPhone。

第三阶段：iPhone把发来的消息传递给相应的应用程序，并且按照设定弹出Push通知。

推送服务极光还不错，极光多种消息类型，开发者可以轻松地通过极光发送各个移动平台的系统通知，还可以在控制台编辑多种富文本展示模板；极光还提供自定义消息的透传，客户端接到消息内容后根据自己的逻辑自由处理。

Q2: 如何在php中用百度云推送进行消息的推送

在php中用百度云推送进行消息的推送的方法

1.Android端推送

// 创建Android SDK对象.

$asdk = new \Vendor\pushsdk\PushSDK(); //自己引入百度云推送的SDK，官网上有文档详细介绍

$channelId = $channelrows;

$message = array (

// 消息的标题.

'title' = $title,

// 消息内容

'description' = $brief,

//传广告id，可以通过键值对的形式传多个值

'custom_content'=array('id'=$id),

);

// 设置消息类型为通知类型.

$opts = array (

'msg_type' = 1,

);

// 向目标设备发送一条消息（群发，指的是通过前面的筛选之后的channelId进行的大量的推送）

$rs = $asdk - pushBatchUniMsg($channelId, $message, $opts);

// 判断返回值,当发送失败时, $rs的结果为false, 可以通过getError来获得错误信息.

if($rs === false)

{

print_r($asdk-getLastErrorCode());

print_r($asdk-getLastErrorMsg());

}

else{echo "success!";}

2.IOS推送

// 创建Ios SDK对象.

$isdk = new \Vendor\ipushsdk\IPushSDK();

$channelId = $channelrows;

$message = array (

'aps' = array(

'alert' = $brief, // 消息内容

'id' =$id, //账号ID，这边能够以键值对的形式可以传多个值

);

// 设置消息类型为通知类型.

$opts = array (

msg_type' = 1,

'deploy_status' = 2, //2是生产状态，刚开始开发测试时需要设置成1进行测试

);

$rs = $isdk-createTag('tag_new'); //通过创建标签的方式来实现群发的功能

if($rs !== false)

{

if($isdk - addDevicesToTag('tag_new',$channelId) !== false)

{

// 发送

$rs = $isdk - pushMsgToTag('tag_new',$message,$opts);

//删除标签

$delRs = $isdk-deleteTag('tag_new');

//判断返回值,当发送失败时, $rs的结果为false, 可以通过getError来获得错误信息.

if($rs === false)

{

print_r($isdk-getLastErrorCode());

print_r($isdk-getLastErrorMsg());

}

else{echo "success!";}

}

Q3: 如何在php后端及时推送消息给客户端

后端代码

push.php

?php

use Workerman\Worker;

require_once './Workerman/Autoloader.php';

// 初始化一个worker容器，监听1234端口

$worker = new Worker('websocket://0.0.0.0:1234');

// 这里进程数必须设置为1

$worker-count = 1;

// worker进程启动后建立一个内部通讯端口

$worker-onWorkerStart = function($worker)

{

// 开启一个内部端口，方便内部系统推送数据，Text协议格式文本+换行符

$inner_text_worker = new Worker('Text://0.0.0.0:5678');

$inner_text_worker-onMessage = function($connection, $buffer)

{

global $worker;

// $data数组格式，里面有uid，表示向那个uid的页面推送数据

$data = json_decode($buffer, true);

$uid = $data['uid'];

// 通过workerman，向uid的页面推送数据

$ret = sendMessageByUid($uid, $buffer);

// 返回推送结果

$connection-send($ret ? 'ok' : 'fail');

};

$inner_text_worker-listen();

};

// 新增加一个属性，用来保存uid到connection的映射

$worker-uidConnections = array();

// 当有客户端发来消息时执行的回调函数

$worker-onMessage = function($connection, $data)use($worker)

{

// 判断当前客户端是否已经验证,既是否设置了uid

if(!isset($connection-uid))

{

// 没验证的话把第一个包当做uid（这里为了方便演示，没做真正的验证）

$connection-uid = $data;

/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，

* 实现针对特定uid推送数据

$worker-uidConnections[$connection-uid] = $connection;

return;

}

};

// 当有客户端连接断开时

$worker-onClose = function($connection)use($worker)

{

global $worker;

if(isset($connection-uid))

{

// 连接断开时删除映射

unset($worker-uidConnections[$connection-uid]);

}

};

// 向所有验证的用户推送数据

function broadcast($message)

{

global $worker;

foreach($worker-uidConnections as $connection)

{

$connection-send($message);

}

// 针对uid推送数据

function sendMessageByUid($uid, $message)

{

global $worker;

if(isset($worker-uidConnections[$uid]))

{

$connection = $worker-uidConnections[$uid];

$connection-send($message);

return true;

}

return false;

}

// 运行所有的worker（其实当前只定义了一个）

Worker::runAll();

启动后端服务

php push.php start -d

前端接收推送的js代码

var ws = new WebSocket('ws://127.0.0.1:1234');

ws.onopen = function(){

var uid = 'uid1';

ws.send(uid);

};

ws.onmessage = function(e){

alert(e.data);

};

后端推送消息的代码

// 建立socket连接到内部推送端口

$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT);

// 推送的数据，包含uid字段，表示是给这个uid推送

$data = array('uid'='uid1', 'percent'='88%');

// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符

fwrite($client, json_encode($data)."\n");

// 读取推送结果

echo fread($client, 8192);

这里的uid不一定是用户的id，也可以理解为任务id即 taskid

以上代码亲测可以直接使用

Q4: php 微信模板消息 5000人的推送

1、php+redis 消息队列

2、swoole异步执行

想玩并发的话，php 的话除了 pcntl_fork 多个进程跑脚本，本身有批处理的模块，可以用 curl_multi_* 批量发送

Q5: php实现websocket实时消息推送

一、socket协议的简介

WebSocket是什么，有什么优点

WebSocket是一个持久化的协议，这是相对于http非持久化来说的。应用层协议

举个简单的例子，http1.0的生命周期是以request作为界定的，也就是一个request，一个response，对于http来说，本次client与server的会话到此结束；而在http1.1中，稍微有所改进，即添加了keep-alive，也就是在一个http连接中可以进行多个request请求和多个response接受操作。然而在实时通信中，并没有多大的作用，http只能由client发起请求，server才能返回信息，即server不能主动向client推送信息，无法满足实时通信的要求。而WebSocket可以进行持久化连接，即client只需进行一次握手，成功后即可持续进行数据通信，值得关注的是WebSocket实现client与server之间全双工通信，即server端有数据更新时可以主动推送给client端。

二、介绍client与server之间的socket连接原理

1、下面是一个演示client和server之间建立WebSocket连接时握手部分

2、client与server建立socket时握手的会话内容，即request与response

a、client建立WebSocket时向服务器端请求的信息

GET /chat HTTP/1.1

Host: server.example.com

Upgrade: websocket //告诉服务器现在发送的是WebSocket协议

Connection: Upgrade

Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== //是一个Base64 encode的值，这个是浏览器随机生成的，用于验证服务器端返回数据是否是WebSocket助理

Sec-WebSocket-Protocol: chat, superchat

Sec-WebSocket-Version: 13

Origin: