package com.debug.steadyjack.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.support.CorrelationData;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
/**
* Created by steadyjack on 2018/8/20.
*/
@Configuration
public class RabbitmqConfig {
private static final Logger log= LoggerFactory.getLogger(RabbitmqConfig.class);
@Autowired
private Environment env;
@Autowired
private CachingConnectionFactory connectionFactory;
@Autowired
private SimpleRabbitListenerContainerFactoryConfigurer factoryConfigurer;
/**
* 单一消费者
* @return
*/
@Bean(name = "singleListenerContainer")
public SimpleRabbitListenerContainerFactory listenerContainer(){
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setMessageConverter(new Jackson2JsonMessageConverter());
factory.setConcurrentConsumers(1);
factory.setMaxConcurrentConsumers(1);
factory.setPrefetchCount(1);
factory.setTxSize(1);
return factory;
}
/**
* 多个消费者
* @return
*/
@Bean(name = "multiListenerContainer")
public SimpleRabbitListenerContainerFactory multiListenerContainer(){
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factoryConfigurer.configure(factory,connectionFactory);
factory.setMessageConverter(new Jackson2JsonMessageConverter());
factory.setAcknowledgeMode(AcknowledgeMode.NONE);
factory.setConcurrentConsumers(env.getProperty("spring.rabbitmq.listener.concurrency",int.class));
factory.setMaxConcurrentConsumers(env.getProperty("spring.rabbitmq.listener.max-concurrency",int.class));
factory.setPrefetchCount(env.getProperty("spring.rabbitmq.listener.prefetch",int.class));
return factory;
}
@Bean
public RabbitTemplate rabbitTemplate(){
connectionFactory.setPublisherConfirms(true);
connectionFactory.setPublisherReturns(true);
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMandatory(true);
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
log.info("消息发送成功:correlationData({}),ack({}),cause({})",correlationData,ack,cause);
}
});
rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {
@Override
public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
log.info("消息丢失:exchange({}),route({}),replyCode({}),replyText({}),message:{}",exchange,routingKey,replyCode,replyText,message);
}
});
return rabbitTemplate;
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
SpringBoot整合RabbitMQ之Spring事件驱动模型-系统源码数据库流程图
共129个文件
xml:89个
class:14个
java:12个
需积分: 50 23 下载量 173 浏览量
2018-09-05
18:43:04
上传
评论
收藏 294KB RAR 举报
温馨提示
SpringBoot整合RabbitMQ之Spring事件驱动模型-系统源码数据库流程图 SpringBoot整合RabbitMQ实战视频教程:https://edu.csdn.net/course/detail/9314 (感兴趣也可以加QQ联系:1974544863)
资源推荐
资源详情
资源评论
收起资源包目录
SpringBoot整合RabbitMQ之Spring事件驱动模型-系统源码数据库流程图 (129个子文件)
RabbitmqConfig.class 4KB
BaseResponse.class 2KB
OrderRecord.class 2KB
OrderRecordController.class 2KB
PushOrderRecordListener.class 2KB
HelloWorldController.class 2KB
SpringbootRabbitmq01Application.class 2KB
StatusCode.class 2KB
RabbitmqConfig$2.class 1KB
RabbitmqConfig$1.class 1KB
PushOrderRecord2Listener.class 1KB
PushOrderRecordEvent.class 1KB
SpringbootRabbitmq01ApplicationTests.class 678B
OrderRecordMapper.class 573B
mvnw.cmd 5KB
.gitignore 268B
springboot-rabbitmq-01.iml 10KB
maven-wrapper.jar 46KB
RabbitmqConfig.java 4KB
OrderRecord.java 2KB
HelloWorldController.java 2KB
OrderRecordController.java 1KB
PushOrderRecordListener.java 1KB
SpringbootRabbitmq01Application.java 1KB
BaseResponse.java 1KB
PushOrderRecordEvent.java 1KB
PushOrderRecord2Listener.java 749B
StatusCode.java 604B
OrderRecordMapper.java 484B
SpringbootRabbitmq01ApplicationTests.java 351B
mvnw 6KB
业务流程图.png 21KB
log4j.properties 2KB
log4j.properties 2KB
application.properties 1KB
application.properties 1KB
maven-wrapper.properties 110B
springboot-rabbitmq-01 169KB
order_record.sql 2KB
业务流程.vsd 225KB
workspace.xml 71KB
OrderRecordMapper.xml 4KB
OrderRecordMapper.xml 4KB
pom.xml 4KB
mybatis-config.xml 3KB
mybatis-config.xml 3KB
spring-jdbc.xml 2KB
spring-jdbc.xml 2KB
misc.xml 872B
Maven__org_springframework_boot_spring_boot_test_autoconfigure_1_5_2_RELEASE.xml 769B
Maven__org_springframework_boot_spring_boot_starter_logging_1_5_2_RELEASE.xml 748B
Maven__org_springframework_boot_spring_boot_starter_tomcat_1_5_2_RELEASE.xml 741B
Maven__org_springframework_boot_spring_boot_autoconfigure_1_5_2_RELEASE.xml 734B
Maven__org_mybatis_spring_boot_mybatis_spring_boot_autoconfigure_1_1_1.xml 730B
Maven__org_springframework_boot_spring_boot_starter_test_1_5_2_RELEASE.xml 727B
Maven__org_springframework_boot_spring_boot_starter_amqp_1_5_2_RELEASE.xml 727B
Maven__org_springframework_boot_spring_boot_starter_jdbc_1_5_2_RELEASE.xml 727B
Maven__org_springframework_boot_spring_boot_starter_web_1_5_2_RELEASE.xml 720B
Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml 700B
Maven__org_springframework_boot_spring_boot_starter_1_5_2_RELEASE.xml 692B
Maven__org_mybatis_spring_boot_mybatis_spring_boot_starter_1_1_1.xml 688B
Maven__org_springframework_boot_spring_boot_test_1_5_2_RELEASE.xml 671B
Maven__org_apache_tomcat_embed_tomcat_embed_websocket_8_5_11.xml 660B
Maven__org_springframework_spring_expression_4_3_7_RELEASE.xml 658B
compiler.xml 656B
Maven__org_springframework_spring_messaging_4_3_7_RELEASE.xml 651B
Maven__org_springframework_amqp_spring_rabbit_1_7_1_RELEASE.xml 650B
Maven__org_springframework_retry_spring_retry_1_2_0_RELEASE.xml 647B
Maven__com_fasterxml_jackson_core_jackson_annotations_2_8_0.xml 644B
Maven__org_springframework_spring_context_4_3_7_RELEASE.xml 637B
Maven__org_springframework_boot_spring_boot_1_5_2_RELEASE.xml 636B
Maven__org_springframework_amqp_spring_amqp_1_7_1_RELEASE.xml 636B
Maven__org_hibernate_hibernate_validator_5_3_4_Final.xml 634B
Maven__org_springframework_spring_webmvc_4_3_7_RELEASE.xml 630B
Maven__org_apache_tomcat_embed_tomcat_embed_core_8_5_11.xml 625B
Maven__com_fasterxml_jackson_core_jackson_databind_2_8_7.xml 623B
Maven__org_springframework_spring_beans_4_3_7_RELEASE.xml 623B
Maven__org_springframework_spring_core_4_3_7_RELEASE.xml 616B
Maven__org_springframework_spring_test_4_3_7_RELEASE.xml 616B
Maven__org_springframework_spring_jdbc_4_3_7_RELEASE.xml 616B
Maven__com_squareup_retrofit2_converter_jackson_2_1_0.xml 614B
Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_11.xml 611B
Maven__javax_validation_validation_api_1_1_0_Final.xml 611B
Maven__org_springframework_spring_aop_4_3_7_RELEASE.xml 609B
Maven__org_springframework_spring_web_4_3_7_RELEASE.xml 609B
Maven__org_jboss_logging_jboss_logging_3_3_0_Final.xml 608B
Maven__org_springframework_spring_tx_4_3_7_RELEASE.xml 602B
Maven__com_fasterxml_jackson_core_jackson_core_2_8_7.xml 595B
Maven__com_rabbitmq_http_client_1_1_1_RELEASE.xml 588B
Maven__org_apache_httpcomponents_httpclient_4_5_3.xml 577B
Maven__ch_qos_logback_logback_classic_1_1_11.xml 575B
Maven__mysql_mysql_connector_java_5_1_37.xml 574B
Maven__org_apache_httpcomponents_httpcore_4_4_6.xml 563B
Maven__org_slf4j_log4j_over_slf4j_1_7_13.xml 562B
Maven__com_github_jsqlparser_jsqlparser_0_9_4.xml 561B
Maven__com_github_pagehelper_pagehelper_4_1_2.xml 561B
Maven__org_apache_tomcat_tomcat_jdbc_8_5_11.xml 559B
Maven__org_apache_tomcat_tomcat_juli_8_5_11.xml 559B
Maven__ch_qos_logback_logback_core_1_1_11.xml 554B
Maven__org_hamcrest_hamcrest_library_1_3.xml 553B
共 129 条
- 1
- 2
资源评论
修罗debug
- 粉丝: 1374
- 资源: 37
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功