AMQP-RabbitMQ/1/概念/一对一简单模型

简介: JMS,AMQP,MQTT的区别与联系JMS Java消息传递服务(Java Messaging Service )AMQP 高级消息队列协议(Advanced Message Queueing Protocol )MQTT消息队列遥测传输(Message Queueing Telemetry Transport )简单理解:*JMS是专门为Java设计的一套消息服务API,像ActiveMQ就是对它的实现*AMQP为了解决不同平台之间的通信问题,定义了一种名为amqp的通信协议,从而实现平台和语言无关性。

JMS,AMQP,MQTT的区别与联系

  • JMS
    Java消息传递服务(Java Messaging Service )
  • AMQP
    高级消息队列协议(Advanced Message Queueing Protocol
  • MQTT
    消息队列遥测传输(Message Queueing Telemetry Transport )

简单理解:
*JMS是专门为Java设计的一套消息服务API,像ActiveMQ就是对它的实现
*AMQP为了解决不同平台之间的通信问题,定义了一种名为amqp通信协议,从而实现平台和语言无关性。
*MQTT也是一种通信协议。相比于AMQP的复杂性,它简单的多。所以amqp用于处理相对较重的任务,如两个系统平台之间的消息传输。而mqtt因为非常轻量,所以大量应用于物联网

RabbitMQ常用命令

  • 修改密码 rabbitmqctl change_password Username Newpassword
  • 显示所有用户 rabbitmqctl list_users
  • 启动 rabbitmq-server start
  • 关闭 rabbitmqctl stop
  • homebrew安装配置文件地址 /usr/local/etc/rabbitmq/rabbitmq-env.conf
  • 管理平台地址 http://localhost:15672/
    image.png

image.png

1. 简单模型

The simplest thing that does something

  • 模型图示

简单模型

  • 生产者
package com.futao.springmvcdemo.mq.rabbit.simple;

import com.futao.springmvcdemo.mq.rabbit.RabbitMqConnectionTools;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqQueueEnum;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import lombok.Cleanup;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

/**
 * 简单发送者
 *
 * @author futao
 * Created on 2019-04-22.
 */
@Slf4j
public class Send {
    @SneakyThrows
    public static void main(String[] args) {
        @Cleanup
        Connection connection = RabbitMqConnectionTools.getConnection();
        @Cleanup
        Channel channel = connection.createChannel();
        //定义一个队列
        channel.queueDeclare(RabbitMqQueueEnum.SIMPLE.getQueueName(), false, false, false, null);
        String msg = "Hello RabbitMq!";
        channel.basicPublish("", RabbitMqQueueEnum.SIMPLE.getQueueName(), null, msg.getBytes());
        log.info("Send msg:[{}] success", msg);
    }
}
  • 消费者
package com.futao.springmvcdemo.mq.rabbit.simple;

import com.futao.springmvcdemo.mq.rabbit.RabbitMqConnectionTools;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqQueueEnum;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

/**
 * 简单消费者
 *
 * @author futao
 * Created on 2019-04-22.
 */
@Slf4j
public class Recv {
    @SneakyThrows
    public static void main(String[] args) {
        Channel channel = RabbitMqConnectionTools.getChannel();
        channel.queueDeclare(RabbitMqQueueEnum.SIMPLE.getQueueName(), false, false, false, null);
        log.info("Waiting for message...");
        DeliverCallback deliverCallback = ((consumerTag, message) -> {
            log.info("收到消息:[{}],tag:[{}]", new java.lang.String(message.getBody()), consumerTag);
        });
        channel.basicConsume(RabbitMqQueueEnum.SIMPLE.getQueueName(), true, deliverCallback, consumerTag -> {
        });
    }
}
  • 特点:一对一。一个生产者,一个消费者。

通用代码

  • 工具类 - 链接工厂
package com.futao.springmvcdemo.mq.rabbit;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import lombok.SneakyThrows;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * rabbitMq配置类
 *
 * @author futao
 * Created on 2019-04-19.
 */
public class RabbitMqConnectionTools {
    /**
     * 获取链接
     *
     * @return
     * @throws IOException
     * @throws TimeoutException
     */
    public static Connection getConnection() {
        try {
            return getConnectionFactory().newConnection();
        } catch (IOException | TimeoutException e) {
            e.printStackTrace();
            throw new RuntimeException(e.getMessage(), e);
        }
    }

    /**
     * 连接工厂
     *
     * @return
     */
    private static ConnectionFactory getConnectionFactory() {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("futao");
        factory.setPassword("123456");
        factory.setVirtualHost("/springmvc");
        return factory;
    }

    /**
     * 创建并获取通道
     *
     * @return
     */
    @SneakyThrows
    public static Channel getChannel() {
        Connection connection = RabbitMqConnectionTools.getConnection();
        return connection.createChannel();
    }
}
  • 枚举类 - RabbitMqQueueEnum队列名称
package com.futao.springmvcdemo.mq.rabbit;

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * queue名称枚举
 *
 * @author futao
 * Created on 2019-04-19.
 */
@Getter
@AllArgsConstructor
public enum RabbitMqQueueEnum {

    /**
     * 简单queue
     */
    SIMPLE("simple-queue"),
    /**
     * WorkQueue 工作队列
     */
    WORK_QUEUE("work-queue"),
    /**
     * 发布订阅-fanout
     */
    EXCHANGE_QUEUE_FANOUT_ONE("exchange-queue-fanout-1"),

    EXCHANGE_QUEUE_FANOUT_TWO("exchange-queue-fanout-2"),

    EXCHANGE_QUEUE_DIRECT_ONE("exchange-queue-direct-1"),
    EXCHANGE_QUEUE_DIRECT_TWO("exchange-queue-direct-2"),

    EXCHANGE_QUEUE_TOPIC_ONE("exchange-queue-topic-1"),
    EXCHANGE_QUEUE_TOPIC_TWO("exchange-queue-topic-2"),
    EXCHANGE_QUEUE_TOPIC_THREE("exchange-queue-topic-3"),
    EXCHANGE_QUEUE_TOPIC_FOUR("exchange-queue-topic-4"),

    /**
     * RPC队列
     */
    RPC_QUEUE("rpc-queue");


    /**
     * queue名称
     */
    private String queueName;
}
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
4月前
|
消息中间件 存储 Kafka
一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
本文详细介绍了分布式消息中间件RocketMQ的核心概念、部署方式及使用方法。RocketMQ由阿里研发并开源,具有高性能、高可靠性和分布式特性,广泛应用于金融、互联网等领域。文章从环境搭建到消息类型的实战(普通消息、延迟消息、顺序消息和事务消息)进行了全面解析,并对比了三种消费者类型(PushConsumer、SimpleConsumer和PullConsumer)的特点与适用场景。最后总结了使用RocketMQ时的关键注意事项,如Topic和Tag的设计、监控告警的重要性以及性能与可靠性的平衡。通过学习本文,读者可掌握RocketMQ的使用精髓并灵活应用于实际项目中。
2360 9
 一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
|
7月前
|
消息中间件
RabbitMQ 的工作模型有哪些
RabbitMQ 的工作模型有哪些
|
9月前
|
消息中间件 存储 Java
【RabbitMQ】-SpringAMQP以及Work模型
RabbitMQ的工作模型通过消息队列和消费者的并行处理,极大地提高了任务处理的效率。通过Spring AMQP可以方便地与RabbitMQ进行交互,实现高效的消息传递和任务处理。本文详细介绍了如何配置和使用Spring AMQP来实现RabbitMQ的工作模型,包括生产者、消费者的定义以及消息的发送和接收过程。
162 14
|
7月前
|
消息中间件 测试技术 Kafka
Apache RocketMQ 批处理模型演进之路
Apache RocketMQ 批处理模型演进之路
|
消息中间件 测试技术 Kafka
Apache RocketMQ 批处理模型演进之路
RocketMQ 早期批处理模型存在一定的约束条件,为进一步提升性能,RocketMQ 进行了索引构建流水线改造,同时 BatchCQ 模型和 AutoBatch 模型也优化了批处理流程,提供了更简便的使用体验,快点击本文查看详情及配置展示~
19934 164
|
消息中间件 存储 缓存
RabbitMQ:WorkQueues模型
RabbitMQ:WorkQueues模型
133 8
RabbitMQ:WorkQueues模型
|
消息中间件 存储 网络协议
消息中间件RabbitMQ---概述和概念 【一】
该文章提供了对消息中间件RabbitMQ的全面概述,包括其核心概念、工作原理以及与AMQP和JMS的关系。
消息中间件RabbitMQ---概述和概念 【一】
|
消息中间件 负载均衡 算法
【RocketMQ系列十二】RocketMQ集群核心概念之主从复制&生产者负载均衡策略&消费者负载均衡策略
【RocketMQ系列十二】RocketMQ集群核心概念之主从复制&生产者负载均衡策略&消费者负载均衡策略
517 2
|
消息中间件 NoSQL 关系型数据库
【RocketMQ系列十三】RocketMQ的集群核心概念之消费重试&死信队列&幂等消息的出现以及处理
【RocketMQ系列十三】RocketMQ的集群核心概念之消费重试&死信队列&幂等消息的出现以及处理
649 1
|
消息中间件 存储 RocketMQ
【RocketMQ系列十】RocketMQ的核心概念说明
【RocketMQ系列十】RocketMQ的核心概念说明
327 1