.net core 怎么实现向service bus发送消息
可以使用 Microsoft.Azure.ServiceBus NuGet 包来向 Azure Service Bus 发送消息。以下是一个示例代码:
-
安装 Microsoft.Azure.ServiceBus NuGet 包。
-
使用以下代码向 Service Bus 发送消息:
using Microsoft.Azure.ServiceBus;
using System.Text;
using System.Threading.Tasks;
public static async Task SendMessageAsync(string connectionString, string queueName, string message)
{
IQueueClient queueClient = new QueueClient(connectionString, queueName);
byte[] messageBytes = Encoding.UTF8.GetBytes(message);
Message queueMessage = new Message(messageBytes);
await queueClient.SendAsync(queueMessage);
await queueClient.CloseAsync();
}
其中,connectionString 是 Service Bus 的连接字符串,queueName 是队列名,message 是要发送的消息。
- 调用 SendMessageAsync 方法,向 Service Bus 发送消息:
string connectionString = "Endpoint=sb://<your-namespace>.servicebus.windows.net/;SharedAccessKeyName=<your-policy-name>;SharedAccessKey=<your-policy-key>";
string queueName = "<your-queue-name>";
string message = "Hello, world!";
await SendMessageAsync(connectionString, queueName, message);
此代码将向名为 “
原文地址: http://www.cveoy.top/t/topic/tYD 著作权归作者所有。请勿转载和采集!