【发布时间】:2014-01-08 13:25:06
【问题描述】:
我有一个 WCF 服务,它在常规客户端->服务器调用方面工作得非常好。然而,我试图在服务中引入一个简单的回调,但它不起作用......最终我不确定我哪里出错了,所以让我告诉你设置并告诉你我所知道的。
1) 合同
public interface IPIRSCallbackService
{
[OperationContract]
void OnCallback();
}
[ServiceContract(CallbackContract = typeof(IPIRSCallbackService))]
public interface IPIRSService
{ etc...
2) 服务器合约实现
注意:我检查了回调通道的状态,它是“打开的”——虽然不知道这值多少钱。
[ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Reentrant)]
class PIRSService : IPIRSService
{
public PIRSService()
{
callback = OperationContext.Current.GetCallbackChannel<IPIRSCallbackService>();
var x = ((ICommunicationObject)callback).State;
callback.OnCallback(); // HANGS HERE
}
etc.
3) 客户端——创建代理
现在,这可能不是您会看到的常见方式,因为我正在使用 ViewModelLocator 将服务注入到我的视图模型中......但我确信这不会导致问题......并注意正常服务调用工作得很好。
ViewModelLocator 注册服务实例
SimpleIoc.Default.Register<PIRSService>(() =>
{
IPIRSCallbackService callback = new PIRSCallbackService();
InstanceContext context = new InstanceContext(callback);
return new PIRSService(context, "PIRSClient");
}, true);
SimpleIoc.Default.Register<IPIRSService>(() =>
{
return SimpleIoc.Default.GetInstance<PIRSService>();
}, true);
4) 连接到服务
DuplexChannelFactory<IPIRSService> channelFactory = new DuplexChannelFactory<IPIRSService>(callbackContext, endpointConfigName);
channelFactory.Credentials.UserName.UserName = userName;
channelFactory.Credentials.UserName.Password = password;
proxy = channelFactory.CreateChannel();
((IClientChannel)proxy).Open();
5) 客户端 - 端点配置
<endpoint address="net.tcp://localhost:20437/PIRSService" binding="netTcpBinding"
bindingConfiguration="StandardNetTcpBinding" contract="PIRS_Common.Service.IPIRSService"
name="PIRSClient" kind="" endpointConfiguration="" behaviorConfiguration="CustomBehavior">
<identity>
<dns value="WCfServer" />
</identity>
</endpoint>
所以,我不知道为什么回调合约的客户端实现没有被触发......因此服务器端对回调方法的调用挂起......因为它正在等待回调完成。我确定这是回调未正确注册的问题......但我不确定我做错了什么。我是否需要在客户端端点或其他任何地方注册回调合同?
【问题讨论】: