我正在使用WCF服务中的TCP绑定,但是客户端的回调函数没有被调用。这是我的代码:
服务端:
public interface IMyContractCallback
{
[OperationContract(IsOneWay = true)]
void OnCallback();
}
[ServiceContract(CallbackContract = typeof (IMyContractCallback),SessionMode =
SessionMode.Required)]
public interface IService1
{
[OperationContract(IsOneWay = true)]
void DoSomething();
[OperationContract]
int GetCount();
}
public class Service1 : IService1
{
private int count=0;
public int GetCount()
{
return count;
}
public void DoSomething()
{
count++;
Console.WriteLine("increased count");
IMyContractCallback callback =
OperationContext.Current.GetCallbackChannel<IMyContractCallback>();
if ((callback as IChannel).State == CommunicationState.Opened)
{
callback.OnCallback();
}
}
}
我的客户是
public class App1
{
private MyServiceCallback callback;
private InstanceContext context;
private Service1Client proxy;
public App1()
{
callback=new MyServiceCallback();
context = new InstanceContext(callback);
var factory = new DuplexChannelFactory<IService1>(callback, "EndPointTCP");
IService1 proxy = factory.CreateChannel();
callback.proxy = proxy;
proxy.DoSomething();
}
}
public class MyServiceCallback : IService1Callback
{
public IService1 proxy
{
get;
set;
}
public void OnCallback()
{
Console.WriteLine("Callback thread = " + Thread.CurrentThread.ManagedThreadId);
Console.WriteLine(proxy.GetCount());
}
}
我面临两个问题:
1.使用上述代码,我无法从DoSomething接收回调。 2.如果我将DoSomething声明为双向绑定,则会收到回调,但会抛出异常“服务器未提供有意义的回复”。
我的客户端配置:
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<bindings>
<netTcpBinding>
<binding name="EndPointTCP" closeTimeout="00:10:00" openTimeout="00:10:00"
receiveTimeout="00:10:00" sendTimeout="00:10:00"
transactionFlow="false"
transferMode="Buffered" transactionProtocol="OleTransactions"
hostNameComparisonMode="StrongWildcard" listenBacklog="10"
maxBufferPoolSize="524288" maxBufferSize="65536" maxConnections="10"
maxReceivedMessageSize="65536">
<readerQuotas maxDepth="32" maxStringContentLength="8192"
maxArrayLength="16384"
maxBytesPerRead="4096" maxNameTableCharCount="16384" />
<reliableSession ordered="true" inactivityTimeout="00:20:00"
enabled="true" />
<security mode="Transport">
<transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
<message clientCredentialType="Windows" />
</security>
</binding>
</netTcpBinding>
<wsDualHttpBinding>
<binding name="EndPointHTTP" closeTimeout="00:01:00" openTimeout="00:01:00"
receiveTimeout="00:10:00" sendTimeout="00:01:00"
bypassProxyOnLocal="false"
transactionFlow="false" hostNameComparisonMode="StrongWildcard"
maxBufferPoolSize="524288" maxReceivedMessageSize="65536"
messageEncoding="Text" textEncoding="utf-8" useDefaultWebProxy="true">
<readerQuotas maxDepth="32" maxStringContentLength="8192"
maxArrayLength="16384"
maxBytesPerRead="4096" maxNameTableCharCount="16384" />
<reliableSession ordered="true" inactivityTimeout="00:10:00" />
<security mode="Message">
<message clientCredentialType="Windows"
negotiateServiceCredential="true"
algorithmSuite="Default" />
</security>
</binding>
</wsDualHttpBinding>
</bindings>
<client>
<endpoint address="masked"
binding="wsDualHttpBinding" bindingConfiguration="EndPointHTTP"
contract="ServiceReference1.IService1" name="EndPointHTTP">
<identity>
<servicePrincipalName value="masked" />
</identity>
</endpoint>
<endpoint address="masked"
binding="netTcpBinding" bindingConfiguration="EndPointTCP"
contract="ServiceReference1.IService1" name="EndPointTCP">
<identity>
<servicePrincipalName value="masked" />
</identity>
</endpoint>
</client>
</system.serviceModel>
</configuration>
我的服务配置
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<system.web>
<compilation debug="true" targetFramework="4.0"/>
<httpRuntime maxRequestLength="102400" />
</system.web>
<system.diagnostics>
<sources>
<source name="System.ServiceModel"
switchValue="Information, ActivityTracing"
propagateActivity="true">
<listeners>
<add name="traceListener"
type="System.Diagnostics.XmlWriterTraceListener"
initializeData= "d:\log\Traces.svclog" />
</listeners>
</source>
</sources>
</system.diagnostics>
<system.serviceModel>
<bindings>
<netTcpBinding>
<binding name="TcpBinding" maxBufferPoolSize="2147483647"
maxBufferSize="2147483647"
maxReceivedMessageSize="2147483647" portSharingEnabled="true" >
<readerQuotas maxDepth="32" maxStringContentLength="2147483647"
maxArrayLength="2147483647"
maxBytesPerRead="2147483647" maxNameTableCharCount="2147483647" />
<security mode="Transport"/>
<reliableSession enabled="true" />
</binding>
</netTcpBinding>
</bindings>
<services>
<service behaviorConfiguration="WcfService2.MyServiceBehaviour"
name="WcfService2.Service1">
<endpoint address="" binding="wsDualHttpBinding" bindingConfiguration=""
name="EndPointHTTP" contract="WcfService2.IService1" />
<endpoint address="" binding="netTcpBinding" bindingConfiguration="TcpBinding"
name="EndPointTCP" contract="WcfService2.IService1" isSystemEndpoint="false" />
<endpoint address="mex" binding="mexTcpBinding" bindingConfiguration=""
name="mexpoint" contract="IMetadataExchange" />
</service>
</services>
<behaviors>
<serviceBehaviors>
<behavior name="WcfService2.MyServiceBehaviour">
<serviceMetadata httpGetEnabled="false" />
<serviceThrottling maxConcurrentSessions="10000"/>
<serviceDebug includeExceptionDetailInFaults="true" />
<dataContractSerializer maxItemsInObjectGraph="2147483647" />
</behavior>
</serviceBehaviors>
</behaviors>
</system.serviceModel>
<system.webServer>
<modules runAllManagedModulesForAllRequests="true" />
<directoryBrowse enabled="true" showFlags="Date, Time, Size, Extension, LongDate" />
</system.webServer>
</configuration>
GetCount()
失败了。你同意吗? - Jay