RabbitMQ: 消息持久化

ゝ一世哀愁。 2023-07-20 13:31 33阅读 0赞

1交换器持久化
connectionFactory.setHost(“127.0.0.1”);
connectionFactory.setUsername(“guest”);
connectionFactory.setPassword(“guest”);
connectionFactory.setVirtualHost(“/“);
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT,true);
2队列的持久化
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
其中第二个参数为true

  1. 消息本身的持久化
    AMQP.BasicProperties prop = new AMQP.BasicProperties.Builder().deliveryMode(2).build();
    channel.basicPublish(“”, QUEUE_NAME, prop, message.getBytes(“utf-8”));

发表评论

表情：
评论列表 （有 0 条评论，33人围观）

还没有评论，来说两句吧...

相关阅读