<?php
$config = require "config.php";

require_once $config['vendor']['path'] . '/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

//创建连接和channel
$connection = new AMQPStreamConnection($config['rabbitmq']['host'], $config['rabbitmq']['port'],
    $config['rabbitmq']['login'], $config['rabbitmq']['password'], $config['rabbitmq']['vhost']);
$channel = $connection->channel();

// 声明队列（发送方其实不需要设置队列， 不过对于持久化有关，建议执行该行）
$channel->queue_declare('hello', false, false, false, false);

$content = 'Welcome!';
//推送消息
$msg = new AMQPMessage($content);
$channel->basic_publish($msg, '', 'hello');

echo " [x] Send success,this message is: '" . $content . "'\n";

//关闭通道
$channel->close();
//关闭连接
$connection->close();
?>