php如何使用rabbitmq实现发布消息和消费消息（一对多）（tp框架）（第二篇）

一个publisher发布消息多个个customer接受消息

1：准备工作参照：

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

2,：路由：

php如何使用rabbitmq实现发布消息和消费消息（一对多）（tp框架）（第二篇）

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();

    }