这篇文章主要介绍“laravel如何使用RabbitMQ”，在日常操作中，相信很多人在laravel如何使用RabbitMQ问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”laravel如何使用RabbitMQ”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
laravel安装RabbitMQ：
首先注意自己laravel-queue-rabbitmq支持的laravel版本信息：
| Package Version | Laravel Version | Bug Fixes Until | |
|---|---|---|---|
| 9 | 6 | October 5th, 2021 | Documentation |
| 10 | 6, 7 | October 5th, 2021 | Documentation |
| 11 | 8 | April 6th, 2021 | Documentation |
执行安装命令：
composer require vladimir-yuldashev/laravel-queue-rabbitmq
等待安装完成后在config/queue.php中添加：
计算
安全
数据库
网络和加速
企业服务
'connections' => [
// ...
'rabbitmq' => [
'driver' => 'rabbitmq',
'queue' => env('RABBITMQ_QUEUE', 'default'),
'connection' => PhpAmqpLib\Connection\AMQPLazyConnection::class,
'hosts' => [
[
'host' => env('RABBITMQ_HOST', '127.0.0.1'),
'port' => env('RABBITMQ_PORT', 5672),
'user' => env('RABBITMQ_USER', 'guest'),
'password' => env('RABBITMQ_PASSWORD', 'guest'),
'vhost' => env('RABBITMQ_VHOST', '/'),
],
],
'options' => [
'ssl_options' => [
'cafile' => env('RABBITMQ_SSL_CAFILE', null),
'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
],
'queue' => [
'job' => VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob::class,
],
],
/*
* Set to "horizon" if you wish to use Laravel Horizon.
*/
'worker' => env('RABBITMQ_WORKER', 'default'),
],
// ... ],并且在config/queue.php中修改：
//把sync修改为rabbitmq，同理使用redis驱动则修改为redis
'default' => env('QUEUE_CONNECTION', 'sync'),
'default' => env('QUEUE_CONNECTION', 'rabbitmq'),
//或者修改.env下QUEUE_CONNECTION=rabbitmq
QUEUE_CONNECTION=rabbitmq执行命令生成任务类：
php artisan make:job TestQueue修改TestQueue.php代码：
<?php
namespace App\Jobs;
use App\Models\UserInfo;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
class TestQueue implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
private $data;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($data)
{
//
$this->data = $data;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
//
$data = $this->data;
UserInfo::query()->firstOrCreate(
["phone" => $data["phone"]],
["name" => $data["name"]]
);
}
}调用队列函数：
public function test(Request $request){
$data = ["name" => "李大", "phone" => "12345678901"];
$this->dispatch(new TestQueue($data));
}开启队列：
php artisan queue:work
队列消费成功，查看数据库，数据也写入正常。
到这里，会有一个问题，既然方法1能够正常使用，为什么还要加入rabbitmq-server，rabbitmq-server又是干啥的？
根据官方描述——RabbitMQ is a feature rich, multi-protocol messaging broker. It supports:
AMQP 0-9-1
AMQP 1.0
MQTT 3.1.1
STOMP 1.0 through 1.2
翻译过来就是：RabbitMQ 是一个功能丰富的多协议消息代理。 它支持以下几种协议。
根据RabbitMQ官网的描述:
RabbitMQ runs on many operating systems and cloud environments, and provides a wide range of developer tools for most popular languages.
翻译过来就是：
RabbitMQ 运行在许多操作系统和云环境中，并为大多数流行语言提供了广泛的开发工具。
rabbitmq-server，为大家提供了一个服务端，不管是什么语言，使用账号、密码连接到相应的host和port就能使用RabbitMQ。类似的还有EMQX（mqtt服务端）等等。并且rabbitmq-server提供了一个管理后台，可以查看队列的相关情况，便于管理。启动rabbitmq-server：
sudo service rabbitmq-server start开启队列：
php artisan queue:work
在config/queue.php的username和password里不要使用默认的guest账号密码来连接，否则会报错：
The connection timed out after 3 sec while awaiting incoming data前文已经添加过admin的账号密码，使用这个账号密码还需要给admin账号添加权限：
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"在rabbitmq-server管理后台查看用户权限：
有权限是Can access virtual hosts显示/，无权限就是显示No Access。
1、laravel-queue-rabbitmq+Supervisor守护进程。本质上就是换了个队列驱动，用法和redis无任何差别；
2、可以使用类似这种用法：java操作RabbitMQ，脱离了laravel，使用连接+生产者+消费者的方式；
3、还可以使用更复杂的用法，例如接入其他通信协议（例如MQTT），订阅主题的方式等等。
到此，关于“laravel如何使用RabbitMQ”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
