{% extends "base.html" %} {% load i18n %} {% block title %}{% trans "Infrastructure" %}{% endblock %} {% block content %} <div class="modal fade" id="myModal" tabindex="-1" role="dialog" aria-labelledby="myModalLabel"> <div class="modal-dialog" role="document"> <div class="modal-content"> <div class="modal-header"> <button type="button" class="close" data-dismiss="modal" aria-label="Close"><span aria-hidden="true">×</span></button> <h4 class="modal-title" id="myModalLabel">提示</h4> </div> <div class="modal-body"> <p>是否确定把业务切换到主机-Primary Server…？</p> <br> <p>操作前,请与技术人员确认</p> </div> <form class="modal-footer" method="post" action="{% url 'instances'%}"> <button type="button" class="btn btn-default" data-dismiss="modal">关闭</button> <button type="button" class="btn btn-primary">确定</button> </form> </div> </div> </div>

时间: 2023-10-15 08:02:29 浏览: 85

springboot整合rabbitmq，开启手工确认。保证消息100%投递

在Spring Boot应用中整合RabbitMQ，以确保消息100%投递，是一个关键的实践，特别是对于那些需要高可靠性和数据一致性的系统。RabbitMQ是一个流行的开源消息代理，它遵循Advanced Message Queuing Protocol (AMQP)标准，提供可靠的消息传递功能。下面将详细解释如何在Spring Boot中配置RabbitMQ，并启用手动确认机制来增强消息的可靠性。我们需要在Spring Boot项目中引入RabbitMQ的相关依赖。这通常通过在`pom.xml`或`build.gradle`文件中添加Spring AMQP的依赖完成。对于Maven项目，可以添加以下依赖： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> ``` 接下来，我们需要配置RabbitMQ的相关属性。这可以在`application.properties`或`application.yml`中完成。例如： ```properties spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest ``` 现在，让我们创建一个RabbitMQ的配置类，定义连接工厂、交换机、队列和绑定。这里我们使用`@Configuration`注解来声明这是一个配置类： ```java @Configuration public class RabbitConfig { @Value("${spring.rabbitmq.queue.name}") private String queueName; @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory factory = new CachingConnectionFactory(); factory.setHost("localhost"); factory.setPort(5672); factory.setUsername("guest"); factory.setPassword("guest"); return factory; } @Bean public AmqpAdmin amqpAdmin() { return new RabbitAdmin(connectionFactory()); } @Bean public SimpleMessageListenerContainer container() { SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); container.setConnectionFactory(connectionFactory()); container.setQueueNames(queueName); container.setMessageListener(messageListenerAdapter()); return container; } @Bean public MessageListenerAdapter messageListenerAdapter() { return new MessageListenerAdapter(new RabbitReceiver()); } @Bean public Queue queue() { return new Queue(queueName, true); // durable 队列，保证重启后仍然存在 } @Bean public DirectExchange exchange() { return new DirectExchange("exchange-name", true, false); // durable 交换机 } @Bean public Binding binding(Queue queue, DirectExchange exchange) { return BindingBuilder.bind(queue).to(exchange).with(queueName); } } ``` 在上述配置中，我们定义了一个名为`queueName`的队列，一个`exchange-name`的直接交换机，并将它们绑定在一起。`RabbitReceiver`是一个自定义的类，用于处理接收到的消息。为了实现消息100%投递，我们需要启用消费者的手动确认模式（`channel.confirmSelect()`）。在Spring Boot中，我们可以通过扩展`SimpleMessageListenerContainer`来实现这一点： ```java @Configuration public class RabbitConfigWithManualAck extends SimpleMessageListenerContainer { public RabbitConfigWithManualAck(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) { super(connectionFactory, listenerAdapter); setAcknowledgeMode(AcknowledgeMode.MANUAL); } @Override protected void doStart() throws Exception { super.doStart(); Channel channel = getChannel(); if (channel != null) { channel.confirmSelect(); } } } ``` 在`RabbitReceiver`类中，我们需要实现`ChannelAwareMessageListener`接口，并在`onMessage`方法中处理消息并发送确认： ```java @Service public class RabbitReceiver implements ChannelAwareMessageListener { @Override public void onMessage(Message message, Channel channel) throws Exception { try { // 处理消息，例如：业务逻辑 // ... // 确认消息已被成功处理 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (Exception e) { // 如果处理消息时发生异常，可以拒绝消息，让它重新入队 channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); } } } ``` 通过这种方式，我们确保了消息只有在成功处理后才会被确认，如果处理过程中出现任何问题，消息将被拒绝并重新投入队列。这样，我们就能达到Spring Boot整合RabbitMQ并开启手工确认，保证消息100%投递的目标。以上就是关于Spring Boot与RabbitMQ整合以及手动确认机制的详细解释，希望对您有所帮助。在实际开发中，您可能还需要根据具体需求调整配置，例如设置超时时间、处理失败后的重试策略等。

这是一段 HTML 代码，用于展示一个模态框（Modal），其中包含一个提示信息和两个按钮：关闭和确定。该模态框的作用是询问用户是否确定将业务切换到主机-Primary Server，并提醒用户在操作前与技术人员确认。代码中还包含一个表单（form），用于提交用户的选择结果。该表单的 action 属性指定了提交数据的 URL。

阅读全文

相关推荐

robocode机器人比赛中胜率高达90%的代码

dajngo中继承模板的用法举例说明{%extends base.html%}

html {% extends 'base.html' %} {% block content %} Video Analysis Result {% for image in images %} {% endfor %} {% endblock %} 给出以上HTML文件继承的父文件base.html

{% extends 'base.html' %}

{% extends 'base.html' %} {% block title %}用户列表{% endblock %} {% block content %} 用户列表 姓名 <form action="{{ url_for('blog.user_list') }}" method="post"> {% for i in name %} {{i}} {% endfor %} </form> {% endblock %}

UserLogIn extends JFrame.java

i18n元素：lit-html和Polymer的I18N基本元素

flutter_i18n_2021:示例项目显示了使用新的i18n Flutter方法的基本设置

Extends.java

Flutter+getX+I18n示例

react国际化化插件react-i18n-auto使用详解

{% block messages %} {% if messages %} {% for message in messages %} {{ message }} {% endfor %} {% endif %} {% endblock %}登录和注册界面都有 message 怎么分开

{% block title%} {% endblock %}怎么用不了

html中 {% block style %}{% endblock %} 是什么意思？怎么使用？

*Django {%blockdetails%}{%endblock%}**的用法

1、什么是ORM?并简述模型与数据库表的映射关系。 2、简述模板标签{% include %}和{% extends %}的区别。 3、cookie是如何产生的，有什么作用

写一个登录界面的base.html

最新推荐

详解JAVA中implement和extends的区别

构建基于Django和Stripe的SaaS应用教程

管理建模和仿真的文件

R语言数据处理与GoogleVIS集成：一步步教你绘图

如何使用Matlab实现PSO优化SVM进行多输出回归预测？请提供基本流程和关键步骤。

Symfony2框架打造的RESTful问答系统icare-server

"互动学习：行动中的多样性与论文攻读经历"

R语言与GoogleVIS包：打造数据可视化高级图表

在三级客户支持体系中，服务台工程师是如何处理日常问题并与其他层次协作以确保IT服务质量和连续性的？

蓝桥杯Python试题解析与答案题库

{% extends 'base.html' %} {% block title %}用户列表{% endblock %} {% block content %} 用户列表

姓名

<form action="{{ url_for('blog.user_list') }}" method="post"> {% for i in name %} {{i}}

{% endfor %} </form> {% endblock %}