Comment faire pour configurer et receiveAndConvert de la charge utile jSON dans le domaine de l'Objet au Printemps de Démarrage et RabbitMQ

Récemment, j'ai eu un vif intérêt sur Microservice de l'Architecture à l'aide de Printemps de Démarrage. Mon œuvre a deux Printemps applications de démarrage;

Demande Un reçoit les demandes à partir d'une API RESTful, convertit et envoie de la charge utile jSON pour un RabbitMQ filea.

Application de Deux, a souscrit à filea, reçoit la charge utile jSON(Objet de Domaine de l'Utilisateur) et est censé activer un service au sein de l'Application de Deux par exemple. envoyer un email à un utilisateur.

N'utilisant pas de XML dans mon Application de Deux configuration, comment puis-je configurer un convertisseur qui convertira la charge utile jSON reçu de RabbitMQ dans un Objet de Domaine de l'Utilisateur.

Ci-dessous sont des extraits de Printemps configurations de Démarrage sur l'Application de Deux

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
    }

}

OriginalL'auteur OchiengOlanga | 2015-04-12

  1. 10

    J'ai eu le même problème et après quelques recherches et essais, j'ai appris qu'il existe plus d'une façon de configurer votre RabbitMQ-Récepteur dans SpringBoot, mais il est important d'en choisir une et de s'en tenir à cela.

    Si vous décidez d'aller avec les Annotation Conduit L'Auditeur D'Extrémité, ce que je retire de votre utilisation de @EnableRabbit et @RabbitListener, que la configuration que vous avez posté n'a pas fonctionné pour moi. Ce qui a fonctionné est la suivante:

    Dériver votre Classe de Configuration de org.springframework.amqp.lapin.annotation.RabbitListenerConfigurer et remplacer la Méthode configureRabbitListeners comme suit:

     @Override
public void configureRabbitListeners(
        RabbitListenerEndpointRegistrar registrar) {
    registrar.setMessageHandlerMethodFactory(myHandlerMethodFactory());
}

    et ajouter un MessageHandlerFactory:

    @Bean
public DefaultMessageHandlerMethodFactory myHandlerMethodFactory() {
    DefaultMessageHandlerMethodFactory factory = new DefaultMessageHandlerMethodFactory();
    factory.setMessageConverter(new MappingJackson2MessageConverter());
    return factory;
}

    En outre, vous devez définir SimpleRabbitListenerContainerFactory (comme vous l'avez déjà fait) et de Autowire le correspondant ConnectionFactory:

    @Autowired
public ConnectionFactory connectionFactory;

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setConcurrentConsumers(3);
    factory.setMaxConcurrentConsumers(10);
    return factory;
}

    La finition de votre Configuration, vous devez définir les Fèves, qui s'occupe de vos Messages et hérite de l' @RabbitListerner-Annotations. Pour moi, j'ai nommé que EventResultHandler (que vous l'avez nommé TestService):

        @Bean
public EventResultHandler eventResultHandler() {
    return new EventResultHandler();
}

    Puis dans votre EventResultHandler (ou TestService) vous définissez l' @RabbitListener-Méthodes et leurs Files d'attente et de la Charge utile (= le POJO, où votre JSON Message est sérialisé):

    @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());
    }
}

    J'ai omis la nécessaire définition et la liaison de Files d'attente et des Échanges - vous pouvez le faire soit dans l'un ou dans l'autre Microservice - ou dans RabbitMQ-Serveur manuellement... Mais vous pour vous avez à faire.

    Vous monsieur.....mérite une médaille. Pour certains drôle de raison, après la mise à jour de mon projet parent au Printemps de Démarrage à 1.3.0.De presse il ya quelques jours mon précédent de mise en œuvre de cassé. Merci

    OriginalL'auteur jonashackt

  2. 6

    Créer un jackson message convertisseur et le mettre à l' MessageListenerAdapter#setMessageConverter

    @Bean
public MessageConverter jsonMessageConverter() {
    return new Jackson2JsonMessageConverter();
}

    Où ne viennent de MessageListenerAdapter ?

    Assurez-vous que vous importez la classe à droite afin d'obtenir ce travail vous avez besoin d'un org.springframework.amqp.de soutien.convertisseur de.MessageConverter et pas un org.springframework.de messagerie.convertisseur de.MessageConverter

    OriginalL'auteur Nicolas Labrot

  3. 0

    Comme par Ressort de Démarrage de la version 2.1.4.VERSION, vous pouvez effectuer les opérations suivantes:

    1. Déclarer "décoré" RabbitMq modèle avec Jackson message converter:
        @Bean
    RabbitTemplate rabbitTemplate(RabbitTemplate rabbitTemplate) {
            rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
           return rabbitTemplate
        }
    1. Lire le message de la file d'attente:
            var receievedValie = rabbitTemplate.receiveAndConvert("TestQueue", new ParameterizedTypeReference<Integer>() {
            @Override
            public Type getType() {
                return super.getType();
            }
        })

    OriginalL'auteur mr.M