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"