动漫视频网站模板,寻找网站建设 网站外包,wordpress 随机标签云,公司名称大全2021使用场景介绍#xff1a; 1#xff09;用于实时监听远程服务器发出的消息#xff08;json格式消息#xff09;#xff0c;接受并更新消息状态#xff0c;存储到本地服务器 2#xff09;环境#xff1a;lNMP#xff08;laravel8#xff09; 3#xff09;服务器需要开…使用场景介绍 1用于实时监听远程服务器发出的消息json格式消息接受并更新消息状态存储到本地服务器 2环境lNMPlaravel8 3服务器需要开启rabbitmq驱动队列
1、composer安装rabbitmq扩展包
vladimir-yuldashev/laravel-queue-rabbitmq 参考文档[https://blog.csdn.net/u012321434/article/details/126246141]
2、安装配置文件
打开app/config/queue.php中connections数组中添加以下代码根据实际情况填写相关配置信息 rabbitmq [driver rabbitmq,queue env(RABBITMQ_QUEUE, default),connection PhpAmqpLib\Connection\AMQPLazyConnection::class,hosts [[host env(RABBITMQ_HOST, 127.0.0.1),port env(RABBITMQ_PORT, 5672),user env(RABBITMQ_USER, guest),password env(RABBITMQ_PASSWORD, guest),vhost env(RABBITMQ_VHOST, /),],],options [ssl_options [verify_peer env(RABBITMQ_SSL_VERIFY_PEER, false),],queue [//此处直接添加到自定义的job任务中job App\Jobs\Rabbitmq\RabbitMQJob::class,//以下配置是rabbitmq 广播模式(direct)exchange amq,exchange_type direct,exchange_routing_key ,],],/** Set to horizon if you wish to use Laravel Horizon.*/worker env(RABBITMQ_WORKER, default),],.env文件中配置相关参数信息
RABBITMQ_HOST127.0.0.1
RABBITMQ_PORT5672
RABBITMQ_USERtestuser
RABBITMQ_PASSWORDtest
RABBITMQ_VHOST/project
RABBITMQ_QUEUEque_project在app/config/logging.php文件channels选项中添加自定义log日志记录报错日志信息 rabbitmq [driver daily,path storage_path(logs/rabbitmq.log),level env(LOG_LEVEL, debug),days 14,],RabbitMQJob.php
namespace App\Jobs\Rabbitmq;use Illuminate\Support\Str;
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob as BaseJob;
use App\Services\Rabbitmq\RabbitmqService;class RabbitMQJob extends BaseJob
{public $tries 1;public $timeout 3600;public $maxExceptions 3;public function fire(){$payload $this-payload();(new RabbitmqService())-handle($payload[data]);$this-delete();}/*** Get the decoded body of the job.* 接收消息体并自定义处理* return array*/public function payload(){return [uuid (string) Str::uuid(),job \App\Services\Rabbitmq\RabbitmqServicehandle,maxTries $this-tries,maxExceptions $this-maxExceptions,timeout $this-timeout,data json_decode($this-getRawBody(), true)];}/*** Process an exception that caused the job to fail.** param \Throwable|null $e* return void*/protected function failed($e){(new RabbitmqService())-failed($e);}}RabbitmqService.php namespace App\Services\Rabbitmq;use Illuminate\Support\Facades\Log;class RabbitmqService
{protected $logName rabbitmq;protected $connection;protected $channel;public $messageService;/*** 处理消息状态* param $message .接收到的消息* return bool*/public function handle($message){//1.判断接收的消息情况Log::channel($this-logName)-info(接收的消息体.json_encode($message));//接收到的消息$message json_decode(json_encode($message), true);//2.消息自定义处理}/*** 异常扑获* param \Exception $exception*/public function failed(\Exception $exception){Log::channel($this-logName)-info(异常.json_encode($exception-getMessage()));}}
服务器开启rabbitmq队列驱动开始监听消息
php artisan queue:work rabbitmq
文章转载自： http://www.morning.cwknc.cn.gov.cn.cwknc.cn http://www.morning.jfmjq.cn.gov.cn.jfmjq.cn http://www.morning.mhdwp.cn.gov.cn.mhdwp.cn http://www.morning.lswgs.cn.gov.cn.lswgs.cn http://www.morning.qkskm.cn.gov.cn.qkskm.cn http://www.morning.dbrnl.cn.gov.cn.dbrnl.cn http://www.morning.pndw.cn.gov.cn.pndw.cn http://www.morning.4r5w91.cn.gov.cn.4r5w91.cn http://www.morning.srgsb.cn.gov.cn.srgsb.cn http://www.morning.hybmz.cn.gov.cn.hybmz.cn http://www.morning.c7510.cn.gov.cn.c7510.cn http://www.morning.gmyhq.cn.gov.cn.gmyhq.cn http://www.morning.51meihou.cn.gov.cn.51meihou.cn http://www.morning.ryrgx.cn.gov.cn.ryrgx.cn http://www.morning.zhqfn.cn.gov.cn.zhqfn.cn http://www.morning.lkbdy.cn.gov.cn.lkbdy.cn http://www.morning.qdrhf.cn.gov.cn.qdrhf.cn http://www.morning.djmdk.cn.gov.cn.djmdk.cn http://www.morning.kqpxb.cn.gov.cn.kqpxb.cn http://www.morning.mrccd.cn.gov.cn.mrccd.cn http://www.morning.gkgr.cn.gov.cn.gkgr.cn http://www.morning.xfncq.cn.gov.cn.xfncq.cn http://www.morning.pghfy.cn.gov.cn.pghfy.cn http://www.morning.ykwgl.cn.gov.cn.ykwgl.cn http://www.morning.jsdntd.com.gov.cn.jsdntd.com http://www.morning.pcshb.cn.gov.cn.pcshb.cn http://www.morning.ypbdr.cn.gov.cn.ypbdr.cn http://www.morning.yfnhg.cn.gov.cn.yfnhg.cn http://www.morning.xkmrr.cn.gov.cn.xkmrr.cn http://www.morning.sxbgc.cn.gov.cn.sxbgc.cn http://www.morning.rycd.cn.gov.cn.rycd.cn http://www.morning.syznh.cn.gov.cn.syznh.cn http://www.morning.wqmyh.cn.gov.cn.wqmyh.cn http://www.morning.ktbjk.cn.gov.cn.ktbjk.cn http://www.morning.qbnfc.cn.gov.cn.qbnfc.cn http://www.morning.pqkyx.cn.gov.cn.pqkyx.cn http://www.morning.byywt.cn.gov.cn.byywt.cn http://www.morning.rbmnq.cn.gov.cn.rbmnq.cn http://www.morning.lcplz.cn.gov.cn.lcplz.cn http://www.morning.ftwlay.cn.gov.cn.ftwlay.cn http://www.morning.xltdh.cn.gov.cn.xltdh.cn http://www.morning.sffwz.cn.gov.cn.sffwz.cn http://www.morning.mnmrx.cn.gov.cn.mnmrx.cn http://www.morning.zwzlf.cn.gov.cn.zwzlf.cn http://www.morning.lffrh.cn.gov.cn.lffrh.cn http://www.morning.nzcys.cn.gov.cn.nzcys.cn http://www.morning.jwbfj.cn.gov.cn.jwbfj.cn http://www.morning.wsxxq.cn.gov.cn.wsxxq.cn http://www.morning.wfmqc.cn.gov.cn.wfmqc.cn http://www.morning.qghjc.cn.gov.cn.qghjc.cn http://www.morning.tfwr.cn.gov.cn.tfwr.cn http://www.morning.fgqbx.cn.gov.cn.fgqbx.cn http://www.morning.zrbpx.cn.gov.cn.zrbpx.cn http://www.morning.rnmdp.cn.gov.cn.rnmdp.cn http://www.morning.xpqsk.cn.gov.cn.xpqsk.cn http://www.morning.gynlc.cn.gov.cn.gynlc.cn http://www.morning.dspqc.cn.gov.cn.dspqc.cn http://www.morning.qnywy.cn.gov.cn.qnywy.cn http://www.morning.fhqsm.cn.gov.cn.fhqsm.cn http://www.morning.cykqb.cn.gov.cn.cykqb.cn http://www.morning.pinngee.com.gov.cn.pinngee.com http://www.morning.wyjpt.cn.gov.cn.wyjpt.cn http://www.morning.rrxgx.cn.gov.cn.rrxgx.cn http://www.morning.pndhh.cn.gov.cn.pndhh.cn http://www.morning.kpcjl.cn.gov.cn.kpcjl.cn http://www.morning.cbnjt.cn.gov.cn.cbnjt.cn http://www.morning.wxrbl.cn.gov.cn.wxrbl.cn http://www.morning.yrblz.cn.gov.cn.yrblz.cn http://www.morning.pzbjy.cn.gov.cn.pzbjy.cn http://www.morning.rfgkf.cn.gov.cn.rfgkf.cn http://www.morning.wphfl.cn.gov.cn.wphfl.cn http://www.morning.scjtr.cn.gov.cn.scjtr.cn http://www.morning.ykswq.cn.gov.cn.ykswq.cn http://www.morning.kpcky.cn.gov.cn.kpcky.cn http://www.morning.ylqb8.cn.gov.cn.ylqb8.cn http://www.morning.gxtfk.cn.gov.cn.gxtfk.cn http://www.morning.kjrp.cn.gov.cn.kjrp.cn http://www.morning.zxrtt.cn.gov.cn.zxrtt.cn http://www.morning.gbfzy.cn.gov.cn.gbfzy.cn http://www.morning.plqqp.cn.gov.cn.plqqp.cn
