<destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" memorylimit="1500mb"> <policyEntry topic=">" memorylimit="5mb"> <dispatchPolicy> <strictOrderDispatchPolicy> </strictOrderDispatchPolicy> <subscriptionRecoveryPolicy> <lastImageSubscriptionRecoveryPolicy> </lastImageSubscriptionRecoveryPolicy> </subscriptionRecoveryPolicy> </dispatchPolicy> </policyEntry> </policyEntry> </policyEntries></policyMap></destinationPolicy>
測(cè)試結(jié)果:
1. 單獨(dú) producer
10,027 async non-persistent msgs / sec
4,462 persistent msgs / sec,,單位下同
2. 單獨(dú) consumer, 使用上步的數(shù)據(jù)
8,195
848
3. 同時(shí)producer 和 consumer, 當(dāng)producer到10萬條的時(shí)候開始 consumer
producer avg:
5,593
960
consumer avg:
4,462
1,002
結(jié)果分析:
- 同時(shí)producer&consumer偶爾有卡住3~5s的現(xiàn)象(可能硬盤慢造成,?),,但會(huì)自動(dòng)恢復(fù)
- 使用 async non-persistent 方式速度極快,,對(duì)于偶爾丟失少量數(shù)據(jù)不敏感的應(yīng)用極為適合。
- 使用 persistent 和 memcacheq 的速度區(qū)別不大,。
- ActiveMQ 可以 tuning,,因?yàn)橄嚓P(guān)配置復(fù)雜,沒有進(jìn)一步去研究。
|