初识rabbitMQ

╰半橙微兮° 2022-01-29 14:45 250阅读 0赞

**composer安装php-amqplib**

配置composer.json

{
     "require": {
        "php-amqplib/php-amqplib": ">=2.6.1"
      }
    }

安装

> composer install

**send.php **

<?php
    require_once __DIR__ . '/vendor/autoload.php';
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    use PhpAmqpLib\Message\AMQPMessage;
    
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $channel = $connection->channel();
    $channel->queue_declare('channel1', false, false, false, false);
    $msg = new AMQPMessage('nicce to meet you !');
    $channel->basic_publish($msg, '', 'channel1');
    echo "信息发送成功!'\n";
    $channel->close();
    $connection->close();

**receive.php**

<?php
    require_once __DIR__ . '/vendor/autoload.php';
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $channel = $connection->channel();
    $channel->queue_declare('channel1', false, false, false, false);
    echo "信息接收中.按CTRL+C可退出\n";
    $callback = function ($msg) {
      echo '收到信息：', $msg->body, "\n";
    };
    $channel->basic_consume('channel1', '', false, true, false, false, $callback);
    while (count($channel->callbacks)) {
        $channel->wait();
    }

**效果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x3cUJyZWxs_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x3cUJyZWxs_size_16_color_FFFFFF_t_70]: /images/20220129/6475119065714322b7ea7c4d88fc46c1.png

发表评论取消回复

表情：

评论列表（有 0 条评论，250人围观）

还没有评论，来说两句吧...

相关阅读

相关 SpringCloud：初识RabbitMQ及快速入门

1.初识`MQ` 1.1.同步和异步通讯微服务间通讯有同步和异步两种方式：同步通讯：就像打电话，需要实时响应。异步通讯：就像发邮件，不需要马上回复。 !

逃离我推掉我的手/ 2024年03月25日 20:53/ 0 赞/ 51 阅读

相关从初识RabbitMQ到安装了解

一、同步和异步通讯微服务间通讯有同步和异步两种方式：同步通讯：就像打电话，需要实时响应。异步通讯：就像发邮件，不需要马上回复。两种方式各有优劣，打电话可以立

小鱼儿/ 2024年03月22日 09:06/ 0 赞/ 82 阅读

相关 Java初识RabbitMQ一死信队列

推荐：[消息中间件汇总][Link 1] Java初识RabbitMQ一死信队列什么是死信队列死信队列`DLX`（dead-letter-exchange），利用

落日映苍穹つ/ 2023年07月05日 05:28/ 0 赞/ 126 阅读

相关 Java初识RabbitMQ一交换机（fanout exchange）

推荐：[消息中间件汇总][Link 1] Java初识RabbitMQ一交换机（fanout exchange）首先看看`AMQP`协议，对`RabbitMQ`的架构

秒速五厘米/ 2023年07月04日 14:03/ 0 赞/ 4 阅读

相关 RabbitMQ实战之初识篇

一、RabbitMQ简介 1. RabbitMQ基础概况 MQ：message queue – 消息队列是应用程序间的通信方法，如进程之间的通信；

深藏阁楼爱情的钟/ 2023年06月17日 12:59/ 0 赞/ 186 阅读

相关 RabbitMQ(一) 初识RabbitMQ

RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用Erlang语言来编写的，并且RabbitMQ是基于AMQ

旧城等待，/ 2023年02月15日 03:43/ 0 赞/ 226 阅读

相关精通RabbitMQ之初识RabbitMQ

精通RabbitMQ之初识RabbitMQ RabbitMQ AMQP模型 AMQP协议层角色相关的概念消息中间件相关的概念 RabbitM

墨蓝/ 2022年04月03日 14:52/ 0 赞/ 273 阅读

相关 rabbitmq初识

[https://www.jianshu.com/p/3e76a144bebd][https_www.jianshu.com_p_3e76a144bebd] [https_

左手的ㄟ右手/ 2022年02月26日 10:05/ 0 赞/ 241 阅读

相关初识rabbitMQ

composer安装php-amqplib 配置composer.json { "require": { "php-amqplib/php

╰半橙微兮°/ 2022年01月29日 14:45/ 0 赞/ 251 阅读

相关 rabbitmq系列（一）初识rabbitmq

为什么要使用消息中间件案例：假如我们开发了一个商品抢购网站。这个网站的目的就是在某一时间点进行抢购商品，同时要求用户注册，在注册的时候会同时给用户电话和邮箱中发送验证码

客官°小女子只卖身不卖艺/ 2021年09月18日 05:08/ 0 赞/ 434 阅读