<bean id="connectionFactory" class="org.springframework.amqp.rabbit.connection.RabbitMQConnectionFactory"> <property name="host" value="localhost" /> <property name="port" value="5672" /> <property name="username" value="guest" /> <property name="password" value="guest" /> </bean> <rabbit:template id="rabbitTemplate" connection-factory="connectionFactory" /> <rabbit:admin connection-factory="connectionFactory" /> <rabbit:queue name="myQueue" durable="true" /> <rabbit:direct-exchange name="myExchange"> <rabbit:bindings> <rabbit:binding queue="myQueue" key="myRoutingKey" /> </rabbit:bindings> </rabbit:direct-exchange> @Autowired private RabbitTemplate rabbitTemplate; public void send(String message) { rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message); } @RabbitListener(queues = "myQueue") public void receive(String message) { System.out.println("Received message: " + message); }


上一篇:
下一篇:
切换中文