ドキュメントの例は、http://msdn.microsoft.com/en-us/library/ms789008.aspxおよびhttp://msdn.microsoft.com/en-us/library/ms751493.aspxにあります。
IIS7 アプリケーション プールが起動しない問題は認識していますが (プレウォーミング手法を使用してこれを回避しようとしています)、Visual の WebDev で実行している場合でも、WCF Web サービスが MSMQ からメッセージを受信することはできません。ローカル PC 上の Studio 2010。
以下の簡単なテストは上記のドキュメントに基づいていますが、簡単なデモでさえうまくいかないようです。
以下をビルドし、以下のテスト行を使用すると、2 番目のものだけが書き出されます。最初の 1 つは MSMQ に送られ、送信先によって取得されることはありません。
a) 「これはテストです。」b) 「!これは別のテストです。」
データの一部をサービス エンドポイントに送信するコンソール クライアントを作成しました。
class Program
{
static void Main(string[] args)
{
string input;
while (!string.IsNullOrEmpty(input = Console.ReadLine()))
{
if (input.StartsWith("!") && input.Length > 1)
{
using (var client = new MSMQClient.DirectServiceRef.Service1Client())
{
client.Log(input.Substring(1));
}
}
else
{
using (var client = new MSMQClient.LogServiceRef.Service2Client())
{
client.Log(input);
}
}
}
Console.WriteLine("Done.");
Console.ReadKey();
}
}
App.config:
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<bindings>
<basicHttpBinding>
<binding name="BasicHttpBinding_IService2">
<security mode="None" />
</binding>
<binding name="BasicHttpBinding_IService1">
<security mode="None" />
</binding>
</basicHttpBinding>
</bindings>
<client>
<endpoint address="http://localhost:1910/Service2.svc" binding="basicHttpBinding"
bindingConfiguration="BasicHttpBinding_IService2" contract="LogServiceRef.IService2"
name="BasicHttpBinding_IService2" />
<endpoint address="http://localhost:1909/Service1.svc" binding="basicHttpBinding"
bindingConfiguration="BasicHttpBinding_IService1" contract="DirectServiceRef.IService1"
name="BasicHttpBinding_IService1" />
</client>
</system.serviceModel>
</configuration>
Service2 は、入力を受信して MSMQ に送信する単純なサービスです。
[ServiceContract]
public interface IService2
{
[OperationContract]
bool Log(string data);
}
public class Service2 : IService2
{
public Service2()
{
var queueName = ConfigurationManager.AppSettings["queueName"];
if (!MessageQueue.Exists(queueName))
{
MessageQueue.Create(queueName, true);
}
}
[OperationBehavior]
public bool Log(string data)
{
using (var client = new MSMQService2.MSMQServiceRef.Service1Client())
{
using (var scope = new TransactionScope(TransactionScopeOption.Required))
{
client.Log(data);
scope.Complete();
}
}
return true;
}
}
Web.config:
<?xml version="1.0"?>
<configuration>
<appSettings>
<add key="queueName" value=".\private$\Service1.svc" />
</appSettings>
<system.web>
<compilation debug="true" targetFramework="4.0" />
</system.web>
<system.serviceModel>
<behaviors>
<serviceBehaviors>
<behavior>
<serviceMetadata httpGetEnabled="true"/>
<serviceDebug includeExceptionDetailInFaults="false"/>
</behavior>
</serviceBehaviors>
</behaviors>
<bindings>
<netMsmqBinding>
<binding name="msmqBinding">
<security mode="None" />
</binding>
</netMsmqBinding>
</bindings>
<services>
<service name="logService">
<endpoint binding="basicHttpBinding"
contract="MSMQService2.IService2" />
</service>
</services>
<client>
<endpoint address="net.msmq://localhost/private/Service1.svc"
binding="netMsmqBinding"
bindingConfiguration="msmqBinding"
contract="MSMQServiceRef.IService1" />
</client>
<serviceHostingEnvironment multipleSiteBindingsEnabled="true" />
</system.serviceModel>
<system.webServer>
<modules runAllManagedModulesForAllRequests="true"/>
</system.webServer>
</configuration>
Service1 は、入力を受け取り、それをローカル ファイルに記録する単純なサービスです。
[ServiceContract]
public interface IService1
{
[OperationContract(IsOneWay=true)]
void Log(string data);
}
public class Service1 : IService1
{
public Service1()
{
var queueName = ConfigurationManager.AppSettings["queueName"];
if (!MessageQueue.Exists(queueName))
{
MessageQueue.Create(queueName, true);
}
}
[OperationBehavior(TransactionAutoComplete=true, TransactionScopeRequired=true)]
public void Log(string data)
{
using (var log = new FileInfo(ConfigurationManager.AppSettings["logFilePath"]).AppendText())
{
log.WriteLine(data);
}
}
}
Web.config:
<?xml version="1.0"?>
<configuration>
<appSettings>
<add key="logFilePath" value="C:\testlog.txt"/>
<add key="queueName" value=".\private$\Service1.svc"/>
</appSettings>
<system.web>
<compilation debug="true" targetFramework="4.0" />
</system.web>
<system.serviceModel>
<behaviors>
<serviceBehaviors>
<behavior>
<serviceMetadata httpGetEnabled="true"/>
<serviceDebug includeExceptionDetailInFaults="false"/>
</behavior>
</serviceBehaviors>
</behaviors>
<bindings>
<netMsmqBinding>
<binding name="msmqBinding">
<security mode="None" />
</binding>
</netMsmqBinding>
</bindings>
<services>
<service name="logService">
<endpoint address="net.msmq://localhost/private/Service1.svc"
binding="netMsmqBinding"
bindingConfiguration="msmqBinding"
contract="MSMQService1.IService1" />
</service>
</services>
<serviceHostingEnvironment multipleSiteBindingsEnabled="true" />
</system.serviceModel>
<system.webServer>
<modules runAllManagedModulesForAllRequests="true"/>
</system.webServer>
</configuration>
この最後のサービスは、MSMQ からのメッセージを "受信" していないようです。これは、デスクトップからソリューションを実行している場合、またはサービスを Server 2008 / IIS7 展開に展開し、クライアントをリモートまたはローカルで実行している場合の両方で発生します。
Windows の設定で確認すべきオプションがいくつかありますか?
よろしく、ロブ。