اتصال به RabbitMQ در برنامه‌های Laravel

composer require php-amqplib/php-amqplib

RABBITMQ_HOST=fitz-roy.liara.cloud
RABBITMQ_PORT=32923
RABBITMQ_USER=root
RABBITMQ_PASS=63LVuatIrWWajE7gxSj20gHL

php artisan make:controller RabbitMQController

<?php

namespace App\Http\Controllers;

use Illuminate\Http\JsonResponse;
use PhpAmqpLib\Connection\AMQPStreamConnection;

class RabbitMQController extends Controller
{
    public function checkConnection(): JsonResponse
    {
        try {

            $host = env('RABBITMQ_HOST');
            $port = env('RABBITMQ_PORT');
            $user = env('RABBITMQ_USER');
            $pass = env('RABBITMQ_PASS');


            $connection = new AMQPStreamConnection($host, $port, $user, $pass);
            $connection->close();

            return response()->json(['message' => 'connection successful']);
        } catch (\Exception $e) {
            return response()->json(['message' => 'connection failed', 'error' => $e->getMessage()], 500);
        }
    }
}

use App\Http\Controllers\RabbitMQController;

Route::get('/check-rabbitmq', [RabbitMQController::class, 'checkConnection']);