大佬教程收集整理的这篇文章主要介绍了如何在Spring Boot和RabbitMQ中配置和receiveAndConvert jSON有效负载到域对象,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
最近,我对使用Spring Boot的微服务架构产生了浓厚的兴趣.我的实现有两个Spring启动应用程序;
Application One接收来自RESTful API的请求,将jSON有效负载转换并发送到RabbitMQ队列A.
应用程序二,已订阅queueA,接收jSON有效负载(域对象用户),并且应该激活Application Two中的服务,例如.向用户发送电子邮件.
在我的Application Two配置中不使用XML,如何配置将从RabbitMQ接收的jSON有效负载转换为域对象用户的转换器.
以下是Application Two上Spring Boot配置的摘录
Application.class
@SpringBootApplication
@EnableRabbit
public class ApplicationInitializer implements CommandLineRunner {
final static String queuename = "user-registration";
@Autowired
RabbitTemplate rabbitTemplate;
@Autowired
AnnotationConfigApplicationContext context;
@Bean
Queue queue() {
return new Queue(queuename,falsE);
}
@Bean
TopicExchange topicExchange() {
return new TopicExchange("user-registrations");
}
@Bean
Binding binding(Queue queue,TopicExchange exchangE) {
return BindingBuilder.bind(queuE).to(exchangE).with(queueName);
}
@Bean
SimplemessageListenerContainer container(ConnectionFactory connectionFactory,messageListenerAdapter listenerAdapter) {
SimplemessageListenerContainer container = new SimplemessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueuenames(queueName);
container.setmessageListener(listenerAdapter);
return container;
}
public static void main(String[] args) {
SpringApplication.run(ApplicationInitializer.class,args);
}
@Override
public void run(String... args) throws Exception {
System.out.println("WaiTing for messages...");
}
}
Testservice.java
@Component
public class Testservice {
/**
* This test verifies whether this consumer receives message off the user-registration queue
*/
@RabbitListener(queues = "user-registration")
public void testReceiveNewUserNotificationmessage(User user) {
// do something like,convert payload to domain object user and send email to this user
}
}
如果您决定使用Annotation Driven Listener Endpoint,我使用的是@EnableRabbit和@RabbitListener,那么您发布的配置对我来说并不适用.有效的是以下内容:
从org.springframework.amqp.rabbit.Annotation.RabbitListenerConfigurer派生您的配置类,并重写方法configureRabbitListeners,如下所示:
@Override
public void configureRabbitListeners(
RabbitListenerEndpointRegistrar registrar) {
registrar.setmessageHandlerMethodFactory(myHandlerMethodFactory());
}
@Bean
public DefaultmessageHandlerMethodFactory myHandlerMethodFactory() {
DefaultmessageHandlerMethodFactory factory = new DefaultmessageHandlerMethodFactory();
factory.setmessageConverter(new MappingJackson2messageConverter());
return factory;
}
此外,您需要定义SimpleRabbitListenerContainerFactory(就像您已经做过的那样)并自动装配相应的ConnectionFactory:
@Autowired
public ConnectionFactory connectionFactory;
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setConcurrentConsumers(3);
factory.setMaxConcurrentConsumers(10);
return factory;
}
完成配置后,您需要定义Bean,它处理您的消息并继承@ RabbitListerner-Annotations.对我来说,我命名为EventResultHandler(您将其命名为TestservicE):
@Bean
public EventResultHandler eventResultHandler() {
return new EventResultHandler();
}
然后在EventResultHandler(或TestservicE)中定义@ RabbitListener-Methods及其相应的队列和Payload(= POJO,您的JSON消息序列化到的地方):
@Component
public class EventResultHandler {
@RabbitListener(queues=Queues.QUEUE_NAME_PRESENTATION_serviCE)
public void handlemessage(@Payload Event event) {
System.out.println("Event received");
System.out.println("EventType: " + event.getType().getText());
}
}
我省略了队列和交换所需的定义和绑定 – 你可以在一个或另一个微服务中 – 或者在RabbitMQ-Server中手动执行…但你肯定必须这样做.
以上是大佬教程为你收集整理的如何在Spring Boot和RabbitMQ中配置和receiveAndConvert jSON有效负载到域对象全部内容,希望文章能够帮你解决如何在Spring Boot和RabbitMQ中配置和receiveAndConvert jSON有效负载到域对象所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。