Skip to content

Commit 5fec948

Browse files
committed
upload some blogs
1 parent d94eb52 commit 5fec948

File tree

1 file changed

+14
-12
lines changed

1 file changed

+14
-12
lines changed

_posts/2019/2019-07-07-how-to-use-amq.markdown

Lines changed: 14 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,9 @@ author: "LSG"
77
header-img: "img/lxy003.jpg"
88
catalog: true
99
tags:
10-
- sister
11-
- about
10+
- MQ
11+
- java
12+
- ActiveMQ
1213
---
1314

1415
## 前言
@@ -185,14 +186,14 @@ public void sendMessage(ActiveMQMessage msg, final String msgid) throws JMSExcep
185186

186187
## 消费者:
187188
### 同步阻塞接受:
188-
* 性能: 慢
189+
* 性能: 慢
190+
189191
但是维护容易,消息不易丢失,同时采用CLIENT_ACKNOWLEDGE来保证消息完好消费
190192
#### 代码示例:
191193

192-
```java
193-
Session session = aliyunAmqConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
194-
Queue workQueue = session.createQueue(queueName+"?consumer.prefetchSize=50");
195-
MessageConsumer consumer = session.createConsumer(workQueue);
194+
Session session = aliyunAmqConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
195+
Queue workQueue = session.createQueue(queueName+"?consumer.prefetchSize=50");
196+
MessageConsumer consumer = session.createConsumer(workQueue);
196197
while(true){
197198
// 停止信号
198199
if(stopFlag == 1){
@@ -206,13 +207,14 @@ public void sendMessage(ActiveMQMessage msg, final String msgid) throws JMSExcep
206207
}
207208
handle(message);
208209
}
209-
210-
```
210+
211211

212212
### 异步接收:
213-
1.自动确认接受
214-
2.手动确认接受
215-
* 性能: 快
213+
1. 自动确认接受
214+
2. 手动确认接受
215+
216+
* 性能: 快
217+
216218
#### 代码示例:
217219
```java
218220
public class LogConsumerWithAMQ implements MessageListener {

0 commit comments

Comments
 (0)