springboot整合rabbitmq中@RabbitListener的方法如何获取Session对象

在springboot整合rabbitmq中，可以通过以下两种方式获取Session对象：

1. 通过连接工厂获取Session对象

@Autowired
private ConnectionFactory connectionFactory;

@RabbitListener(queues = "myQueue")
public void processMessage(String message) throws JMSException {
    Connection connection = connectionFactory.createConnection();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    // do something with session
}

2. 通过监听器容器获取Session对象

@Autowired
private SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory;

@RabbitListener(queues = "myQueue")
public void processMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
    ChannelAwareMessageListener listener = rabbitListenerContainerFactory.getMessageListener();
    Session session = ((ChannelProxy) listener).getDelegate().getConnection().createSession(false, Session.AUTO_ACKNOWLEDGE);
    // do something with session
}

请注意，在上述方法中，要确保Session对象在使用后被正确关闭。建议使用try-with-resources语句块来确保Session对象被正确关闭，如下所示：

try (Connection connection = connectionFactory.createConnection();
     Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
    // do something with session
} catch (JMSException e) {
    // handle exception
}