乐趣区

关于后端:消息传输不丢失掌握消息中间件的持久化机制

jiezi

当波及到音讯的长久化和重放时，咱们能够应用 Spring Boot 与 RabbitMQ 来实现这个场景。RabbitMQ 反对音讯的长久化，以确保在发送和接管过程中音讯不会失落。同时，咱们能够应用音讯的重放机制，以便在须要时从新发送音讯。

首先，咱们须要创立一个 Spring Boot 工程，并增加以下依赖项到 pom.xml 文件中：

<dependencies>
    <!-- Spring Boot Starter for RabbitMQ -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

接下来，咱们创立一个音讯发送者和接收者。首先，咱们定义一个音讯实体类Message：

public class Message implements Serializable {
    private String content;

    // 构造函数、Getter 和 Setter 省略...
}

而后，咱们创立一个音讯发送者MessageSender：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

@Component
public class MessageSender {
    @Autowired
    private AmqpTemplate amqpTemplate;

    @Bean
    public DirectExchange myExchange() {return new DirectExchange("my-exchange", true, false); // 设置交换器长久化为 true
    }

    public void sendMessage(Message message) {amqpTemplate.convertAndSend("my-exchange", "my-routing-key", message);
        System.out.println("Message sent:" + message.getContent());
    }
}

在上述代码中，咱们应用 AmqpTemplate 来发送音讯，并指定交换机名为my-exchange，路由键为my-routing-key。

接下来，咱们创立一个音讯接收者MessageReceiver：

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

@Component
public class MessageReceiver {
    @Bean
    public Queue myQueue() {return new Queue("my-queue", true); // 设置队列长久化为 true
    }

    @RabbitListener(queues = "my-queue")
    public void receiveMessage(Message message) {System.out.println("Message received:" + message.getContent());
    }
}

在上述代码中，咱们应用 @RabbitListener 注解来指定监听的队列为 my-queue，并定义了一个办法receiveMessage 来接管音讯。

接下来，咱们须要在 application.properties 文件中增加 RabbitMQ 的配置：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

在这个示例中，咱们假如 RabbitMQ 运行在本地，端口为 5672，用户名和明码为guest。

当初，咱们能够进行测试。咱们能够在 main 办法中调用发送音讯的代码：

@SpringBootApplication
public class MessagingApplication implements CommandLineRunner {
    @Autowired
    private MessageSender messageSender;

    public static void main(String[] args) {SpringApplication.run(MessagingApplication.class, args);
    }

    @Override
    public void run(String... args) {Message message = new Message();
        message.setContent("Hello, RabbitMQ!");

        messageSender.sendMessage(message);
    }
}

在这个示例中，咱们创立了一个 Message 对象，并调用 messageSender.sendMessage(message) 来发送音讯。

运行应用程序后，你应该可能在管制台上看到相似以下输入：

这表明音讯已胜利发送和接管。

在这个示例中，音讯是长久化的，这意味着即便 RabbitMQ 服务器在发送和接管过程中产生故障，音讯也会被保留，并在服务器复原后从新发送。

本文由 mdnice 多平台公布

退出移动版