一、服务连接

//服务器地址，端口号，用户名，密码
$connection = new AMQPStreamConnection('localhost',5672,'guest','guest');

二、创建通道

//通道id，不传默认null
$channel = $connection->channel($channel_id = null);

三、交换器声明

/**
 * exchange :交换器的名称
 *  type : 交换器的类型，常见的有direct,fanout,topic，headers等
 *  passive : 设置为true时；消极的
 * durable :是否持久化, 队列的声明默认是存放到内存中的，
 *          如果rabbitmq重启会丢失，如果想重启之后还存在就要使队列持久化，
 *          保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库
 * autoDelete：设置是否自动删除。autoDelete设置为true时，则表示自动删除。
 *             自动删除的前提是至少有一个队列或者交换器与这个交换器绑定，之后，所有与这个交换器绑定的队列或者交换器都与此解绑。
 *             不能错误的理解—当与此交换器连接的客户端都断开连接时，RabbitMq会自动删除本交换器
 * internal：设置是否内置的。如果设置为true，则表示是内置的交换器，客户端程序无法直接发送消息到这个交换器中，只能通过交换器路由到交换器这种方式。
 * arguments:其它一些结构化的参数，比如：alternate-exchange
 */
$channel->exchange_declare('logs','fanout',false,false,false,false,false,[],null);
        

四、队列声明

/**
 * queue :队列的名称
 * passive :
 * durable :是否持久化, 队列的声明默认是存放到内存中的，
 *          如果rabbitmq重启会丢失，如果想重启之后还存在就要使队列持久化，
 *          保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库
 * exclusive：是否排外的，有两个作用，
 *            一：当连接关闭时connection.close()该队列是否会自动删除；
 *            二：该队列是否是私有的private，如果不是排外的，可以使用两个消费者都访问同一个队列，没有任何问题，
 *                如果是排外的，会对当前队列加锁，其他通道channel是不能访问的，如果强制访问会报异常；一般等于true的话用于一个队列只能有一个消费者来消费的场景
 * autoDelete：设置是否自动删除。autoDelete设置为true时，则表示自动删除。
 *             自动删除的前提是至少有一个队列或者交换器与这个交换器绑定，之后，所有与这个交换器绑定的队列或者交换器都与此解绑。
 *             不能错误的理解—当与此交换器连接的客户端都断开连接时，RabbitMq会自动删除本交换器
 * arguments:其它一些结构化的参数，比如：alternate-exchange
 */
$channel->queue_declare('',false,false,true,false);

五、消息发布

/**
 * 消息
 * exchange ： 交换器
 * routing_key ： 路由键
 */
$msg = new AMQPMessage($message);
$channel->basic_publish($msg,'logs','');

六、消费消息

/**
 * queue 队列名
 * consumerTag 消费者标签，用来区分多个消费者
 * noLocal 设置为true，表示 不能将同一个Conenction中生产者发送的消息传递给这个Connection中 的消费者
 * exclusive 是否排他
 * arguments 消费者的参数
 * callback 消费者 DefaultConsumer建立使用，重写其中的方法
 */
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);