Service Broker 内部激活中毒 - 在哪里？

Question

我收到有毒信息，但我不知道为什么。

我的代理设置如下所示：

CREATE MESSAGE TYPE
  [//DB/Schema/RequestMessage]
  VALIDATION = WELL_FORMED_XML;
CREATE MESSAGE TYPE
  [//DB/Schema/ReplyMessage]
  VALIDATION = WELL_FORMED_XML;

CREATE CONTRACT [//DB/Schema/Contract](
  [//DB/Schema/RequestMessage] SENT BY INITIATOR,
  [//DB/Schema/ReplyMessage] SENT BY TARGET
)

CREATE QUEUE Schema.TargetQueue

CREATE SERVICE [//DB/Schema/TargetService]
ON QUEUE Schema.TargetQueue (
  [//DB/Schema/Method3Contract]
)

CREATE QUEUE Schema.InitiatorQueue

CREATE SERVICE [//DB/Schema/InitiatorService]
ON QUEUE Schema.InitiatorQueue

然后我有我的内部激活程序：

CREATE PROCEDURE Schema.Import
AS

DECLARE @RequestHandle UNIQUEIDENTIFIER;
DECLARE @RequestMessage VARCHAR(8);
DECLARE @RequestMessageName sysname;

WHILE (1=1)
BEGIN
  BEGIN TRANSACTION;

  WAITFOR (
    RECEIVE TOP(1)
      @RequestHandle = conversation_handle,
      @RequestMessage = message_body,
      @RequestMessageName = message_type_name
    FROM
      Schema.TargetQueue

  ), TIMEOUT 5000;


  IF (@@ROWCOUNT = 0)
  BEGIN
    COMMIT TRANSACTION;
    BREAK;
  END

  EXEC Schema.ImportStep1 @ID = @RequestMessage;
  --EXEC Schema.ImportStep2 @ID = @RequestMessage;

  END CONVERSATION @RequestHandle;

  COMMIT TRANSACTION;
END

我的激活是通过以下方式启用的：

ALTER QUEUE Schema.TargetQueue
    WITH 
    STATUS = ON,
    ACTIVATION 
    ( STATUS = ON,
      PROCEDURE_NAME = Schema.Import,
      MAX_QUEUE_READERS = 10,
      EXECUTE AS SELF
    )

我用这个存储过程启动这个过程

CREATE PROCEDURE Schema.ImportStart
AS
BEGIN
  DECLARE @ID VARCHAR(8);

  DECLARE Cursor CURSOR FOR 
    SELECT ID FROM OtherDatabase.OtherSchema.ImportTable
    EXCEPT
    SELECT ID FROM Table

  OPEN Cursor;
  FETCH NEXT FROM Cursor INTO @ID;
  WHILE @@FETCH_STATUS = 0
  BEGIN
    DECLARE @InitiateHandle UNIQUEIDENTIFIER;
    DECLARE @RequestMessage VARCHAR(8);

    BEGIN TRANSACTION;

    BEGIN DIALOG
      @InitiateHandle
    FROM SERVICE
      [//DB/Schema/InitiatorService]
    TO SERVICE
      N'//DB/Schema/TargetService'
    ON CONTRACT
      [//DB/Schema/Contract]
    WITH
      ENCRYPTION = OFF;

    SELECT @RequestMessage = @ID;

    SEND ON CONVERSATION
      @InitiateHandle
    MESSAGE TYPE
      [//DB/Schema/RequestMessage]
      (@RequestMessage);

    COMMIT TRANSACTION;

    FETCH NEXT FROM Cursor INTO @ID;
  END
  CLOSE Cursor;
  DEALLOCATE Cursor;
END

所以这应该是如何工作的：

• 我执行 ImportStart
• 为每个 ID 生成一条消息
• 内部激活使导入步骤得以执行

相反，我收到有毒消息并且队列被禁用。

如果，

• 我将 Schema.TargetQue 激活设置为关闭
• EXEC schema.ImportStart
• EXEC 架构。手动导入

效果很好。

有什么见解吗？

Answer 1

嗯：

• 您的消息类型定义为well_formed_xml，但您将varchar(8) 作为消息正文发送。真的有用吗？
• 您使用[//DB/Schema/Method3Contract] 作为目标队列，但没有定义它。很可能是拼写错误。
• 您在队列激活中指定EXECUTE AS SELF。 BOL 对这个案例说了一些神秘的话：

  自我
  指定存储过程作为当前用户执行。 （执行此 ALTER QUEUE 语句的数据库主体。）

我不确定我是否理解引用的陈述，因为它显然与您的经验相矛盾。如果它是您的用户帐户，那么一切都应该没问题，因为您似乎拥有完成这项工作所需的所有权限。

所以，以防万一——Schema 架构的所有者是谁？该委托人拥有什么权限？而且，如果不是你，谁执行alter queue 语句（为什么）？

如果无法访问日志，诊断问题要困难得多，但我会先创建一个具有与您相同权限的新用户帐户，将其设置为 Schema 架构的所有者，然后慢慢处理它，撤销不必要的权限，直到它中断。当然，假设它会起作用。