php如何使用rabbitmq實現發布消息和消費消息（一對多）（tp框架）（第二篇）

本文轉載自查看原文 2017-11-30 10:28 3204 linux/ php/ 隊列

一個publisher發布消息多個個customer接受消息

1：准備工作參照：

　　http://www.cnblogs.com/spicy/p/7886820.html

2,：路由：

3: 方法：”

 public function callFunc($msg) {
        echo " [x] Received ", $msg->body, "\n";
        if($msg->body==2){
            sleep(50);
        }else{
            sleep($msg->body);
        }

//        sleep(substr_count($msg->body, '.'));
        echo " [x] Done", "\n";

    }

    public function worker()
    {
        set_time_limit(0);
        $connection = new AMQPStreamConnection('localhost', 5672, 'bitch', 'bitch');
        $channel = $connection->channel();
        $channel->queue_declare('hello', false, true);

        $receiver = new self();
        #下面第四個參數如果為true表示開啟確認模式，也就是消費以后會告知rabbitmq服務器該條消息已經處理完畢，這樣可以方式消息處理一半掛掉了，結果服務器也刪除了這條未處理完畢的消息
        $channel->basic_consume('hello', '', false, true, false, false, [$receiver, 'callFunc']);

        while(true) {
            $channel->wait();
        }
        $channel->close();
        $connection->close();
    }

    public function task()
    {
        $re = input('uid');

        $connection = new AMQPStreamConnection('localhost', 5672, 'bitch', 'bitch');
        $channel = $connection->channel();
        $channel->queue_declare('hello', false, true);

        for($i=1; $i<11; $i++){
        $msg = new AMQPMessage($i);
            $channel->basic_publish($msg, '', 'hello');
            echo "第".$i.'發送完畢';
        }
        $channel->close();
        $connection->close();
    }