@RabbitListener的代码实例

下面是一个使用@RabbitListener注解的简单示例：

@Component
public class RabbitMQListener {

    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的代码中，我们定义了一个名为RabbitMQListener的Java类，并在类上添加了@Component注解，以将其标记为Spring组件。然后，我们在类中定义了一个方法receiveMessage()，并在该方法上使用@RabbitListener注解来指示它将监听名为“myQueue”的RabbitMQ队列。当消息到达该队列时，该方法将被调用，并将消息作为字符串参数传递给它。

要使用上面的代码，您需要在Spring应用程序中配置一个RabbitMQ连接工厂并创建一个名为“myQueue”的队列。然后，您可以将RabbitMQListener组件添加到您的应用程序中，并开始接收来自该队列的消息。

相关问题

RabbitMQ中@RabbitListener注解使用pull模式该怎么设置

RabbitMQ的@RabbitListener注解默认使用push模式，但也可以设置为pull模式。在使用pull模式时，需要将containerType属性设置为SimpleMessageListenerContainer，并配置acknowledgeMode为MANUAL。

示例代码如下：

@RabbitListener(
    id = "myListener",
    containerFactory = "myContainerFactory",
    bindings = @QueueBinding(
        value = @Queue(value = "myQueue"),
        exchange = @Exchange(value = "myExchange", type = "topic"),
        key = "myKey"
    ),
    containerType = SimpleMessageListenerContainer.class,
    acknowledgeMode = AcknowledgeMode.MANUAL
)
public void handleMessage(Message message, Channel channel) throws IOException {
    // 处理消息
    channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}

其中，myContainerFactory是自定义的SimpleRabbitListenerContainerFactory实例。在该实例中，可以设置prefetchCount属性，以控制每次从消息队列拉取的消息数量。例如：

@Bean
public SimpleRabbitListenerContainerFactory myContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
    factory.setPrefetchCount(10); // 每次从队列中拉取10条消息
    return factory;
}

我用不了这个@RabbitListener(queues = "myQueue.*") 换个方式实现动态监听以什么开头的队列

如果你的Spring Boot版本较低，或者不支持`@RabbitListener`注解和通配符`*`、`#`，你可以通过编程方式实现动态监听以特定前缀开头的队列。

以下是一个示例代码，实现了监听以`myQueue.`开头的队列：

首先，在你的配置类中注入`RabbitListenerEndpointRegistry`：

@Configuration
public class RabbitMQConfig {
    @Autowired
    private RabbitListenerEndpointRegistry registry;
    // ...
}

然后，编写一个方法来动态添加监听器：

public void addListeners(String prefix) {
    SimpleRabbitListenerEndpoint endpoint = new SimpleRabbitListenerEndpoint();
    endpoint.setMessageListener(new MyMessageListener());

    String queueName = prefix + UUID.randomUUID().toString();
    endpoint.setQueueNames(queueName);

    // 注册监听器
    registry.registerListenerContainer(endpoint, new MyRabbitListenerContainerFactory(), true);

    // 启动监听器
    registry.getListenerContainer(endpoint).start();
}

这个方法会创建一个`SimpleRabbitListenerEndpoint`实例，设置消息监听器和队列名称。然后，使用`RabbitListenerEndpointRegistry`注册监听器，使用自定义的`MyRabbitListenerContainerFactory`创建监听器容器，并启动监听器。

最后，你需要编写一个消息监听器来处理消息，例如：

public class MyMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        // 处理消息
    }
}

当要监听以`myQueue.`开头的队列时，只需要调用`addListeners("myQueue.")`方法即可。这将会创建一个以`myQueue.`开头的随机队列，并启动一个监听器来监听这个队列。