Есть продюсер:
@Configuration
public class ToDoConfig {
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setMessageConverter(new Jackson2JsonMessageConverter());
return factory;
}
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate template = new RabbitTemplate(connectionFactory);
template.setMessageConverter(new Jackson2JsonMessageConverter());
template.setExchange("my_topic_exchange");
return template;
}
@Bean
public Queue queueCreation(@Value("${todo.amqp.queue}") String queue) {
return new Queue(queue, true, false, false);
}
}
@Component
@Log4j2
@AllArgsConstructor
public class ToDoProducer {
private final RabbitTemplate rabbitTemplate;
public void sendTo(String key, ToDo toDo) {
log.info("попытка отправить инфу");
this.rabbitTemplate.convertAndSend(key, toDo);
}
}
@AllArgsConstructor
@Log4j2
@Service
public class ScheduledBaySend {
private final ToDoProducer toDoProducer;
private final Environment environment;
private static Integer k = 0;
@Scheduled(fixedRate = 5000L)
public void send() {
toDoProducer.sendTo(this.environment.getProperty("todo.amqp.key"), new TodoBuilder()
.setName("mname " + k++)
.setDesc("desc").build());
}
}
и есть консюмер в том же приложении:
@Component
@Log4j2
public class ToDoConsumer {
private final ToDoRepository toDoRepository;
public ToDoConsumer(ToDoRepository toDoRepository) {
this.toDoRepository = toDoRepository;
}
@RabbitListener(queues = "${todo.amqp.queue}")
public void processTodo(ToDo message) {
log.info("Consumer >> {}", message);
this.toDoRepository.save(message);
log.info("Save todo >> {}", message);
}
}
провперти
# ключ по которому отправляется сообщение в топик
todo.amqp.key=my_key
# первая очередь которая забиндилась получать по ключу сообщение из топика
todo.amqp.queue=spring=boot
и вот я хочу чтобы очередь слушалась и со второго приложения но чтобы данные из одной очереди отдавались в два приложения т.е. если я отправил сообщение то оно должно отобразиться и в первом и во втором консюмере. конечно я могу в rabbitMQ создать ещё одну очередь например spring=boot2 и забиндиться на exchange и во втором приложении подписаться уже на вторую очередь а не на первую...
и данные тоже будут поступать равномерно
@Component
@Log4j2
public class ToDoConsumer {
private final ToDoRepository toDoRepository;
public ToDoConsumer(ToDoRepository toDoRepository) {
this.toDoRepository = toDoRepository;
}
@RabbitListener(queues = "spring=boot2")
public void processTodo(ToDo message) {
log.info("Consumer >> {}", message);
this.toDoRepository.save(message);
log.info("Save todo >> {}", message);
}
}
а получится ли получать равномерно данные из одной очереди , установив время жизни сообщения и указав что это консюмер уже другой.????