你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

MessageSender 类

定义

命名空间:

Microsoft.Azure.ServiceBus.Core

程序集:

Microsoft.Azure.ServiceBus.dll

包:

Microsoft.Azure.ServiceBus v5.2.0

Source:

MessageSender.cs

MessageSender 可用于将消息发送到队列或主题。

public class MessageSender : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.Core.IMessageSender

type MessageSender = class
    inherit ClientEntity
    interface IMessageSender
    interface ISenderClient
    interface IClientEntity

Public Class MessageSender
Inherits ClientEntity
Implements IMessageSender

继承

Object

ClientEntity

MessageSender

实现

IMessageSender ISenderClient IClientEntity

示例

创建要发送到队列的新 MessageSender

IMessageSender messageSender = new MessageSender(
    namespaceConnectionString,
    queueName)

发送消息

byte[] data = GetData();
await messageSender.SendAsync(data);

注解

这使用 AMQP 协议与服务通信。

构造函数

MessageSender(ServiceBusConnection, String, RetryPolicy)	在给定的 上创建新的 AMQP MessageSender ServiceBusConnection
MessageSender(ServiceBusConnection, String, String, RetryPolicy)	创建 ViaMessageSender。 这可用于通过另一个实体将消息发送到目标实体。
MessageSender(ServiceBusConnectionStringBuilder, RetryPolicy)	创建新的 AMQP MessageSender。
MessageSender(String, String, ITokenProvider, TransportType, RetryPolicy)	创建新的 MessageSender
MessageSender(String, String, RetryPolicy)	创建新的 AMQP MessageSender。

属性

ClientId	获取用于标识此客户端的 ID。 这可用于关联日志和异常。 (继承自 ClientEntity)
IsClosedOrClosing	如果客户端关闭或关闭，则返回 true。 (继承自 ClientEntity)
OperationTimeout	持续时间，之后单个操作将超时。
OwnsConnection	如果拥有连接，则返回 true;如果共享连接，则返回 false。 (继承自 ClientEntity)
Path	获取 MessageSender 的实体路径。 对于通过发送方，这将返回 via 实体的路径。
RegisteredPlugins	获取此发件人当前注册的插件的列表。
RetryPolicy	获取客户端 RetryPolicy 上定义的 。 (继承自 ClientEntity)
ServiceBusConnection	服务总线命名空间的连接对象。
TransferDestinationPath	对于通过发送方，获取消息的最终目标路径;否则为 null。
ViaEntityPath	对于通过发送方，则消息通过 ViaEntityPath发送到 TransferDestinationPath ;否则为 null。

方法

CancelScheduledMessageAsync(Int64)	取消已计划的消息。
CloseAsync()	关闭客户端。 关闭它打开的连接。 (继承自 ClientEntity)
OnClosingAsync()	关闭连接。
RegisterPlugin(ServiceBusPlugin)	ServiceBusPlugin注册要用于此发送方的 。
ScheduleMessageAsync(Message, DateTimeOffset)	计划稍后在服务总线上显示一条消息。
SendAsync(IList<Message>)	按 所述 Path将消息列表发送到实体。 当对分区实体调用时，用于不同分区的消息不能一起批处理。
SendAsync(Message)	按照 所述 Path将消息发送到实体。
ThrowIfClosed()	如果对象为 Closing，则引发 OperationCanceledException。 (继承自 ClientEntity)
UnregisterPlugin(String)	取消注册 ServiceBusPlugin。