php 发送消息,golang接收消息

flanchegong · · 662 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

<?php use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; class RabbitMQ_InventoryBatch { protected $_conn; public function __construct() { $mq_config = new Zend_Config_Ini(APPLICATION_PATH . '/../application/configs/mq.ini', 'production',true); $this->host = $mq_config->mq->host; $this->port = $mq_config->mq->port; $this->user = $mq_config->mq->user; $this->pass = $mq_config->mq->pass; //获得连接 $this->_conn = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->pass); } public function pusher($msg_body){ $exchange = 'exchange1'; $queue = 'Inventory'; //建立mq通道 $channel = $this->_conn->channel(); /* * 声明通道 name: $queue passive: false durable: true // the queue will survive server restarts exclusive: false // the queue can be accessed in other channels auto_delete: false //the queue won't be deleted once the channel is closed. */ $channel->queue_declare($queue, false, false, false, false); /* * name: $exchange type: direct passive: false durable: true // the exchange will survive server restarts auto_delete: false //the exchange won't be deleted once the channel is closed. */ //fanout $channel->exchange_declare($exchange, 'direct', false, true, false); //绑定exchange $channel->queue_bind($queue, $exchange); if(empty($msg_body)) $msg_body = "Hello World!"; if(is_array($msg_body)){ $msg_body=serialize($msg_body); } $msg = new AMQPMessage($msg_body, array('content_type' => 'text/plain', 'delivery-mode' => 2)); $channel->basic_publish($msg, $exchange); $channel->close(); $this->_conn->close(); } } ![微信图片_20190731145511.png](https://static.studygolang.com/190731/07049a110466558d3655e2d616c45c45.png)

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

662 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传