activemq集合JMS處理非同步訊息

2021-05-23 02:44:04 字數 2442 閱讀 6350

jms 傳送 **:

public static void main(string args) throws exception   

session.commit();  

session.close();  

connection.close();  

}  原始碼

copy to clipboard列印?

public static void main(string args) throws exception    

session.commit();   

session.close();   

connection.close();   

}

public static void main(string args) throws exception 

session.commit();

session.close();

connection.close();

}

jms 接收**:

public static void main(string args) throws exception  

}); 

thread.sleep(30000); 

*/  

int i=0;  

while(i<3)   

session.close();  

connection.close();  

}  原始碼

copy to clipboard列印?

public static void main(string args) throws exception   

});  

thread.sleep(30000);  

*/  

int i=0;   

while(i<3)    

session.close();   

connection.close();   

}

public static void main(string args) throws exception 

});thread.sleep(30000);

*/ int i=0;

while(i<3)

session.close();

connection.close();

}

啟動 jmsreceiver 和 jmssender 可以在看輸出三條時間資訊。當然 jms 還指定有其它格式的資料,如 textmessage

結合 spring 的 jmstemplate 方便用:

}  原始碼

copy to clipboard列印?

public static void main(string args)    

});   

}

public static void main(string args) 

});}

receiver:

public static void main(string args)   

}  原始碼

copy to clipboard列印?

public static void main(string args)    

}

public static void main(string args) 

}

注意:直接用 jms 介面時接收了訊息後要提交一下,否則下次啟動接收者時還可以收到舊資料。有了 jmstemplate 就不用自己提交 session.commit() 了。如果使用了 pooledconnectionfactory 要把 apache-activemq-5.3.0/lib/optional/activemq-pool-5.3.0.jar 加到 classpath

摘自:http://my.oschina.net/liusoft/blog/2907

Active MQ技術文章 JMS

將已經有的mq的demo 傳送到部落格上 如何部署自己部署mq jml理論 wsad環境下jms非同步通訊全攻略 1 學習其對jms說明部分 使用 apache geronimo 和 jms 構建事件驅動的框架 jms 基本可靠性機制 和 事務機制 jms簡介與activemq實戰 總結的挺好的 配...

ActiveMQ的JMS訊息可靠機制

activemq訊息簽收機制 客戶端成功接收一條訊息的標誌是一條訊息被簽收,成功應答。訊息的簽收情形分兩種 1 帶事務的session 如果session帶有事務,並且事務成功提交,則訊息被自動簽收。如果事務回滾,則訊息會被再次傳送。2 不帶事務的session 不帶事務的session的簽收方式,...

JMS學習五(ActiveMQ的本地事務)

1 activemq的本地事務 在乙個jms客戶端,可以使用本地事務來組合訊息的傳送和接收。jms session介面提供了commit和rollback方法。事務提交意味著生產的所有訊息被傳送,消費的所有訊息被確認 事務回滾意味著生產的所有訊息被銷毀,消費的所有訊息被恢復並重新提交,除非它們已經過...