3

我正在运行安装了外部激活器的 SQL Server 2005 标准版。我在 SSMS 选项卡中有以下代码：

-- Begin a conversation and send a request message
DECLARE @InitDlgHandle UNIQUEIDENTIFIER;
DECLARE @RequestMsg NVARCHAR(100);

BEGIN TRANSACTION;
    BEGIN DIALOG @InitDlgHandle
        FROM SERVICE [//abc/XYZ/InitiatorPostService]
        TO SERVICE N'//abc/XYZ/TargetPostService'
        ON CONTRACT [//abc/XYZ/PostContract]
        WITH ENCRYPTION = OFF;

    SELECT @RequestMsg = N'<RequestMsg>Message for Target service.</RequestMsg>';

    SEND ON CONVERSATION @InitDlgHandle
        MESSAGE TYPE [//abc/XYZ/RequestPostMessage](@RequestMsg);

    SELECT @RequestMsg AS SentRequestMsg, @InitDlgHandle AS ConversationHandle;
COMMIT TRANSACTION;
GO

当我运行它时，我会在结果窗格中得到预期的输出。在 EATrace.log 中，我收到错误消息“通知消息类型 //abc/XYZ/RequestPostMessage 是意外的。”

-- Create message types
CREATE MESSAGE TYPE [//abc/XYZ/RequestPostMessage]  VALIDATION = WELL_FORMED_XML;
CREATE MESSAGE TYPE [//abc/XYZ/ReplyPostMessage]    VALIDATION = WELL_FORMED_XML;
GO

-- Create contract
CREATE CONTRACT [//abc/XYZ/PostContract]
     ([//abc/XYZ/RequestPostMessage] SENT BY INITIATOR,
     [//abc/XYZ/ReplyPostMessage] SENT BY TARGET
);
GO

-- Create target queue and service
CREATE QUEUE TargetPostQueue WITH RETENTION = ON;
CREATE SERVICE [//abc/XYZ/TargetPostService]
     ON QUEUE TargetPostQueue([//abc/XYZ/PostContract]);
GO

-- Create the initiator queue and service
CREATE QUEUE InitiatorPostQueue WITH RETENTION = ON;
CREATE SERVICE [//abc/XYZ/InitiatorPostService]
     ON QUEUE InitiatorPostQueue([//abc/xyz/PostContract]);
GO

-- Create a notification for External Activator
CREATE QUEUE NotificationPostQueue
CREATE SERVICE [//abc/xyz/NotificationPostService]
    ON QUEUE NotificationPostQueue([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification])
CREATE EVENT NOTIFICATION EventQueueActivation
    ON QUEUE [TargetPostQueue]
    FOR QUEUE_ACTIVATION
    TO SERVICE '//abc/xyz/NotificationPostService', 'current_database';
GO

-- Security
GRANT CONNECT TO [**Company**\**Machine**$]                          -- allow CONNECT to the notification database
GRANT RECEIVE ON TargetPostQueue TO [**Company**\**Machine**$]       -- allow RECEIVE from the service queue
GRANT RECEIVE ON NotificationPostQueue TO [**Company**\**Machine**$] -- allow RECEIVE from the notifcation queue
GRANT REFERENCES ON SCHEMA::dbo TO [**Company**\**Machine**$]        -- allow REFRENCES right on the notification queue schema

-- allow VIEW DEFINITION on the target service
GRANT VIEW DEFINITION ON SERVICE::[//abc/xyz/TargetPostService] TO [**Company**\**Machine**$]

-- allow VIEW DEFINITION on the notification service
GRANT VIEW DEFINITION ON SERVICE::[//abc/xyz/NotificationPostService] TO [**Company**\**Machine**$]
GO

EAService.config 中没有任何内容告诉 EA 预期的消息类型。为什么我收到此错误，而不是 EA 执行其配置文件中指定的应用程序？我的合同设置不正确吗？

** 以下新增部分：**

根据 Remus 的建议，我添加了以下内容：

-- Create a notification for External Activator
CREATE QUEUE NotificationPostQueue

CREATE SERVICE [//abc/xyz/NotificationPostService]
    ON QUEUE NotificationPostQueue([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification])

CREATE EVENT NOTIFICATION EventQueueActivation
    ON QUEUE [TargetPostQueue]
    FOR QUEUE_ACTIVATION
    TO SERVICE '//abc/xyz/NotificationPostService', 'current_database';
GO

但是当我将配置文件中的 NotificationService 名称从“//abc/xyz/TargetPostService”更改为“//abc/xyz/NotificationPostService”时，我收到错误“ERROR = 31, The notification service //abc/xyz/启动服务时，EATrace.log 中的 NotificationPostService 不存在”。但是，该服务在 sys.services 中列出。

** 错误 31 已解决，现在的问题是我的应用没有被调用 **

我使用了 Service Broker 团队博客中的示例应用程序，添加了用于调试目的的日志记录。它会在运行后立即写入日志文件，然后再执行其他任何操作。我已经通过从 VS2010 运行它来测试它并且工作正常，但是当我使用这个问题开头的代码发送消息时，不再创建。因此我知道我的应用程序不是由 EA 运行的。我如何诊断为什么会发生这种情况？我的 EAService.config 文件中的路径是正确的。这是整个文件：

<?xml version="1.0" encoding="utf-8"?>
<Activator xmlns="http://schemas.microsoft.com/sqlserver/2008/10/servicebroker/externalactivator"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://schemas.microsoft.com/sqlserver/2008/10/servicebroker/externalactivator EAServiceConfig.xsd"
           >
  <NotificationServiceList>
    <NotificationService name="//abc/xyz/NotificationPostService" id="100" enabled="true">
      <Description>My test notification service</Description>
      <ConnectionString>
        <!-- All connection string parameters except User Id and Password should be specificed here -->
        <Unencrypted>server=**MyServer**\**MyInstance**;database=CompanyRehabManagement;Application Name=External Activator;Integrated Security=true;</Unencrypted>
      </ConnectionString>
    </NotificationService>
  </NotificationServiceList>
  <ApplicationServiceList>
    <ApplicationService name="Company.xyz.EAProcessor" enabled="true">
      <OnNotification>
        <ServerName>**MyServer**\**MyInstance**</ServerName>
        <DatabaseName>**MyDbName**</DatabaseName>
        <SchemaName>dbo</SchemaName>
        <QueueName>TargetPostQueue</QueueName>
      </OnNotification>
      <LaunchInfo>
        <ImagePath>C:\Project\Pathway\Source\Company.xyz\Company.xyz.EAProcessor\bin\Debug\Company.xyz.EAProcessor.exe</ImagePath>
        <CmdLineArgs> %sqlserver% %database% %schema% %queue% </CmdLineArgs>
        <WorkDir>C:\Project\Pathway\Source\Company.xyz\Company.xyz.EAProcessor</WorkDir>
      </LaunchInfo>
      <Concurrency min="1" max="1" />
    </ApplicationService>
  </ApplicationServiceList>
  <LogSettings>
    <LogFilter>
      <TraceFlag>All Levels</TraceFlag>
      <TraceFlag>All Modules</TraceFlag>
      <TraceFlag>All Entities</TraceFlag>
    </LogFilter>
  </LogSettings>
</Activator>

我使用了正确的 QueueName 吗？此文件中是否还有其他可能的错误？我还能做些什么来诊断这个？这是发生的对话：

conversation_id,                      is_initiator, conversation_handle,                  local_service,                  remote_service,                 service_contract,       state_desc, far_broker_instance,                  security_timestamp,      send_sequence, receive_sequence, end_dialog_sequence, system_sequence
411C6F74-B29F-4C47-A538-1B9C900F49BD, 1,            7E7DD27A-E102-E011-93D2-0004239AA238, //abc/xyz/InitiatorPostService, //abc/xyz/TargetPostService,    //abc/xyz/PostContract, CONVERSING, 083E1179-A1C3-4414-A1A6-67238E3879CE, 1900-01-01 00:00:00.000, 1,             0,                -1,                  0
411C6F74-B29F-4C47-A538-1B9C900F49BD, 0,            817DD27A-E102-E011-93D2-0004239AA238, //abc/xyz/TargetPostService,    //abc/xyz/InitiatorPostService, //abc/xyz/PostContract, CONVERSING, 083E1179-A1C3-4414-A1A6-67238E3879CE, 2010-12-08 16:10:59.260, 0,             1,                -1,                  0
4

4 回答 4

3

创建事件通知时，应使用“当前数据库”（不带下划线）而不是“当前数据库”。'current database' 是一个特殊值，它将匹配当前数据库的代理 ID，而在您的情况下，事件通知会尝试将通知消息发送到代理 ID = 'current_database' 的服务。

于 2010-12-08T23:44:33.640 回答
2

外部激活器不监视您的队列，而是监视通知队列。外部激活由事件通知订阅驱动，例如：

CREATE EVENT NOTIFICATION EventQueueActivation
ON QUEUE [TargetPostQueue]
FOR QUEUE_ACTIVATION
TO SERVICE '...','...';

所以 SSBEA 需要它自己的队列来接收 QUEUE_ACTIVATION 通知消息。此队列必须具有支持http://schemas.microsoft.com/SQL/Notifications/PostEventNotification合同（事件通知合同）的服务。

在您的情况下，SSBEA 似乎配置为侦听TargetPostQueue自身的通知，因此它获取您的自定义应用程序消息而不是预期的事件通知消息。

于 2010-12-06T21:47:44.513 回答
1

关于问题末尾提到的ERROR 31的问题，请确保External Activator的配置文件中的连接字符串将初始目录明确设置为通知服务所在的数据库。否则它将尝试在主数据库中找到它，这显然会失败。

Service Broker 团队博客上提供了一个示例。

于 2010-12-07T19:45:01.480 回答
1

我想补充一点，EAConfig 中的 ApplicationService 名称属性需要与 SQL 中的 TargetService 相同。因此，如果您的目标服务称为 PostInsertedRecordsService，那么 ApplicationService 名称属性也将是 PostInsertedRecordsService。

于 2014-06-05T15:07:22.173 回答