zoukankan      html  css  js  c++  java
  • php-rabbitmq安装、打印hello word

    服务器Ubuntu16.04

    1.安装服务器端

      apt-cache search rabbitmq

      apt install rabbitmq-server

    2.using the php-amqplib Client 

      { "require": { "php-amqplib/php-amqplib": ">=2.6.1" } }
      composer install

    3. send.php  

    <?php
    require_once __DIR__ . '/vendor/autoload.php';
    use PhpAmqpLibConnectionAMQPStreamConnection;
    use PhpAmqpLibMessageAMQPMessage;
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $channel = $connection->channel();
    $channel->queue_declare('hello', false, false, false, false);
    $msg = new AMQPMessage('Hello World!');
    $channel->basic_publish($msg, '', 'hello');
    
    echo " [x] Sent 'Hello World!'
    ";
    
    $channel->close();
    $connection->close();
    ?>

    4.receive.php

    <?php
    require_once __DIR__ . '/vendor/autoload.php';
    use PhpAmqpLibConnectionAMQPStreamConnection;
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $channel = $connection->channel();
    $channel->queue_declare('hello', false, false, false, false);
    echo ' [*] Waiting for messages. To exit press CTRL+C', "
    ";
    $callback = function($msg) {
      echo " [x] Received ", $msg->body, "
    ";
    };
    $channel->basic_consume('hello', '', false, true, false, false, $callback);
    while(count($channel->callbacks)) {
        $channel->wait();
    }
    $channel->close();
    $connection->close();
    ?>

    5.终端运行代码实现消息传递

    http://www.rabbitmq.com/tutorials/tutorial-one-php.html

     
  • 相关阅读:
    cannot import name 'PILLOW_VERSION'
    scala spark2.0 rdd dataframe 分布式计算欧式距离
    scala spark dataframe 修改字段类型
    获取cookie脚本
    Loadrunner 获取请求的返回结果函数web_reg_save_param
    Python模拟接口登录
    web自动化上传附件 2
    Web自动化附件上传
    robotframework 连接mysql数据库
    Json格式获取接口返回的值
  • 原文地址:https://www.cnblogs.com/luotingliang/p/7264076.html
Copyright © 2011-2022 走看看