swoole如何監聽redis數據

<?php namespace AppEvents; use IlluminateBroadcastingChannel; use IlluminateQueueSerializesModels; use IlluminateBroadcastingPrivateChannel; use IlluminateBroadcastingPresenceChannel; use IlluminateFoundationEventsDispatchable; use IlluminateBroadcastingInteractsWithSockets; use IlluminateContractsBroadcastingShouldBroadcast; class RedisTest {     use Dispatchable, InteractsWithSockets, SerializesModels;     public $message;     /**     * Create a new event instance.     *     * @return void     */     public function __construct($message)     {         $this->message?=?$message; ????} ????/** ????*?Get?the?channels?the?event?should?broadcast?on. ????* ????*?@return?IlluminateBroadcastingChannel|array ????*/ ????public?function?broadcastOn() ????{ ????????return?new?PrivateChannel('channel-name'); ????} }

<?php namespace AppListeners; use AppEventsRedisTest; use IlluminateQueueInteractsWithQueue; use IlluminateContractsQueueShouldQueue; use IlluminateSupportFacadesLog; class RedisTestListener {     /**     * Create the event listener.     *     * @return void     */     public function __construct()     {         //     }     /**     * Handle the event.     *     * @param  RedisTest  $event     * @return void     */     public function handle(RedisTest $event)     {         $message = $event->message; ????????Log::info('the?message?received?from?subscribed?redis?channel?msg_0:?'.$message); ????} }

protected?$listen?=?[ ????????'AppEventsRedisTest'?=>?[ ????????????'AppListenersRedisTestListener', ????????], ????];

<?php namespace AppConsoleCommands; use IlluminateConsoleCommand; use swoole_redis; use IlluminateSupportFacadesEvent; use AppEventsRedisTest; class RedisSubscribe extends Command {     /**     * The name and signature of the console command.     *     * @var string     */     protected $signature = &#39;redis:subscribe&#39;;     /**     * The console command description.     *     * @var string     */     protected $description = &#39;deamon process to subscribe redis broadcast&#39;;     /**     * Create a new command instance.     *     * @return void     */     public function __construct()     {         parent::__construct();     }     /**     * Execute the console command.     *     * @return mixed     */     public function handle()     {         $client = new swoole_redis;         $client->on('message',?function?(swoole_redis?$client,?$result)?{ ????????????var_dump($result); ????????????static?$more?=?false; ????????????if?(!$more?and?$result[0]?==?'message') ????????????{ ????????????????echo?"trigger?Event?RedisTestn"; ????????????????Event::fire(new?RedisTest($result[2])); ????????????} ????????}); ????????$client-&gt;connect('127.0.0.1',?6379,?function?(swoole_redis?$client,?$result)?{ ????????????echo?"connectn"; ????????????$client-&gt;subscribe('msg_0'); ????????}); ????} }

[group:echos] programs=echo-queue,echo-redis [program:echo-queue] command=php?artisan?queue:work directory=/home/bella/Downloads/lnmp/echo1.0/echo user=bella autorestart=true redirect_stderr=true stdout_logfile=/home/bella/Downloads/lnmp/echo1.0/echo/storage/logs/queue.log loglevel=info [program:echo-redis] command=php?artisan?redis:subscribe directory=/home/bella/Downloads/lnmp/echo1.0/echo user=bella autorestart=true redirect_stderr=true stdout_logfile=/home/bella/Downloads/lnmp/echo1.0/echo/storage/logs/redis.log loglevel=info

supervisorctl?reload

publish?msg_0?"Hello?Bella"