AWS SQS与JMS：多队列订阅策略及并发优化

import javax.jms.*;
import com.amazon.sqs.javamessaging.SQSConnectionFactory;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;

public class SingleQueueSubscriber {

    public static void main(String[] args) throws JMSException {
        // 1. 创建SQSConnectionFactory
        SQSConnectionFactory factory = new SQSConnectionFactory(
            new SQSConnectionFactory.Builder()
                .withRegion(Regions.US_EAST_1) // 根据实际情况选择区域
                .withAWSCredentialsProvider(null) // 提供AWS凭证，例如DefaultAWSCredentialsProviderChain
                .build()
        );

        // 2. 创建连接
        Connection connection = factory.createConnection();

        // 3. 创建会话 (非事务性, 自动确认)
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 4. 创建队列对象
        Queue queue = session.createQueue("my-q-1");

        // 5. 创建消费者
        MessageConsumer consumer = session.createConsumer(queue);

        // 可选: 设置消息监听器
        consumer.setMessageListener(message -> {
            try {
                System.out.println("Received message from my-q-1: " + ((TextMessage) message).getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        });

        // 6. 启动连接
        connection.start();
        System.out.println("Listening to my-q-1. Press Ctrl+C to exit.");

        // 保持主线程运行，以便监听器可以接收消息
        // 通常在生产环境中，会使用线程池或管理框架来管理连接和会话生命周期
        try {
            Thread.sleep(Long.MAX_VALUE);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            if (connection != null) {
                connection.close();
            }
        }
    }
}

// ... (Connection和Session的创建与上述单队列示例相同) ...

// 创建第一个队列的消费者
Queue queue1 = session.createQueue("my-q-1");
MessageConsumer consumer1 = session.createConsumer(queue1);
consumer1.setMessageListener(message -> {
    // 处理来自my-q-1的消息
    System.out.println("From Q1: " + message);
});

// 创建第二个队列的消费者
Queue queue2 = session.createQueue("my-q-2");
MessageConsumer consumer2 = session.createConsumer(queue2);
consumer2.setMessageListener(message -> {
    // 处理来自my-q-2的消息
    System.out.println("From Q2: " + message);
});

connection.start();

// ... (Connection的创建与上述单队列示例相同) ...

// 为队列1创建独立的会话和消费者
Session session1 = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue1 = session1.createQueue("my-q-1");
MessageConsumer consumer1 = session1.createConsumer(queue1);
consumer1.setMessageListener(message -> {
    // 处理来自my-q-1的消息
    System.out.println("From Q1: " + message);
});

// 为队列2创建独立的会话和消费者
Session session2 = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue2 = session2.createQueue("my-q-2");
MessageConsumer consumer2 = session2.createConsumer(queue2);
consumer2.setMessageListener(message -> {
    // 处理来自my-q-2的消息
    System.out.println("From Q2: " + message);
});

connection.start();