(消息中间件使用场景) 消息中间件的使用场景有哪些消息中间件简介全网首发(图文详解1)

(消息中间件使用场景) 消息中间件的使用场景有哪些

消息中间件，正如其名，就是在整个系统架构中扮演着“信息传递”的角色。它可以将不同地点，不同应用，不同时间的需求和信息进行合理的收集、排队和分发。消息中间件常用的包括RabbitMQ, ActiveMQ, Kafka, RocketMQ等。

消息中间件主要的使用场景如下：

应用程序解耦：如果应用程序直接与其它应用程序通信，那么一个应用程序的任何改动都可能影响其它应用程序。消息中间件在这种情况下可以作为应用程序之间的一个媒介。
松耦合系统：它允许系统与系统之间的通讯，无论它们是否正在运行，都不会影响系统的调用。只要发送者发送了消息，不论接受者是否在线，都能接受到消息。
流量消峰：在高并发场景，直接访问数据库可能会导致数据库连接异常，此时可以通过消息中间件进行流量的削峰。
重复消费及顺序消费：对于一些需要重复处理的业务，或者说一些需要顺序处理的业务，使用消息中间件能够很好的解决这个问题。

使用步骤如下：

安装消息中间件软件。例如安装RabbitMQ。
配置消息中间件。在管理界面中，添加需要的交换机类型，绑定相应的队列，设置路由键等。
代码层面的开发。

以RabbitMQ为例，对于Java开发来说，需要在pom.xml添加相关的依赖。

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.1.2</version>
</dependency>

然后在代码中创建连接工厂，获取连接。

ConnectionFactory factory = new ConnectionFactory();
//设置RabbitMQ地址
factory.setHost("localhost");
//设置RabbitMQ相关信息
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");
//创建一个新的连接
Connection connection = factory.newConnection();
//创建一个通道
Channel channel = connection.createChannel();

接着，我们可以根据需求来进行数据的发送和接收。如发送消息。

// 发送消息
String message = "Hello World!";
channel.basicPublish("", "QUEUE_NAME", null, message.getBytes("UTF-8"));

接收消息则需要定义一个消费者来进行消息的消费。

// 定义消费者
Consumer consumer = new DefaultConsumer(channel) {
    @Override
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
      String message = new String(body, "UTF-8");
      System.out.println("Received Message '" + message + "'");
    }
};
// 绑定消费者
channel.basicConsume("QUEUE_NAME", true, consumer);