README

通过Composer

 composer require jeanku/rabbitmq:dev-master

初始化

在.env文件中添加以下配置，并确保我们可以使用env()方法获取配置

.env file config:
RABBITMQ_HOST=127.0.0.1             #rabbitmq host
RABBITMQ_USERNAME=rabbitmq          #rabbitmq user
RABBITMQ_PASSWORD=123456            #rabbitmq password
RABBITMQ_PORT=5672                  #rabbit port

用法

步骤 1: 创建你的类；

<?php
 
 use Jeanku\Rabbitmq\Queue;
 
 /**
  * demo
  * @desc more description
  * @date 2018-04-02
  */
 class Demo extends Queue
 {
     //exchange name
     protected $exchange = 'demo';          //please overwrite the exchange depend on your business
     //queue name
     protected $queue = 'email';            //please overwrite the $queue depend on your business
     //route key
     protected $route = 'email';            //please overwrite the $route depend on your business
     //default direct
     protected $type = AMQP_EX_TYPE_DIRECT;
     //空队列等待时间 默认10秒
     protected $wait = 10;
     //多消费者任务均衡分配 默认一个
     protected $prefetch = 1;
 
     /**
      * your business code, consume the queue data function
      * @param string $mge require the message you get from queue
      * @return array
      */
     public function handle($msg) {
         //todo
     }
 }

步骤 2: 推送消息

Demo::push('log message');

步骤 3: 消费队列

  php Demo.php

jeanku / rabbitmq

维护者

详细信息

README

初始化

用法

步骤 1: 创建你的类；

步骤 2: 推送消息

步骤 3: 消费队列