php redis实现对200w用户的即时推送

实现对200w用户的即时推送，需要使用PHP的Redis扩展。Redis是内存数据库，具有高效的读写速度和好的扩展性，非常适合处理实时数据，支持多种数据结构，如字符串、列表、集合、有序集合等。

下面是详细的攻略流程：

第一步：安装Redis

首先需要安装Redis服务端程序和Redis扩展包，可根据自己的操作系统类型进行安装。

第二步：连接Redis并设置参数

连接Redis时，可以使用以下代码示例：

$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);

这里我们使用127.0.0.1作为Redis的主机地址，6379作为默认的Redis端口号。

在连接Redis之后，需要设置相关的参数，如连接池大小、超时时间等，以提高Redis的使用效率和稳定性。

$redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
$redis->setOption(\Redis::OPT_WRITE_TIMEOUT, -1);
$redis->setOption(\Redis::OPT_SERIALIZER, \Redis::SERIALIZER_PHP);

这里我们将读超时时间和写超时时间设置为-1，表示无限等待，以确保Redis连接不会因超时而断开。

第三步：使用Redis实现即时推送

使用Redis实现即时推送需要使用Pub/Sub模式，通过使用Redis发布订阅机制，将消息实时推送给客户端。

3.1 订阅消息

用户订阅消息时，需要执行以下代码：

$redis->subscribe([$channelName], function ($redis, $channel, $message) {
    //TODO 接收到消息后的处理逻辑
});

这里我们使用$redis->subscribe()方法，传递一个频道名称数组，当Redis接收到该频道中的消息时，回调函数将被执行。

3.2 发送消息

在推送消息时，需要执行以下代码：

$redis->publish($channelName, $message);

这里我们使用$redis->publish()方法，传递频道名称和要发送的消息，将实时消息发布到指定的频道，所有订阅该频道的客户端都可以接收到该消息。

示例一：基于Websocket实现即时推送

以下是基于Websocket实现即时推送的示例代码：

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Websocket;

$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
$redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
$redis->setOption(\Redis::OPT_WRITE_TIMEOUT, -1);
$redis->setOption(\Redis::OPT_SERIALIZER, \Redis::SERIALIZER_PHP);

$worker = new Worker('websocket://0.0.0.0:8000');
$worker->onConnect = function (TcpConnection $connection) use ($redis) {
    $redis->subscribe(['realtime_push'], function ($redis, $channel, $message) use ($connection) {
        if ($connection->websocketSend($message) === false) {
            $redis->unsubscribe(['realtime_push']);
        }
    });
};

Worker::runAll();

上述代码使用Workerman框架提供的Websocket协议，当客户端连接到服务器之后，将会自动订阅名为realtime_push的频道，一旦接收到有新的消息推送到该频道时，Workerman将把消息发送给客户端。

示例二：基于Laravel实现即时推送

以下是基于Laravel实现即时推送的示例代码：

use Illuminate\Http\Request;
use Illuminate\Support\Facades\Redis;

Route::get('/realtime_push', function (Request $request) {
    $redis = Redis::connection();
    $redis->subscribe(['realtime_push'], function ($redis, $channel, $message) use ($request) {
        $response = new \Symfony\Component\HttpFoundation\StreamedResponse(function () use ($redis, $channel, $request) {
            echo $message;
            flush();
        });
        $response->headers->set('Content-Type', 'text/event-stream');
        $response->headers->set('Cache-Control', 'no-cache');
        $response->headers->set('X-Accel-Buffering', 'no');
        $response->send();
    });
});

上述代码使用Laravel框架提供的Route路由功能，当客户端请求/realtime_push路由时，将会自动订阅名为realtime_push的频道，一旦接收到有新的消息推送到该频道时，Laravel将把消息作为SSE(Server-Sent Event)返回给客户端。

以上示例仅供参考，实际场景中还需要根据具体需求和业务逻辑进行相应的修改。