http:\/\/www.rabbitmq.com\/tutorials\/tutorial-five-php.html<\/p>\n
Amqp\u534f\u8bae<\/a> http:\/\/ip:15672\/ \u670d\u52a1\u91cd\u542f\u65f6, \u662f\u5426\u80fd\u6062\u590d\u961f\u5217\u4e2d\u7684\u6570\u636e.<\/p>\n <\/p>\n","protected":false},"excerpt":{"rendered":" \u5e94\u7528\u573a\u666f http:\/\/www.rabbitmq.com\/tutorials\/tutorial-five-ph […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[20,6],"tags":[42],"_links":{"self":[{"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/posts\/334"}],"collection":[{"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=334"}],"version-history":[{"count":3,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/posts\/334\/revisions"}],"predecessor-version":[{"id":337,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=\/wp\/v2\/posts\/334\/revisions\/337"}],"wp:attachment":[{"href":"https:\/\/blog.inforere.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=334"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=334"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/blog.inforere.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=334"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
\nphp\u5ba2\u6237\u7aef<\/a>
\nhttp:\/\/www.rabbitmq.com\/queues.html
\n\u6709\u6548\u671f\u00a0http:\/\/www.rabbitmq.com\/ttl.html<\/p>\n\u5b89\u88c5\u6559\u7a0b<\/h1>\n
\n
yum install erlang --enablerepo=epel\r\nwget https:\/\/github.com\/rabbitmq\/rabbitmq-server\/releases\/download\/rabbitmq_v3_5_8\/rabbitmq-server-3.5.8-1.noarch.rpm\r\nrpm --import https:\/\/www.rabbitmq.com\/rabbitmq-release-signing-key.asc\r\nyum install rabbitmq-server-3.5.8-1.noarch.rpm<\/pre>\n
Web\u63d2\u4ef6<\/h2>\n
\n
rabbitmq-plugins enable rabbitmq_management\r\nrabbitmqctl change_password guest guest<\/pre>\n
\nguest guest<\/span><\/p>\n\u6301\u4e45\u5316<\/h2>\n
\n
\u00a0\u4f7f\u7528\u793a\u4f8b<\/h2>\n
# jz.inc.php\r\n<?php\r\n\r\nnamespace rmqTest;\r\n\r\nrequire_once __DIR__ . '\/vendor\/autoload.php';\r\nuse PhpAmqpLib\\Connection\\AMQPStreamConnection;\r\nuse PhpAmqpLib\\Message\\AMQPMessage;\r\nuse PhpAmqpLib\\Channel\\AMQPChannel;\r\n\r\n\/**\r\n * Class JzRabbitMQExample\r\n * @package rmqTest\r\n *\/\r\nclass JzRabbitMQExample {\r\n\r\n protected $channel;\r\n protected $connection;\r\n protected $exchange;\r\n\r\n \/**\r\n * JzRabbitMQExample constructor.\r\n * @param string $exchange\r\n *\/\r\n function __construct($exchange = 'topic-jz'){\r\n $this->connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');\r\n $this->channel = $this->connection->channel();;\r\n\r\n $this->exchange = $exchange;\r\n $this->channel->exchange_declare($exchange, 'topic', false, false, false);\r\n }\r\n\r\n function close(){\r\n $this->channel->close();\r\n $this->channel->close();\r\n }\r\n}\r\n\r\n\r\n\/**\r\n * Class JzRabbitMQExample\r\n * @package rmqTest\r\n *\/\r\nclass JzProducer extends JzRabbitMQExample{\r\n \/**\r\n * @param string $data\r\n * @param string $routingKey\r\n *\/\r\n function sendMessage($data, $routingKey){\r\n $msg = new AMQPMessage($data);\r\n $this->channel->basic_publish($msg, $this->exchange, $routingKey);\r\n echo \" [x] Sent \",$routingKey,':',$data,\" \\n\";\r\n }\r\n}\r\n\r\n\/**\r\n * Class JzConsumer\r\n *\/\r\nclass JzConsumer extends JzRabbitMQExample{\r\n \/**\r\n * @var array\r\n *\/\r\n protected $queues = [\r\n 'search' => [\"*.add\", \"*.edit\", \"*.delete\"],\r\n 'points' => [\"*.add\", '*.delete'],\r\n 'user-count' => [\"*.add\", \"*.delete\"]\r\n ];\r\n\r\n protected function declareQueue($queueName, $keys = []){\r\n $this->channel->queue_declare($queueName, false, false, false, false);\r\n if(isset($this->queues[$queueName])){\r\n $keys = $this->queues[$queueName];\r\n }\r\n\r\n foreach($keys as $key){\r\n $this->channel->queue_bind($queueName, $this->exchange, $key);\r\n }\r\n }\r\n\r\n function receive($queueName, $keys) {\r\n \/\/ \u7ed1\u5b9a\u961f\u5217\r\n $this->declareQueue($queueName, $keys);\r\n\r\n $callback = [$this, 'process'];\r\n $this->channel->basic_consume($queueName, '', false, true, false, false, $callback);\r\n while(count($this->channel->callbacks)) {\r\n $this->channel->wait();\r\n }\r\n }\r\n\r\n \/**\r\n * @param $msg\r\n *\/\r\n function process($msg){\r\n echo ' [x] ', $msg->body, \"\\n\";\r\n var_dump($msg->delivery_info['delivery_tag']);\r\n echo \"\\n\";\r\n }\r\n}\r\n\r\n<\/pre>\n<?php\r\n# jz-publish.php\r\n\r\nnamespace rmqTest;\r\n\r\nrequire_once __DIR__ . '\/jz.inc.php';\r\n\r\n$routing_key = isset($argv[1]) && !empty($argv[1]) ? $argv[1] : 'anonymous.info';\r\n$data = implode(' ', array_slice($argv, 2));\r\nif(empty($data))\r\n $data = \"Hello World!\";\r\n\r\n$mq = new JzProducer();\r\n$mq->sendMessage($data, $routing_key);\r\n$mq->close();<\/pre>\n<?php\r\n# jz-receive.php\r\nnamespace rmqTest;\r\n\r\nrequire_once __DIR__ . '\/jz.inc.php';\r\n\r\n$queueName = isset($argv[1]) ? $argv[1] : '';\r\n$keys = array_slice($argv, 2);\r\nif(empty($queueName) && empty($keys)) {\r\n file_put_contents('php:\/\/stderr', \"Usage: $argv[0] queueName [binding_key]\\n\");\r\n exit(1);\r\n}\r\n\r\necho ' [*] Waiting for logs. To exit press CTRL+C', \"\\n\";\r\n$mq = new JzConsumer();\r\n$mq->receive($queueName, $keys);\r\n$mq->close();\r\n\r\n<\/pre>\n# cli\r\nphp jz-receive.php search\r\nphp jz-receive.php use-count\r\n\r\nphp jz-publish.php goods.edit 2\r\nphp jz-publish.php news.add 5<\/pre>\n