2

我有一个 WCF 服务，它公开了两个操作 - IncrementList() 和 GetList()。客户端 B 连接到服务，调用 GetList() 并显示给用户。客户端 A 可以通过调用 IncrementList() 来更新此列表。
我希望客户端 B 在调用 IncrementList() 时得到通知，以便它可以再次调用 GetList() 以显示更新的数据。

您能否概述一下您将如何实现这一点？回调？双工？发布者/订阅者？
WCF 4.0 中有什么新东西可以帮助解决这种情况吗？

服务图

谢谢！

4

1 回答 1

5

您应该预先决定的是，您是想在整个列表增加（重）时将整个列表推送给每个客户端，还是只将更新的项目推送给每个客户端。下面的代码用于推送整个列表，但很容易修改它只是为了推送更新的对象（推荐）。
在应用程序启动时，客户端 B 应该调用Register_client然后GetList. 随后，当列表增加时，将通过回调通知（客户端需要隐含此接口）
调用GetList需要双工通道和SessionMode.Required.

您的服务器应该暗示：

[ServiceContract(SessionMode = SessionMode.Required
                 CallbackContract = typeof(IMyCallback))]
    public interface IMyServer {

    [OperationContract]
    void Register_client();

    [OperationContract(IsOneWay = true)]
    void IncrementList();

    [OperationContract]
    ListObject[] GetList();
}  

[DataContract]
public class ListObject {
    [DataMember]...
}

您的客户应该暗示：

public interface IMyCallback {
    [OperationContract(IsOneWay = true)]
    void PushList(ListObject[] list);
}

注册客户端只需要存储客户端回调接口，以便在列表增加时使用，例如：

public override void Register_client() {
    // Store callback interfaces for all connected clients:
    IMyCallback callback = OperationContext.Current.GetCallbackChannel<IGatewayServerCallback>();
    if (clients.Contains(callback) == false)
    clients.Add(callback);
    Trace.WriteLine(string.Format("Client connection established ({0})", clients.Count));
}

在哪里：

private List<IMyCallback> clients = new List<IMyCallback>();

应该IncrementList执行回调以将新列表（或者最好只是添加到列表中的新对象）推送到客户端 - 例如：

for (int i = 0; i < clients.Count; i++) {
    if (((ICommunicationObject)clients[i]).State == CommunicationState.Opened) {
    try {
        clients[i].PushList(list);
    }
    catch (Exception e) {
        clients.RemoveAt(i--);
        Trace.WriteLine(e);
        Trace.WriteLine(string.Format("Removing client {0} (exception).", i + 1));
    }
}

回调实现（客户端）看起来像：

public class MyCallback : IMyCallback {
public void PushList(ListObject[] list) {
    // Were client side - update list code here...
}

可能这个回调实现需要引用一些保存列表数据的对象——可能这被传递给构造函数（未显示）。

当您实例化您的代理对象时，您需要将回调实例传递给代理构造函数 - 例如： 

MyServerClient client_proxy = new MyServerClient(new InstanceContext(my_callback, binding_str)
于 2011-11-03T10:18:03.483 回答