发送信息:
@Controller
public class controller {
@Autowired
private RabbitTemplate rabbitTemplate;
@Autowired
private AmqpAdmin amqpAdmin;
@RequestMapping("/send")
public void send(){
rabbitTemplate.convertAndSend("exchange.direct","antiguigu",new user("abc","bcd"));
}
}
接受信息:
public class Bookservice {
@RabbitListener(queues = "antiguigu")
public void receive(Book book, Channel channel, Message message){
System.out.println("收到信息"+message.getBody());
}
}
队列中将不会有任何剩余的消息,因为已经被@RabbitListener所接受并确认;
而后将接受信息的代码注释掉,rabbitmq则有