亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

消息中間件之ActiveMQ

發布時間:2020-06-15 21:54:38 來源:網絡 閱讀:548 作者:微微一笑aaa 欄目:軟件技術

一,簡介
ActiveMQ是較優秀的JMS實現框架,在異步消息通信方面有簡單便捷,性能良好的優點。

二,安裝
下載地址:http://mirror.bit.edu.cn/apache/activemq/
解壓即可

三,啟動
windows啟動
linux啟動

四,java應用
依賴的包:activemq-all-5.12.0.jar
發送消息:
// 構造ConnectionFactory實例對象,此處采用ActiveMq的實現jar<br/>ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(<br/>ActiveMQConnection.DEFAULT_USER,<br/>ActiveMQConnection.DEFAULT_PASSWORD,<br/>"tcp://localhost:61616");<br/>// 構造從工廠得到連接對象<br/>Connection connection = connectionFactory.createConnection();<br/>// 啟動<br/>connection.start();<br/>// 獲取操作連接<br/>Session session = connection.createSession(Boolean.TRUE,<br/>Session.AUTO_ACKNOWLEDGE); <br/>Destination destination = session.createQueue("FirstQueue");<br/>// 得到消息生成者【發送者】<br/>MessageProducer producer = session.createProducer(destination);<br/>// 設置不持久化,此處學習,實際根據項目決定<br/>producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); <br/>
到此生產者對象生成,下一步發送數據
//創建消息<br/>TextMessage message = session<br/>.createTextMessage("ActiveMq 發送的消息");<br/>//發送<br/>producer.send(message);<br/>
消費者接受數據
創建連接如上
`//消息消費者對象
MessageConsumer consumer = session.createConsumer(destination);
//接收消息
TextMessage message = (TextMessage) consumer.receive(100000);

    `

五,消息管理
自帶管理:http://127.0.0.1:8161/admin/
用戶名密碼:默認用戶名密碼admin,admin
設置

    管理頁面主要幾個菜單:
    1,home:當前ActiveMq的信息,名稱,id,版本等
    2,queues:在當前消息中運行的隊列,以及隊列的生產者,消費者數目,入隊出隊消息數目等
    3,topic
    4,Subscribers 
    5,Connections
向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

庐江县| 和田县| 聊城市| 刚察县| 峨眉山市| 潼南县| 芜湖市| 修文县| 广水市| 文登市| 镇雄县| 稻城县| 资兴市| 犍为县| 金溪县| 奉节县| 洞头县| 都匀市| 姜堰市| 河东区| 上杭县| 乌鲁木齐市| 嘉鱼县| 海兴县| 铜鼓县| 保山市| 繁峙县| 安徽省| 乐安县| 蒙自县| 贵定县| 杂多县| 临洮县| 宁南县| 毕节市| 祁阳县| 闽侯县| 多伦县| 清原| 崇州市| 唐河县|