1

所以我只需要几天时间就可以了解 wcf 服务，特别是双工服务，并且我从一个测试应用程序开始。目标是拥有一个服务，该服务具有一个存储变量的内部（静态？）类，以及一个获取这些变量的客户端。

目前，我在 Storage 类中有两个变量，一个是订阅者列表 ( ObservableCollection<IMyContractCallBack>)，另一个是ObservableCollection<string>，其中每个字符串在回调方法中发送到客户端。

我希望能够让客户端Fetch（如果尚未订阅，则首先订阅，通过将其上下文添加到服务器端的集合）服务器端集合中的字符串。该部分按预期工作。但是，我还想将Push一个字符串从服务器发送到订阅列表中的每个客户端，以及将Add字符串发送到字符串集合。这就是我的问题出现的地方。

任何时候我Fetch，它都会添加到字符串列表“test1...”和“test2...”并发送它们，然后客户端更新一个文本块 UI（wpa）所以如果我获取两次，我就会有"test1...","test2...","test1...","test2..."，因为现在没有检查对于重复。这证明集合可以在服务器端从Fetch到更新和记忆Fetch。但是，当我尝试Add或Send给定文本时，所有变量都被遗忘了，因此订阅者列表为空，而要添加的列表为空。然而，当我再Fetch一次时，旧清单又回来了（现在有 6 件事，test1...,test2... etc...）

我上课前有这个

[ServiceBehavior(InstanceContextMode= InstanceContextMode.PerSession, ConcurrencyMode = ConcurrencyMode.Single)]

而且我还尝试了单例上下文模式，但无济于事。更改ConcurrencyMode为 Multiple 也没有任何不同。关于为什么我的静态数据仅在内部命令来自服务器本身时才被重置的任何想法？

这是我的服务的代码：

namespace WcfService3
{   
[ServiceBehavior(InstanceContextMode= InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)]
public class Service1 : IService1
{
    public static event Action NullContext;

    public static ObservableCollection<IMyContractCallBack> Subscriptions;

    public void     NormalFunction()
    {

        //Only sends to Subs that are STILL Open
        foreach (IMyContractCallBack user in Subscriptions)
        {
            //Removes the Closed users, because they are hanging around from last session
            if (((ICommunicationObject)user).State != CommunicationState.Opened)
            {
                Subscriptions.Remove(user);
            }
            else
            {
                ObservableCollection<string> holder = Storage.GetList();

                foreach (string str in holder)
                {
                    user.CallBackFunction(str);
                }
            }
        }
    }
    public static void Send(string str)
    {
        try
        {
            foreach (IMyContractCallBack user in Subscriptions)
            {
                user.CallBackFunction(str);
            }
        }
        catch
        {
            //For some reason 'Subscriptions' is always null
            NullContext.Invoke();
        }
    }
    public static void Add(string str)
    {
        //For some reason 'SendList' is always null here, too
        Storage.AddToList(str);
        if (Subscriptions != null)
        {
            //For same reason 'Subscriptions' is always null
            foreach (IMyContractCallBack user in Subscriptions)
            {
                user.CallBackFunction(str);
            }
        }
    }

    public void Subscribe()
    {
        //Adds the callback client to a list of Subscribers
        IMyContractCallBack callback = OperationContext.Current.GetCallbackChannel<IMyContractCallBack>();
        if (Subscriptions == null)
        {
            Subscriptions = new ObservableCollection<IMyContractCallBack>();
        }
        if(!Subscriptions.Contains(callback))
        {
            Subscriptions.Add(callback);
        }
    }

这是我的Storage课程代码：

namespace WcfService3
{
public static class Storage
{

    public static readonly ObservableCollection<string> SendList = new ObservableCollection<string>();

    public static IMyContractCallBack callback;

    public static ObservableCollection<string> GetList()
    {

        if (SendList.Count == 0)
        {
            AddToList("Test1...");
            AddToList("Test2...");
        }

        return SendList;
    }

    public static void AddToList(string str)
    {


            SendList.Add(str);

    }
}

}

如果需要，我可以提供更多代码。

4

1 回答 1

0

您是否在任何地方使用该ThreadStatic属性？（只是快速搜索）那是一个真正的远射，可能不是你的问题。

你可能有线程问题。您的所有客户端是否同时连接（我的意思是连续连接？）如果是，您将在您的Subscribe方法中遇到此代码的线程问题：

   if (Subscriptions == null)
    {
        Subscriptions = new ObservableCollection<IMyContractCallBack>();
    }

您应该更好地限制对您的Subscriptions方法的访问，以便您可以查看谁修改了它以及何时修改它，并使用控制台语句找出您出错的地方。

于 2012-07-23T14:16:43.980 回答