1

真ん中のディストリビューターで動作するPubSubサンプルがあります-それらはすべて私のローカルマシン上にあります。現在、ディストリビューターを別のマシンに移動しようとしていますが、問題が発生しています。サブスクライバーはディストリビューターを介してパブリッシャーに登録されているようです（サブスクライバーの数を示し、適切な値を提供するログステートメントをパブリッシャーに追加しました）が、サブスクライバーはいずれも取得しません公開されたイベント。私は何が間違っているのですか？さまざまなキューに提供する必要のある権限はありますか？これが私の設定ファイルです：

出版社：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>

  <MsmqTransportConfig InputQueue="MyPublisherInputQueue" ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5" />

  <UnicastBusConfig DistributorControlAddress=""
    DistributorDataAddress=""
    ForwardReceivedMessagesTo="">
    <MessageEndpointMappings>
        <add Messages="MyMessages" Endpoint="distributorDataBus@rosmi" />
    </MessageEndpointMappings>
  </UnicastBusConfig>

</configuration>

サブスクライバー：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>

 <MsmqTransportConfig
    InputQueue="Subscriber1InputQueue_1"  
    ErrorQueue="error"
    NumberOfWorkerThreads="1"
    MaxRetries="5"
  />

  <UnicastBusConfig  DistributorControlAddress="distributorControlBus@rosmi" DistributorDataAddress="distributorDataBus@rosmi">
    <MessageEndpointMappings>
      <add Messages="MyMessages" Endpoint="MyPublisherInputQueue" /> <!-- I've also tried this with MyPublisherInputQueue@rrajagop -->
    </MessageEndpointMappings>
  </UnicastBusConfig>

</configuration>

ディストリビューター：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <appSettings>
    <add key="NumberOfWorkerThreads" value="1"/>

    <add key="DataInputQueue" value="distributorDataBus"/>
    <add key="ControlInputQueue" value="distributorControlBus"/>
    <add key="ErrorQueue" value="error"/>
    <add key="StorageQueue" value="distributorStorage"/>

    <add key="NameSpace" value="http://www.UdiDahan.com"/> 
    <!-- relevant for a Serialization of "interfaces" or "xml" -->

    <add key="Serialization" value="xml"/>
    <!-- can be either "xml", or "binary" -->
  </appSettings>
</configuration>

上記の構成では、ディストリビューターは「rosmi」というマシンで実行されており、パブリッシャーとサブスクライバーは「rrajagop」で実行されています。

4

1 に答える 1

0

問題を理解しました：マシン名のnslookupが間違ったIPアドレスを指しているために問題が発生していました-これはDHCPがマシンに別のIPを割り当てたためですが、DNSエントリの更新に時間がかかります。

于 2011-08-04T03:42:22.127 に答える