call('rabbitmq:exchange-declare', [ 'name' => $exchange, '--type' => Arr::get($options['queue'], 'exchange_type'), '--durable' => 0, ]); //如果队列不存在,创建队列 $this->call('rabbitmq:queue-declare', [ 'name' => $queue, ]); //判断是否包含keys,如果包含直接绑定到队列 $keys = config('lrouter.keys'); if ($keys) { foreach ($keys as $key) { $this->call('rabbitmq:queue-bind', [ 'queue' => $queue, 'exchange' => $exchange, '--routing-key' => sprintf(Arr::get($options['queue'],'exchange_routing_key'),$key), ]); } } } }