我要评论1、主动拉取消费
@resource
private rabbittemplate rabbittemplate;
public void consumer(){
rabbittemplate.execute(channel -> {
list list = new arraylist();
while (true) {
getresponse response = channel.basicget("消费的对列名称", true);
byte[] b = response.getbody();
string json = new string(b);
log.error(json);
list.add(json);
}
return null;
});
}
2、监听方式进行消费
@rabbitlistener(queuestodeclare = @queue(value = “消费的对列名称”))
private void modelconvert(string content){
业务逻辑代码
}
提示：queuestodeclare 标记会对没有创建的对列进行自动创建。
发表评论