当前位置: 首页 > news >正文

国家城乡和住房建设部网站首页上海公共招聘官网

国家城乡和住房建设部网站首页,上海公共招聘官网,河南省建设厅村镇建设处网站,网站定制营销的过程ThinkPHP8集成RabbitMQ的完整案例实现一、安装依赖#xff1a;需通过Composer安装php-amqplib库‌二、配置RabbitMQ三、生产者1、发送一个邮件#xff0c;将任务发送到RabbitMQ队列中。2、运行结果展示四、启动消费者#xff1a;命令行执行php think rabbitmq:consumer1需通过Composer安装php-amqplib库‌二、配置RabbitMQ三、生产者1、发送一个邮件将任务发送到RabbitMQ队列中。2、运行结果展示四、启动消费者命令行执行php think rabbitmq:consumer1在command文件夹下创建consumer.php文件2配置指令3、执行结果展示五、补充:宝塔安装rabbitmq一、安装依赖需通过Composer安装php-amqplib库‌ composer require php-amqplib/php-amqplib二、配置RabbitMQ 在服务器开放RabbitMQ端口5672 return [default rabbitmq,connections [rabbitmq [driver rabbitmq,host 127.0.0.1, // RabbitMQ服务器地址port 5672, // RabbitMQ端口user guest, // 用户名password guest, // 密码vhost /, // 虚拟主机queue email_queue, // 队列名称exchange email_exchange, // 交换机名称routing_key email_queue, // 路由键durable true, // 是否持久化队列和消息]] ];三、生产者 1、发送一个邮件将任务发送到RabbitMQ队列中。 app/controller/SendEMail.php namespace app\controller; use app\common\SendEmailJob; use think\facade\Config; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; class SendEmail {public function sendemail(){$config config(queue.connections.rabbitmq);// dd($config);$connection new AMQPStreamConnection($config[host], $config[port],$config[user], $config[password], $config[vhost]);$channel $connection-channel();$channel-exchange_declare($config[exchange], direct, false, true, false);$channel-queue_declare($config[queue], false, true, false, false);$channel-queue_bind($config[queue], $config[exchange], $config[routing_key]);$data [to 11userexample.com,subject ThinkPHP8 RabbitMQ测试,content 这是一封通过消息队列发送的邮件];$msg new AMQPMessage(json_encode($data), [delivery_mode 2]);$channel-basic_publish($msg, $config[exchange], $config[routing_key]);$channel-close();$connection-close();return 邮件任务已发送到队列;}}2、运行结果展示 四、启动消费者命令行执行php think rabbitmq:consumer 1在command文件夹下创建consumer.php文件 接收任务从RabbitMQ队列中获取任务执行。 app/command/consumer.php namespace app\command; use think\console\Command; use think\console\Input; use think\console\Output; use PhpAmqpLib\Connection\AMQPStreamConnection;class Consumer extends Command {protected function configure() {$this-setName(rabbitmq:consumer)-setDescription(RabbitMQ消费者);}protected function execute(Input $input, Output $output) {$config config(queue.connections.rabbitmq);$connection new AMQPStreamConnection($config[host], $config[port],$config[user], $config[password], $config[vhost]);$channel $connection-channel();$channel-queue_declare($config[queue], false, true, false, false);$callback function($msg) use ($output) {$data json_decode($msg-body, true);$output-writeln(收到邮件任务: {$data[to]});// 实际发送邮件逻辑$msg-ack();};$channel-basic_qos(null, 1, null);$channel-basic_consume($config[queue], , false, false, false, false, $callback);while ($channel-is_consuming()) {$channel-wait();}$channel-close();$connection-close();} }2配置指令 config/console.php commands [rabbitmq:consumer app\command\Consumer,],执行命令 php think rabbitmq:consumer3、执行结果展示 五、补充:宝塔安装rabbitmq 在宝塔软件里面安装rabbitmq 3.12.4 登录可直观展示
http://www.pierceye.com/news/666080/

相关文章:

  • 网站建设静态部分报告总结在合肥哪里学网站建设
  • 建站行业现状网易与暴雪合作
  • 网站中添加百度地图购物网站产品做促销能赚钱吗
  • 金融公司 网站开发怎么样建网站卖东西
  • 网站导航栏垂直如何提高你的网站的粘性
  • 直播网站开发接入视频中国建筑招聘官网2022
  • 大连专业企业建站找哪家wordpress 保护wp-login.php
  • 微网站建设哪家便宜想要找个网站做环评公示
  • 建设银行网银网站激活个人简历模板电子版可填写
  • 肃州区建设局网站宁夏百度seo
  • 关于做电影的网站设计西安网站建设制作 熊掌号
  • idc网站建设怎么自己做一个网页链接
  • 网站开发安全模块方案个人网站搭建软件
  • 重庆建设招标造价信息网站个人网站建设与维护
  • 网站备案用户名忘了怎么办嘉兴做外贸网站的公司
  • 1688网站的特点网站制作器手机版下载
  • 兖州网站开发做一个中英文网站多少钱
  • wordpress怎么做网盘站好看的页面图片
  • 建设网站深圳罗湖安徽合肥做网站
  • 一级a做爰片免费网站下载网站快慢由什么决定
  • 网页设计与网站建设 郑州大学网络购物网站备案
  • 美观网站建设哪家好优化大师最新版下载
  • 外贸品牌网站制作wordpress 微信主题
  • 旅游网站开发需求分析网站的根目录的路径
  • easyUI网站开发docker wordpress mysql
  • dede手机网站模板下载黄冈做网站
  • 诸城网站建设葛小燕现在搜索引擎哪个比百度好用
  • 嘉兴做微网站多少钱注册网页需要多少钱
  • 论坛类网站设计大型网站系统解决方案
  • 网站建设中页面设计广告策划书籍