邮件未添加到我的MSMQ

安德鲁·辛普森

我正在尝试第一次运行MSMQ服务。

我已经从MSDN复制了一个示例,并且正在尝试使其运行。

一切运行正常,没有任何错误。但是,当我去检查我的MSMQ时,没有消息可用/未添加。

我已经使用了跟踪工具SvcTraceViewe.exe,并且没有错误报告。

这是我在类DLL中定义的服务:

public class MotionSaver : IMotionSaver
{
    [OperationBehavior]
    public void MotionFrame(byte[] data)
    {
        // DO I NEED TO PUT ANTHING IN HERE??
    }
}

[ServiceContract]
public interface IMotionSaver
{
    //IsOneWay=true denotes that there will no return message from the server to the client.
    [OperationContract(IsOneWay = true)]
    void MotionFrame(byte[] data);
}

这是我的服务器主机,它调用上述DLL:

static void Main(string[] args)
{
    try
    {
        using (ServiceHost host = new ServiceHost(typeof(MotionSaver)))
        {
            //Path of the Queue. Here we are creating a private queue with the name VishalQ 
            //where all our message would be stored, if server is unavialable.
            string queueName = ConfigurationManager.AppSettings["queueName"];
            //Checking whether the queue exists or not.
            if (!MessageQueue.Exists(queueName))
            {
                //If the queue doesnot exists it will create a queue with the name VishalQ
                //the second parameter false denotes that the queue would be a non transaction queue. If you want that your queue to be 
                //transaction then make the second parameter to true.
                MessageQueue.Create(queueName, true);
            }
            //finally opening the host to server the clients.
            host.Open();
            Console.WriteLine("Server is up and running on port 32578");
            Console.WriteLine("Press any key to exit");
            Console.ReadKey();
        }
    }
    catch  (Exception ex)
    {
        Console.WriteLine(ex.ToString());
        Console.ReadKey();
    }
}

这是主机应用程序中我的app.config设置:

<configuration>
  <appSettings>
    <add key="queueName" value=".\private$\MotionSaverTest4" />
  </appSettings>

  <system.diagnostics>
    <trace autoflush="true" />
    <sources>
      <source name="System.ServiceModel"
              switchValue="Information, ActivityTracing"
              propagateActivity="true">
        <listeners>
          <add name="sdt"
              type="System.Diagnostics.XmlWriterTraceListener"
              initializeData= "SdrConfigExample.e2e" />
        </listeners>
      </source>
    </sources>
  </system.diagnostics>


  <system.serviceModel>
    <diagnostics performanceCounters="All"/>
    <services>
      <service name="InformedMotion.Motion.MotionSaver" behaviorConfiguration="myBehavior">
        <!--Address attribute specifies the name of the MSMQ Queue.-->
        <endpoint name="motionQ" address="net.msmq://localhost/private/MotionSaverTest4" binding="netMsmqBinding" 
                  bindingConfiguration="myMSMQ"                
                  contract="InformedMotion.Motion.IMotionSaver">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange"/>
        <host>
          <baseAddresses>
            <add baseAddress="net.msmq://localhost/private/"/>
            <!--Both Mex and HttpBinding uses http://localhost:8888 port-->
            <add baseAddress="http://localhost:32578"/>
          </baseAddresses>
        </host>
      </service>
    </services>
    <bindings>
      <!--The property exactlyOnce=false means that i am using non transactional queue. The property is by default true.-->
      <netMsmqBinding>
        <binding name="myMSMQ" exactlyOnce="true">
        <!--<binding name="myMSMQ" exactlyOnce="false" durable="false">-->
          <!--
                        If we donot set the security mode to none then the following error occurs.
                        Binding validation failed because the binding's MsmqAuthenticationMode property is set to 
                        WindowsDomain but MSMQ is installed with Active Directory integration disabled. 
                        The channel factory or service host cannot be opened.
                    -->
          <security mode="None"/>
        </binding>
      </netMsmqBinding>
    </bindings>
    <behaviors>
      <serviceBehaviors>
        <behavior name="myBehavior">
          <serviceMetadata httpGetEnabled="true"/>
          <!--This is for enabling an exception-->
          <serviceDebug includeExceptionDetailInFaults="true"/>
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>
<startup><supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2"/></startup></configuration>

这是调用该服务的客户端应用程序:

static void Main(string[] args)
{
    wsMotionQ.MotionSaverClient ws = new MotionSaverClient();
    ws.MotionFrame(new byte[] { 1 });

    Console.WriteLine("All Wishes sent successfully");
    Console.ReadLine();
}

这是我的客户端app.config:

<configuration>
    <system.serviceModel>
        <bindings>
            <netMsmqBinding>
                <binding name="motionQ">
                    <security mode="None" />
                </binding>
            </netMsmqBinding>
        </bindings>
        <client>
            <endpoint address="net.msmq://localhost/private/MotionSaverTest4"
                binding="netMsmqBinding" bindingConfiguration="motionQ" contract="wsMotionQ.IMotionSaver"
                name="motionQ">
                <identity>
                    <dns value="localhost" />
                </identity>
            </endpoint>
        </client>
    </system.serviceModel>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2"/>
  </startup>
</configuration>

我检查了我的消息队列是否已创建。

1)。如何将消息添加到队列中?我的服务中空方法的意义是什么?2)。为什么未添加我的消息?

谢谢

NB

更改为此代码:

[OperationBehavior]
public void MotionFrame(byte[] jpegData)
{
    using (Message msg = new Message())
    {
        msg.BodyStream = new MemoryStream(jpegData);
        msgQMissedData.Send(msg);
    }
}
蒂亚戈·库斯托迪奥(Thiago Custodio)

您只是在创建队列,但没有在队列中发送消息或从中接收消息。

http://www.codeproject.com/Articles/5830/Using-MSMQ-from-C

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章