ActiveMQ詳細入門使用教程

2021-10-23 00:06:52 字數 2743 閱讀 4365

mq是訊息中介軟體，是一種在分布式系統中應用程式藉以傳遞訊息的媒介，常用的有activemq，rabbitmq，kafka。activemq是apache下的開源專案，完全支援jms1.1和j2ee1.4規範的jms provider實現。 

特點： 

1、支援多種語言編寫客戶端 

2、對spring的支援，很容易和spring整合 

3、支援多種傳輸協議：tcp,ssl,nio,udp等 

4、支援ajax 

訊息形式： 

1、點對點（queue） 

2、一對多（topic） 

activemq安裝

我這裡提供乙個安裝好的虛擬機器： 

伺服器執行後，我們可以直接訪問到activemq的介面： 

activemq測試

org.apache.activemq


activemq-all


5.14.4
queue的傳送**如下:

public void testmqproducerqueue() throws exception
接收**：   

public void testmqconsumerqueue() throws exception catch (jm***ception e) }}


});//8、程式等待接收使用者訊息


system.in.read();


//9、關閉資源


consumer.close();


session.close();


connection.close();


}
然後當我們執行queue傳送的時候可以看到佇列裡已經有一條訊息了，但沒有傳送出去： 

然後在執行queue 的接收端，可以看到訊息已經發出了： 

接著對topic進行測試，傳送**如下：

public void testtopicproducer() throws exception
接收**：   

public void testtopicconsumer() throws exception catch (jm***ception e) }}


});//8、程式等待接收使用者訊息


system.in.read();


//9、關閉資源


consumer.close();


session.close();


connection.close();


}
然後執行topic傳送： 

可以看到訊息已經傳送出去。再執行topic接收： 

可以看到有了乙個消費者，但是沒有接收的訊息，這是因為正常情況下我們的topic訊息不會再伺服器持久化，所以要先開啟消費者，再開啟生產者，這個時候我們再執行生產者傳送一條訊息看到訊息已經接收到了： 

activemq整合spring及專案中運用

org.springframework


spring-context


<?xml version="1.0" encoding="utf-8"?>  
然後在我們淘淘**中，商品新增到資料庫的時候，對應也要新增資料到我們的solr索引中，所以生產者應該在插入資料後建立： 

當然，在xml檔案中配置好的jmstemplate和destination也要注入進來：

@autowired


private jmstemplate jmstemplate;


@resource(name="itemaddtopic")


private destination destination;
然後消費者應該寫在我們的搜尋工程中，首先新增spring和activemq的jar包，然後配置xml檔案，再編寫乙個***，當接收到訊息時，就講資料存入索引庫，xml檔案**如下：  

<?xml version="1.0" encoding="utf-8"?>  

backdoor factory詳細使用教程

backdoor factory是一款後門構建工具。與其他工具不同的是，他不會增加軟體的大小，而是利用 縫隙進行注入，免殺效果更好。執行命令 git clone h 檢視幫助資訊 f 測試指定檔案 s 檢查軟體是否支援patch s 指定payload，可以通過 show 來檢視 h 指定回連的ip...

ActiveMQ入門 ActiveMQ環境搭建

解壓縮就能用，執行bin資料夾下面的可執行檔案 cd users szz downloads apache activemq 5.15.9 bin macosx macosx activemq startstarting activemq broker.可以開啟它的管理介面http localhos...

ActiveMQ入門例項

解壓縮apache activemq 5.5.1 bin.zip，然後雙擊apache activemq 5.5.1 bin activemq.bat執行activemq程式。啟動activemq以後，登陸 http localhost 8161 admin 建立乙個queue，命名為firstqu...