寻求WCF双工"TwoWay"订阅+回调示例

[ServiceContract]
public interface IMyService
{
    [OperationContract(IsOneWay = true)]
    void Subscribe();

    [OperationContract(IsOneWay = true)]
    void Callback(string message);
}

public class MyService : IMyService
{
    private List<IMyServiceCallback> subscribers = new List<IMyServiceCallback>();

    public void Subscribe()
    {
        IMyServiceCallback callback = OperationContext.Current.GetCallbackChannel<IMyServiceCallback>();
        if (!subscribers.Contains(callback))
        {
            subscribers.Add(callback);
        }
    }

    public void Callback(string message)
    {
        foreach (var subscriber in subscribers)
        {
            subscriber.OnCallback(message);
        }
    }
}

public interface IMyServiceCallback
{
    [OperationContract(IsOneWay = true)]
    void OnCallback(string message);
}

public class MyServiceCallback : IMyServiceCallback
{
    public void OnCallback(string message)
    {
        Console.WriteLine("Received callback: " + message);
    }
}

InstanceContext instanceContext = new InstanceContext(new MyServiceCallback());
MyServiceClient client = new MyServiceClient(instanceContext);
client.Subscribe();

foreach (var subscriber in subscribers)
{
    subscriber.OnCallback("Hello from server!");
}