快捷導(dǎo)航

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

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

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

pom中導(dǎo)入坐標(biāo)

        <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 #消息隊(duì)列的默認(rèn)名字
pub-sub-domain: false #是否開啟消息訂閱模式

業(yè)務(wù)層代碼

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

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

監(jiān)聽器代碼

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

業(yè)務(wù)層代碼

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

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

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

您可能感興趣的文章: