热久久伊人中文字幕无码,人妻无码中字中出,欧美黑白配精品视频第一页

本文記錄通過SDK收發消息時常見的問題。

開源客戶端是否可以直接訪問云上服務？

云消息隊列 RabbitMQ 版完全兼容開源RabbitMQ。開源RabbitMQ可以直接訪問云上服務。您需要通過云消息隊列 RabbitMQ 版控制臺生成靜態用戶名密碼之后，通過靜態賬戶直接訪問云上服務。如何創建靜態用戶名密碼，請參見靜態用戶名密碼管理。

支持哪些語言的開源SDK？

開源RabbitMQ提供的多語言或框架SDK云消息隊列 RabbitMQ 版全部都支持。具體信息，請參見開源RabbitMQ AMQP協議支持的多語言或框架SDK。

是否可以直接使用開源RabbitMQ JMS Client？

云消息隊列 RabbitMQ 版不支持直接使用開源RabbitMQ JMS Client。您需要通過Maven配置依賴庫才能接入云消息隊列 RabbitMQ 版收發消息。如何通過Maven配置依賴庫來收發消息，請參見JMS概述。

JMS標準有哪些接口不支持？

云消息隊列 RabbitMQ 版支持JMS 1.1。具體兼容的接口信息，請參見JMS接口兼容性。

如果是自動ACK，是否支持通過Reject來觸發消息重新入隊列？

不可以。您可以使用basicReject方法否定應答單條消息，或者使用basicNack方法否定應答一條或多條消息，并使消息重入隊列。

使用basicReject方法否定應答消息并使消息重入隊列

參數	說明
deliveryTag	Channel的消息投遞的唯一標識符。
requeue	被否定應答的消息是否重入隊列。如果設置為true，則消息重入隊列；如果設置為false，則消息被丟棄或發送到死信Exchange。更多信息，請參見死信Exchange。

使用basicNack方法否定應答多條消息并使消息重入隊列

參數	說明
deliveryTag	Channel的消息投遞的唯一標識符。
multiple	是否否定應答多條消息。如果設置為true，則否定應答帶指定deliveryTag的消息及該deliveryTag之前的多條消息；如果設置為false，則僅否定應答帶指定deliveryTag的單條消息。
requeue	被否定應答的消息是否重入隊列。如果設置為true，則消息重入隊列；如果設置為false，則消息被丟棄或發送到死信Exchange。更多信息，請參見死信Exchange。

示例代碼

channel.basicConsume("test", false, "consumertag", new DefaultConsumer(channel) {
   @Override
    public void handleDelivery(String consumerTag, Envelope envelope,
                      AMQP.BasicProperties properties, byte[] body)
            throws IOException {
        System.out.println("Rejected: " + new String(body, "UTF-8") + ", deliveryTag: " + envelope.getDeliveryTag() + ", messageId: " + properties.getMessageId());
        channel.basicNack(envelope.getDeliveryTag(), true, true);
    }
});

如何設置Message ID？

如果您需追蹤和識別消息，可以在云消息隊列 RabbitMQ 版的Producer客戶端設置Message ID屬性，為每條消息設置唯一標識符。

在云消息隊列 RabbitMQ 版的Producer客戶端設置Basic.Properties的message-id屬性。示例代碼如下：

Java

AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().messageId("messageid").build(); 
channel.basicPublish("${ExchangeName}", "RoutingKey", true, props, ("消息發送Body").getBytes(StandardCharsets.UTF_8));

Python

properties = pika.BasicProperties(app_id='example-publisher', content_type='application/json', 'message_id'='messageid')

PHP

$msg = new AMQPMessage($msgBody, ['application_headers'=>$amqpTable,'content_type' => 'text/plain', 'delivery_mode' => 2,'message_id' => 'messageid',]);

Go

err = ch.Publish( "helloExchange", "hello", false, false, amqp.Publishing { ContentType: "text/plain", Body: []byte(body), MessageId: "messageId", })

Node.js

channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: null, body: body);

如何刪除隊列消息？

您可以使用Java客戶端庫中queuePurge方法刪除某個隊列的所有消息。示例代碼如下：

channel.queuePurge("queue-name");

如何在開源客戶端設置加密傳輸？

以下示例使用默認的非加密端口5672，如果使用加密傳輸，需要連接5671端口，并設置

com.rabbitmq.client.ConnectionFactory的SslProtocol。

 private void setSSL(com.rabbitmq.client.ConnectionFactory factory) throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
        SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
        
        TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
        trustManagerFactory.init((KeyStore) null);
        
        sslContext.init(null, trustManagerFactory.getTrustManagers(), null);
        
        factory.useSslProtocol(sslContext);
    }

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

SDK FAQ