使用 JMS 临时队列进行同步使用是否是一种很好的做法?
如果我们使用使用“临时队列”的JMS请求/应答机制,该代码是否可扩展?
截至目前,我们不知道我们是否将支持每秒100个请求,还是每秒支持1000个请求。
下面的代码是我想实现的。它以“同步”方式使用JMS。关键部分是创建“使用者”以指向为此会话创建的“临时队列”的位置。我只是无法弄清楚使用这样的临时队列是否是一种可扩展的设计。
destination = session.createQueue("queue:///Q1");
producer = session.createProducer(destination);
tempDestination = session.createTemporaryQueue();
consumer = session.createConsumer(tempDestination);
long uniqueNumber = System.currentTimeMillis() % 1000;
TextMessage message = session
.createTextMessage("SimpleRequestor: Your lucky number today is " + uniqueNumber);
// Set the JMSReplyTo
message.setJMSReplyTo(tempDestination);
// Start the connection
connection.start();
// And, send the request
producer.send(message);
System.out.println("Sent message:\n" + message);
// Now, receive the reply
Message receivedMessage = consumer.receive(15000); // in ms or 15 seconds
System.out.println("\nReceived message:\n" + receivedMessage);
更新:
我遇到了另一种模式,请参阅此博客 的想法是使用“常规”队列进行发送和接收。但是,对于“同步”调用,为了获得所需的响应(即匹配请求),您需要创建一个使用“选择器”侦听接收队列的使用者。
步骤:
// 1. Create Send and Receive Queue.
// 2. Create a msg with a specific ID
final String correlationId = UUID.randomUUID().toString();
final TextMessage textMessage = session.createTextMessage( msg );
textMessage.setJMSCorrelationID( correlationId );
// 3. Start a consumer that receives using a 'Selector'.
consumer = session.createConsumer( replyQueue, "JMSCorrelationID = '" + correlationId + "'" );
因此,此模式的不同之处在于,我们不会为每个新请求创建新的临时队列。相反,所有响应都只进入一个队列,但使用“选择器”来确保每个请求线程接收唯一关心的响应。
我认为这里的缺点是你必须使用“选择器”。我还不知道这是否比前面提到的模式更不受欢迎或更受欢迎。思潮?