1

我正在尝试建立一个简单的双工服务，让客户端连接到服务器。任何连接的客户端都可以执行BookAdded服务操作。发生这种情况时，服务器应该在所有连接的客户端上引发回调，以通知它们更改。

回调似乎工作正常，只是回调操作需要在 UI 线程上使用Dispatcher.BeginInvoke.

在我的情况下Console.WriteLine("Callback thread")执行购买Console.WriteLine("Dispatcher thread")没有。这是什么原因？

我的服务合同：

public interface ICallback
{
    [OperationContract(IsOneWay = true)]
    void BookAdded(string bookId);
}

[ServiceContract(
    CallbackContract = typeof(ICallback), 
    SessionMode = SessionMode.Required)]
public interface IService
{
    [OperationContract]
    bool BookAdded(string bookId);
}

我的服务实现：

[ServiceBehavior(
    UseSynchronizationContext = false,
    InstanceContextMode = InstanceContextMode.PerSession, 
    ConcurrencyMode = ConcurrencyMode.Reentrant)]
public class MyService : IService
{
    public bool BookAdded(string bookId)
    {
        try
        {
            Console.WriteLine("Client Added Book " + bookId);

            foreach (ICallback callback in connectedClients)
            {
                callback.BookAdded(bookId);
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
        return true;
    }
}

我的客户端实现：

[CallbackBehavior(UseSynchronizationContext = false, ConcurrencyMode = ConcurrencyMode.Multiple)]
public class MyCallBack: ICallback, IDisposable
{
    private Dispatcher theDispatcher;
    private InstanceContext context;
    private WcfDuplexProxy<IService> proxy;

    [ImportingConstructor]
    public MyCallBack()
    {  
        theDispatcher = Dispatcher.CurrentDispatcher;
        context = new InstanceContext(this);
        proxy = new WcfDuplexProxy<IService>(context);

        proxy.Connect();
    }

    public IService Service
    {
        get
        {
            return proxy.ServiceChannel;
        }
    }

    public void CallServiceOperation()
    {
        Service.BookAdded("BOOK1234");
    }

    public void BookAdded(string bookId)
    {
        Console.WriteLine("Callback thread");
        theDispatcher.BeginInvoke(new Action(() => { Console.WriteLine("Dispatcher thread"); }));
    }

    public void Dispose()
    {
        Service.Disconnect();
        proxy.Close();
    }
4

2 回答 2

3

我怀疑正在发生的事情是 UI 线程仍然被阻塞在对服务器的原始调用尚未完成。 我认为如果您将客户端上的并发模式更改为可重入，它可能会起作用。. 您需要做的是在回调上设置 [CallbackBehavior(UseSynchronizationContext = false)]。

这篇文章很好地解释了这个问题。

GJ

于 2011-04-03T12:59:14.563 回答
0

我想我遇到了与你类似的问题。我用一个新线程来解决它来调用 Dispatcher.beginInvoke。据我了解，UI线程向服务发送请求，服务将在服务操作期间调用在您的客户端中实现的回调合约。因此，如果在回调操作中，它会调用 UI 线程的控制，该线程等待服务操作的响应。这就是客户端死锁的原因。所以你可以试试下面的代码： Thread th=new Thread(new ThreadStart(()=>{Console.WriteLine("Callback thread");
theDispatcher.BeginInvoke(new Action(() => { Console.WriteLine("Dispatcher thread"); }));
})); th.Start();

于 2012-07-20T06:42:34.090 回答