前言

技术点：restful微信开发，支付，订阅发布，rpc。
不知道自己会在什么时候中断，先继续。

1.订阅推送

在高并发探测系列已经实战过消息队列。与发布订阅原理相同，实时功能需要cli在线服务，否则就要在页面做定时刷新。已知有redis发布订阅、rabbitmq发布订阅、swoole发布订阅，先看下swoole的订阅。

a.swoole发布订阅

参考官方《订阅模式》，swoole的订阅是基于redis的：
发布者pub.php：

go(function (){    $redis = new Swoole\Coroutine\Redis();    $redis->connect('172.1.13.11', 6379);    $redis->auth('123456');    $channels = ['channel1', 'channel2', 'channel3'];    swoole_timer_tick(1000, function () use ($redis, $channels) {        $channel = $channels[array_rand($channels)];        $news = [            'time'=>date("Y-m-d H:i:s"),            'document'=> "这是".date("Y-m-d", strtotime('+ 1 days'))."的新闻内容"        ];        $redis->publish($channel, json_encode($news, JSON_UNESCAPED_UNICODE));        print_r("--发布成功：".$channel .PHP_EOL);    });});

订阅者sub.php

go(function (){    $redis = new Swoole\Coroutine\Redis();    $redis->connect('172.1.13.11', 6379);    $redis->auth('123456');    function counter (){        $c = 1; //准备静态化        return function () use (&$c) { return $c++; };    }    $counter = counter(); //实例计数器    if ($redis->subscribe(['channel1', 'channel2', 'channel3'])) { // 或者使用psubscribe        while ($msg = $redis->recv()) {            // msg是一个数组, 包含以下信息            // $type # 返回值的类型：显示订阅成功            // $name # 订阅的频道名字 或 来源频道名字            // $info  # 目前已订阅的频道数量 或 信息内容            list($type, $name, $info) = $msg;            if ($type == 'subscribe'){ // 或psubscribe                // 频道订阅成功消息，订阅几个频道就有几条：首次连接                var_dump("频道订阅成功消息 ", $msg);            } else if ($type == 'unsubscribe' && $info == 0) { // 或punsubscribe                break; // 收到取消订阅消息，并且剩余订阅的频道数为0，不再接收，结束循环            } else if ($type == 'message') { // 若为psubscribe，此处为pmessage                $rev_times = $counter();                //标记退订                // 打印来源频道名字、消息                print_r( ['rev_times'=>$rev_times, 'name'=>$name, 'info'=>$info] );                // 处理消息                // balabalaba....                if ($rev_times%10==0){ // 测试退订，每10个退订一个channel                    $status = $redis->unsubscribe($msg); // 继续recv等待退订完成                    var_dump("准备退订 $name", $status);                }            }        }    }});

cli界面运行。
在swoole里的协程操作，使用 CoroutineHttpClient、CoroutineHttpServer、CoroutineHttp2Client、CoroutineRedis、CoroutineSocket、CoroutineMySQL、CoroutinePostgreSQL，二次封装的类操作。