1 //引用所需文件
2 require_once __DIR__ . '/vendor/autoload.php';
3 use PhpAmqpLib\Connection\AMQPStreamConnection;
4 use PhpAmqpLib\Message\AMQPMessage;
5 //建立一个连接通道,声明一个可以发送消息的队列hello
6 $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
7 $channel = $connection->channel();
8 $channel->queue_declare('hello', false, false, false, false);
9
10 //定义一个消息,消息内容为Hello World!
11 $msg = new AMQPMessage('Hello World!');
12 $channel->basic_publish($msg, '', 'hello');
13
14 //发送完成后打印消息告诉发布消息的人:发送成功
15 echo " [x] Sent 'Hello World!'\n";
16 //关闭连接
17 $channel->close();
18 $connection->close();