WCF回调超时的问题
问题
-
/// <summary> /// WCF 访问的服务契约 /// </summary> [ServiceContract(CallbackContract = typeof(IServiceCallback))] public interface IService { /// <summary> /// 执行添加操作 /// </summary> [OperationContract] [TransactionFlow(TransactionFlowOption.Allowed)] void Insert(DataPortal data); /// <summary> /// 执行更新操作 /// </summary> [OperationContract] [TransactionFlow(TransactionFlowOption.Allowed)] void Update(DataPortal data); /// <summary> /// 执行删除操作 /// </summary> [OperationContract] [TransactionFlow(TransactionFlowOption.Allowed)] void Delete(DataPortal data); /// <summary> /// 执行查询操作 /// </summary> [OperationContract] void Load(DataPortal data); } /// <summary> /// WCF 服务回调接口 /// </summary> [ServiceContract] public interface IServiceCallback { /// <summary> /// 服务器端在执行过程中时调用 /// </summary> /// <param name="sender">触发该事件的对象</param> /// <param name="e">引发的 YiYou.Wcf.OperatingEventArgs 事件</param> [OperationContract(IsOneWay = true)] void OnProcessing(object sender, OperatingEventArgs e); /// <summary> /// 服务器端在执行过程中时调用 /// </summary> /// <param name="sender">触发该事件的对象</param> /// <param name="e">引发的 YiYou.Wcf.OperatedEventArgs 事件</param> [OperationContract(IsOneWay = true)] void OnCompleted(object sender, OperatedEventArgs e); }
/// <summary> /// 服务契约的实现 /// </summary> [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Reentrant)] public class Service : IService { /// <summary> /// 添加 /// </summary> public void Insert(DataPortal data) { } /// <summary> /// 更新 /// </summary> public void Update(DataPortal data) { } /// <summary> /// 删除 /// </summary> public void Delete(DataPortal data) { } /// <summary> /// 加载 /// </summary> public void Load(DataPortal data) { IServiceCallback callback = OperationContext.Current.GetCallbackChannel<IServiceCallback>(); callback.OnProcessing(null, new OperatingEventArgs(OperationAction.Load)); } }
private void button1_Click(object sender, EventArgs e) { InstanceContext context = new InstanceContext(new ClientCallback()); NetTcpBinding binding = new NetTcpBinding(); EndpointAddress address = new EndpointAddress("net.tcp://localhost:9901/Client.svc"); using (DuplexChannelFactory<IService> channel = new DuplexChannelFactory<IService>(context, binding, address)) { IService service = channel.CreateChannel(); DataPortal data = new DataPortal(); using (service as IDisposable) { service.Load(data); } } } public class ClientCallback : YiYou.Wcf.IServiceCallback { public void OnProcessing(object sender, YiYou.Wcf.OperatingEventArgs e) { Console.WriteLine("OnProcessing:" + e.Action); } public void OnCompleted(object sender, YiYou.Wcf.OperatedEventArgs e) { Console.WriteLine("OnCompleted"); } }
还有一个异常是在客户端 Callback的时候提示： “服务器未提供有意义的回复；这可能是由协定不匹配、会话过早关闭或内部服务器错误引起的。”
在：callback.OnProcessing(new DataPortal(), new OperatingEventArgs(OperationAction.Load));
服务器配置：
<behaviors> <serviceBehaviors> <behavior> <dataContractSerializer maxItemsInObjectGraph="6553600"/> </behavior> </serviceBehaviors> </behaviors> <bindings> <netTcpBinding> <binding name="customTcpBindding" maxReceivedMessageSize="2147483647"> <security mode="None" /> <readerQuotas maxDepth="32" maxStringContentLength="2147483647" maxArrayLength="2147483647" maxBytesPerRead="2147483647" maxNameTableCharCount="2147483647" /> </binding> </netTcpBinding> </bindings>
客户端配置：<system.serviceModel> <bindings> <netTcpBinding> <binding name="customNetTcpBinding" maxReceivedMessageSize="2147483647" maxBufferSize="2147483647"> <security mode="None" /> <readerQuotas maxDepth="32" maxStringContentLength="2147483647" maxArrayLength="2147483647" maxBytesPerRead="2147483647" maxNameTableCharCount="2147483647" /> </binding> </netTcpBinding> </bindings> </system.serviceModel>
- 已编辑 lanzhoulei2012 2012年7月22日 10:38
