帮我写一段用线程池消费mq的事例代码

好的，以下是一个使用线程池消费MQ的示例代码：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;

public class MQConsumerThreadPool {
    private static final String BROKER_URL = "tcp://localhost:61616";
    private static final String QUEUE_NAME = "testQueue";
    private static final int THREAD_POOL_SIZE = 5;

    public static void main(String[] args) throws Exception {
        // 创建连接工厂
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE);

        // 创建连接和会话
        Connection connection = connectionFactory.createConnection();
        connection.start();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(QUEUE_NAME);

        // 创建消息消费者
        MessageConsumer consumer = session.createConsumer(destination);

        // 注册消息监听器
        consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                if (message instanceof TextMessage) {
                    TextMessage textMessage = (TextMessage) message;
                    String text = null;
                    try {
                        text = textMessage.getText();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    // 处理消息的业务逻辑
                    executorService.execute(new MessageHandler(text));
                }
            }
        });
    }

    // 处理消息的业务逻辑
    private static class MessageHandler implements Runnable {
        private String text;

        MessageHandler(String text) {
            this.text = text;
        }

        @Override
        public void run() {
            System.out.println("处理消息：" + text);
        }
    }
}

上述代码中，我们首先创建了一个线程池，然后创建了一个MQ连接和会话，接着创建了一个消息消费者并注册了消息监听器，当有消息到达时，会调用`onMessage`方法将消息交给线程池处理。线程池中的线程会执行`MessageHandler`类的`run`方法，这个方法中对消息进行了处理。

需要注意的是，在实际应用中，我们需要根据业务需求调整线程池的大小和消息监听器的处理方式。