Springboot整合ActiveMQ實現(xiàn)消息隊列的過程淺析

更新時間：2023年02月10日 11:14:38 作者：零維展開智子

昨天仔細研究了activeMQ消息隊列,也遇到了些坑,下面這篇文章主要給大家介紹了關于SpringBoot整合ActiveMQ的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下

pom中導入坐標

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>

書寫yml配置

spring:
activemq:
broker-url: tcp://localhost:61616
jms:
template:
default-destination: my #消息隊列的默認名字
pub-sub-domain: false #是否開啟消息訂閱模式

業(yè)務層代碼

@Service
public class MessageServiceActive implements MessageService {
    @Autowired
    private JmsMessagingTemplate template;
    @Override
    public void getMessage(String id) {
        template.convertAndSend("AA",id);        //自定義消息隊列名字
        System.out.println("待發(fā)送短信的訂單已納入處理隊列，id："+id);
    }
    @Override
    public String doMessage() {
        String id=template.receiveAndConvert("AA",String.class);
        return id;
    }

此時，你書寫控制層代碼就可以實現(xiàn)消息隊列了，不過有一個缺陷，那就是處理消息的時候必須手動書寫網(wǎng)址，調(diào)用執(zhí)行對應的方法才可以，不過我們可以通過監(jiān)聽器來實現(xiàn)自動化，就是一旦有消息產(chǎn)生就會立即處理。

監(jiān)聽器代碼

@Component
public class MessageListener {
    @Autowired
    private JmsMessagingTemplate template;
    @JmsListener(destination = "AA")    //要監(jiān)聽的消息隊列名稱
    @SendTo(value = "BB")        //自動化處理完，還可以把該消息傳遞給下一了消息隊列        
    public String receive(){
        String id=template.receiveAndConvert("AA",String.class);
        System.out.println("已完成短信發(fā)送業(yè)務，id："+id+"\n");
        return "new_"+id;       //利用返回值轉(zhuǎn)發(fā)給下一個
    }
}

業(yè)務層代碼

@Service
public class MessageServiceActive implements MessageService {
    @Autowired
    private JmsMessagingTemplate template;
    @Override
    public void getMessage(String id) {
        template.convertAndSend("AA",id);
        System.out.println("待發(fā)送短信的訂單已納入處理隊列，id："+id);
    }
}

這樣我們的消息就可以流水線似的處理了，這是點對點的消息隊列方式，還有訂閱式的。

到此這篇關于Springboot整合ActiveMQ實現(xiàn)消息隊列的過程淺析的文章就介紹到這了,更多相關Springboot整合ActiveMQ內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: