SEND (Transact-SQL)

  • 项目

适用于：SQL ServerAzure SQL 托管实例

使用一个或多个现有会话发送消息。

Transact-SQL 语法约定

语法

  
SEND  
   ON CONVERSATION [(]conversation_handle [,.. @conversation_handle_n][)]  
   [ MESSAGE TYPE message_type_name ]  
   [ ( message_body_expression ) ]  
[ ; ]

注意

若要查看 SQL Server 2014 (12.x) 及更早版本的 Transact-SQL 语法，请参阅早期版本文档。

自变量

ON CONVERSATION conversation_handle [.. @conversation_handle_n]
指定消息所属的会话。 conversation_handle 必须包含一个有效的会话标识符。 不能多次使用相同的会话句柄。

MESSAGE TYPE message_type_name
指定发送的消息的消息类型。 必须将此消息类型包含在这些会话使用的服务约定中。 这些约定必须允许从此会话方发送该类型的消息。 例如，会话的目标服务只能发送在约定中指定为 SENT BY TARGET 或 SENT BY ANY 的消息。 如果省略此子句，则消息类型为 DEFAULT。

message_body_expression
提供一个表示消息主体的表达式。 Message_body_expression 是可选的。 但如果存在 message_body_expression，则表达式必须是一个可以转换为 varbinary(max) 的类型。 该表达式不能为 NULL。 如果省略该子句，则消息主体为空。

注解

重要

如果 SEND 语句不是批处理或存储过程中的第一个语句，则必须使用分号 (;) 终止前面的语句。

SEND 语句将来自一个或多个 Service Broker 会话一端的服务的消息传送到这些会话另一端的服务。 然后，使用 RECEIVE 语句从目标服务的关联队列中检索发送的消息。

提供给 ON CONVERSATION 子句的会话句柄来自以下三个来源之一：

  • 如果发送的消息不是为了响应从另一服务收到的消息，则使用从创建此会话的 BEGIN DIALOG 语句返回的会话句柄。

  • 如果发送的消息是为了响应之前从另一服务收到的消息，则使用由返回原始消息的 RECEIVE 语句返回的会话句柄。

  • 包含 SEND 语句的代码与包含提供会话句柄的 BEGIN DIALOG 或 RECEIVE 语句的代码有时是分开的。 在这些情况下，会话句柄必须是传递给包含 SEND 语句的代码的状态信息中的数据项之一。

发送到其他 SQL Server 数据库引擎实例中的服务的消息将存储在当前数据库的传输队列中，直到可以将这些消息传输到远程实例中的服务队列为止。 发送到同一数据库引擎实例中的服务的消息被直接放入与这些服务关联的队列中。 如果因出现某种情况导致无法将本地消息直接放入目标服务队列中，则可以先将本地消息存储在传输队列中，直到解决了这种情况为止。 这些事件的示例包括某些类型的错误或目标服务队列处于非活动状态。 可使用 sys.transmission_queue 系统视图查看传输队列中的消息。

SEND 是一个原子语句。 如果在多个会话中发送消息的 SEND 语句失败（例如，对话处于错误状态时），则不会将任何消息存储在传输队列中，也不会将消息放入任何目标服务队列中。

Service Broker 优化使用相同 SEND 语句在多个会话中发送的消息的存储和传输。

一个实例的传输队列中的消息按照以下顺序传输：

  • 与其关联的会话端点的优先级别。

  • 在优先级别内，依照它们在会话中的发送顺序。

如果 HONOR_BROKER_PRIORITY 数据库选项设置为 ON，则会话优先级中指定的优先级别仅应用于传输队列中的消息。 如果 HONOR_BROKER_PRIORITY 设置为 OFF，则会为该数据库的传输队列中的所有消息都分配默认优先级别 5。 优先级别不会应用于 SEND，其中消息直接放入 数据库引擎 的同一示例中的服务队列中。

SEND 语句分别锁定发送消息的每个会话，以确保每个会话按顺序传送消息。

SEND 在用户定义的函数中无效。

权限

若要发送消息，当前用户必须在每个发送消息的服务的队列中具有 RECEIVE 权限。

示例

以下示例启动一个对话，并在该对话中发送一条 XML 消息。 为了发送此消息，该示例将 xml 对象转换为 varbinary(max)。

DECLARE @dialog_handle UNIQUEIDENTIFIER,
    @ExpenseReport XML;

SET @ExpenseReport = <construct message as appropriate for the application>;

BEGIN DIALOG @dialog_handle
    FROM SERVICE [//Adventure-Works.com/Expenses/ExpenseClient]
    TO SERVICE '//Adventure-Works.com/Expenses'
    ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseProcessing];

SEND ON CONVERSATION @dialog_handle
    MESSAGE TYPE [//Adventure-Works.com/Expenses/SubmitExpense](@ExpenseReport);

以下示例启动三个对话，并在每个对话中发送一条 XML 消息。

DECLARE
    @dialog_handle1 UNIQUEIDENTIFIER,
    @dialog_handle2 UNIQUEIDENTIFIER,
    @dialog_handle3 UNIQUEIDENTIFIER,
    @OrderMsg XML;

SET @OrderMsg = '<construct message as appropriate for the application>';

BEGIN DIALOG @dialog_handle1
    FROM SERVICE [//InitiatorDB/InitiatorService]
    TO SERVICE '//TargetDB1/TargetService'
    ON CONTRACT [//AllDBs/OrderProcessing];

BEGIN DIALOG @dialog_handle2
    FROM SERVICE [//InitiatorDB/InitiatorService]
    TO SERVICE '//TargetDB2/TargetService'
    ON CONTRACT [//AllDBs/OrderProcessing];

BEGIN DIALOG @dialog_handle3
    FROM SERVICE [//InitiatorDB/InitiatorService]
    TO SERVICE '//TargetDB3/TargetService'
    ON CONTRACT [//AllDBs/OrderProcessing];

SEND ON CONVERSATION (
    @dialog_handle1,
    @dialog_handle2,
    @dialog_handle3
)
    MESSAGE TYPE [//AllDBs/OrderMsg](@OrderMsg);

另请参阅

BEGIN DIALOG CONVERSATION (Transact-SQL)
END CONVERSATION (Transact-SQL)
RECEIVE (Transact-SQL)
sys.transmission_queue (Transact-SQL)