在应用程序终止时，WCF 中 IsOneWay=true 的方法会发生什么情况

Question

我有一个客户端应用程序，它偶尔会通知其服务进度。 对服务的方法调用标记为 IsOneWay=true，因为通知不需要任何返回值，而且我不想延迟。

客户端可能会向服务发出错误通知，然后终止。

问题是：单向方法调用在发送消息后是否返回调用者代码？ 或者它将消息排队，然后由另一个线程发送？

两个进程（客户端和服务）位于同一台机器上，我注意到有时（当机器过载时）服务不会收到错误通知。 我怀疑我提到的第二种选择会发生，但我不确定。

如果我是对的，我如何确保通知已发送并保留该方法？

Answer 1

我同意蒂莫西的观点。 我还想补充一点，WCF 服务为传入消息保留一个队列。 如果服务无法像消息传入一样快地处理消息，则该队列可能会变满。当传入队列变满时，WCF 将丢弃新消息。

我不确定如果单向消息被丢弃，客户端会发生什么。 我假设没有抛出异常/错误，但我不确定。

Answer 2

我遇到了类似的问题（单向调用不执行任何操作或抛出异常）。 我发现负责将方法参数从 xml 转换回对象的反序列化器正在创建一个异常。 我的服务方法从未被访问，并且没有异常被返回，因为它是单向调用。 直到我暂时禁用“单向”，我才检测到它，因此我的异常被传播回客户端。

希望这可以帮助处于类似情况的其他人。

Answer 3

好问题。 在客户端应用程序调用方法之前，它会打开通道。 该通道用于所有数据通信。 有两种发送方式：1) 可靠会话 - 当您的数据包被可靠地传递并重新发送破解的数据包时，2) 排序 - 当服务上的请求按照从客户端传输的顺序计算时（而不是如何传递） 。 如果您有可靠的有序会话，并且服务主机在关闭应用程序后遇到数据问题，主机将尝试要求客户端重新发送数据，并且在没有响应后拒绝您的所有请求。 在其他情况下（不可靠），打开通道后您可以发送数据并破坏通信，oneway 方法将计算您的请求，如果不会出现异常。

为了测试服务问题的一些可能性（不完全是您的客户端问题，但很有帮助），我创建了一个解决方案：

1）带有一个文件“IService1.cs”的库项目“WcfContracts”：

    [ServiceContract]
    public interface IService1
    {
        [OperationContract]
        void ThrowException();

        [OperationContract(IsOneWay=true)]
        void ThrowExceptionUseIsOneWay();
    }

2）控制台项目“WcfConsoleHoster”，其中引用了两个“ WcfContracts”，由三个文件组成：

a) Service1.cs，这是服务实现

public class Service1 : WcfContracts.IService1
{    
        public void ThrowException()
        {
            throw new Exception("Basic exception");
        }

        public void ThrowExceptionUseIsOneWay()
        {
            throw new Exception("Basic exception using IsOneWay=true");
        }
}

b) Program.cs，它具有默认入口点并仅启动服务

static void Main(string[] args)
    {
        ServiceHost host = new ServiceHost(typeof(Service1));
        host.Open();
        Console.WriteLine("host 1 opened");
        Console.ReadKey();
    }

c) 服务“App.config”

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <system.serviceModel>
    <services>
      <service behaviorConfiguration="behavourHttpGet" name="WcfConsoleHoster.Service1">
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:8732/Design_Time_Addresses/WcfConsoleHoster/Service1/" />
          </baseAddresses>
        </host>
        <endpoint binding="wsHttpBinding" contract="WcfContracts.IService1" />        
        <endpoint address ="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior name="behavourHttpGet">
          <serviceMetadata httpGetEnabled="true" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>
</configuration>

3) 控制台项目“WcfConsoleClient” ”，它只是调用服务

a) 在“Program.cs”中

Console.WriteLine("Wcf client. Press any key to start");
Console.ReadKey();
ChannelFactory<IService1> factory = new ChannelFactory<IService1>("Service1_Endpoint");
IService1 channel = factory.CreateChannel();
//Call service method
channel.ThrowException();

Console.WriteLine("Operation executed");
Console.ReadKey();

b) 客户端“App.config”

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <system.serviceModel>
    <client>
      <endpoint name="Service1_Endpoint"
        address="http://localhost:8732/Design_Time_Addresses/WcfConsoleHoster/Service1/"
        binding="wsHttpBinding"
        contract="WcfContracts.IService1">
      </endpoint>
    </client>
  </system.serviceModel>
</configuration>

---

1. 抛出异常。首先，我们调用双向方法，在服务器主机中抛出异常。 然后这个异常返回到客户端并且通道在客户端引发它，应用程序被销毁。 当然，您可以使用 try()catch{} 块来处理这个问题。

让我们通过调用 channel.ThrowExceptionUseIsOneWay(); 来查看单向方法的相同情况。 服务主机中引发异常，但客户端没有异常，我们得到“操作已执行”。 重要的是要认识到该通道将无法用于下次使用。

所以 IsOneWay=true 按预期工作 - 它仅以一种方式发送消息。 您不能从方法返回任何对象（预计为 void），并且不能使用FaultContract，或在服务启动后获得InvalidOperationException。

2. Thread.Sleep()。下一个测试是使用 Thread.Sleep() 进行大规模操作。
IService1 被扩展为

  [OperationContract]
  int ThreadSleep();

  [OperationContract(IsOneWay=true)]

，Service1.cs 中的实现是等待 5 秒

public int ThreadSleep()
{
    System.Threading.Thread.Sleep(TimeSpan.FromSeconds(5));
    return 1;
}

public void ThreadSleepUseIsOneWay()
{
    System.Threading.Thread.Sleep(TimeSpan.FromSeconds(5));
}

现在对客户端进行一点修改，用于计算已用调用时间

System.Diagnostics.Stopwatch stopwatch = new System.Diagnostics.Stopwatch();
stopwatch.Start();
//call methode
channel.ThreadSleep();
stopwatch.Stop();
Console.WriteLine(string.Format("Operation executed in {0} seconds", stopwatch.Elapsed.Seconds));
Console.ReadKey();

调用两种方式方法< /em> ThreadSleep() 的结果是“操作在 7 秒内执行”（线程睡眠 5 秒 + 通道初始化 2 秒）。

调用 channel.ThreadSleepUseIsOneWay() 的单向方法 的结果为“0 秒”！ 无需等待服务响应！

最好使用NetNamedPipeBinding，它可靠且可靠在同一台机器上快速连接。

Answer 4

您不能“确保发送通知”......并“保持方法单向”。 这有点违背了“OneWay”的含义:)

如果您想确保消息已发送，那么可以使用 TwoWay。 您很可能不会注意到轻微的性能影响。 如果服务器和客户端位于您提到的同一台计算机上......那么您根本不会注意到性能受到影响。

Answer 5

查看这篇文章以获取一些详细信息：
http://kennyw.com/?p=130

另外，我相信如果你有可靠的消息传递使请求将被验证为已成功发送，但正如上面的帖子所述，该服务将在该点之后结束连接。

Answer 6

这可能是使用 netMsmqBinding 的好地方。 所有 MSMQ 消息本质上都是 OneWay，因为队列本质上是断开连接的。 一旦客户端将消息与 netMsmq 客户端一起排队，它就可以安全地关闭，并且服务器稍后可以拾取该消息并处理它。