1

我正在尝试为即时消息传递一些协议，所以我使用的是 Socket 类。当 Socket 从服务器接收到任何数据包时，我试图触发一个事件，通知我的其他类有一些数据可以使用。但是当我尝试从事件处理程序的方法中调用方法时，我收到一个错误：“.NET Compact Framework 不支持异步调用委托”

这是我正在使用的一些代码。我在发生异常的行上留下了评论。

public class ClientSocket3
{
    Socket _socket;

    private const int ConnectionTimeout = 5000;
    private static ManualResetEvent connectedDone = new ManualResetEvent(false);

    public OnReceiveHandler3 OnReceive
    {
        get;
        set;
    }

    public void Connect(IPEndPoint endPointAddress)
    {
        _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        SocketAsyncEventArgs args = new SocketAsyncEventArgs();
        args.Completed += new EventHandler<SocketAsyncEventArgs>(args_Completed);
        args.RemoteEndPoint = endPointAddress;
        args.UserToken = _socket;

        _socket.ConnectAsync(args);

        if (connectedDone.WaitOne(ConnectionTimeout))
        {

        }            
    }

    void args_Completed(object sender, SocketAsyncEventArgs e)
    {
        if (e.LastOperation == SocketAsyncOperation.Connect)
        {
            connectedDone.Set();

            Debug.WriteLine("Connected");
        }
        else if (e.LastOperation == SocketAsyncOperation.Receive)
        {
            if (OnReceive != null)
            {
                OnReceive(this, null);
            }
        }
        else if (e.LastOperation == SocketAsyncOperation.Send)
        {
            Debug.WriteLine("Sent... Waiting for answer");

            _socket.ReceiveAsync(e);
        }
    }

    public void Send(byte[] data)
    {
        SocketAsyncEventArgs sendArgs = new SocketAsyncEventArgs();
        sendArgs.Completed += new EventHandler<SocketAsyncEventArgs>(args_Completed);
        sendArgs.SetBuffer(data, 0, data.Length);

        _socket.SendAsync(sendArgs);
    }

    public void Close()
    {
        _socket.Close();
    }
}

public delegate void OnReceiveHandler3(object sender, byte[] receivedData);

 class XYZ
    {
            private ClientSocket3 client;

            public void Connect(IPEndPoint ipep)
            {

                try
                {
                    client = new ClientSocket3();
                    client.Connect(ipep);
                    client.OnReceive += new OnReceiveHandler3(testReceived);

                }
                catch (SocketException se)
                {
                    // todo
                }
                catch
                {
                    throw;
                }
            }

            private void Send(byte[] data)
            {
                    _client.Send(data);
            }

            private void testReceived(object sender, byte[] e)
            {
                    RecvData(e); **// here exception is thrown: Exception: .NET Compact Framework does not support invoking delegates asynchronously**
            }

            private void RecvData(byte[] data) 
            { 
                //....
            }
    }

从 XYZ 类调用 Send() 方法后立即引发异常。当然，在发送任何内容之前，我会调用 Connect 方法，以便连接到服务器。

我尝试使用 ThreadPool.QueueUserWorkItem() 和 System.Windows.Deployment.Current.Dispatcher.BeginInvoke() 但没有运气 - 也许我以错误的方式使用它们。

任何想法如何解决这个问题？提前致谢。

更新；

异常 - 堆栈：

   at Test.IM.XYZ.testReceived(Object sender, Byte[] e)
   at Test.Net.ClientSocket3.args_Completed(Object sender, SocketAsyncEventArgs e)
   at System.Net.Sockets.SocketAsyncEventArgs.OnCompleted(SocketAsyncEventArgs e)
   at System.Net.Sockets.SocketAsyncEventArgs.OnCompletedInternal(SocketAsyncEventArgs e)
   at System.Net.Sockets.SocketAsyncEventArgs.FinishOperationSuccess(SocketError socketError, Int32 bytesTransferred, SocketFlags flags)
   at System.Net.Sockets.Socket.AsyncCallback(IAsyncResult ar)
   at System.Net.LazyAsyncResult.InvokeCallback(Boolean asyncCompletion)
   at System.Net.Sockets.Socket.SocketAsyncRequestManager.WorkerThread.doWork()
   at System.Net.Sockets.Socket.SocketAsyncRequestManager.WorkerThread.doWorkI(Object o)
   at System.Threading.ThreadPool.WorkItem.WaitCallback_Context(Object state)
   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)

异常类：System.NotSupportedException。

在数据中是 System.Collections.ListDictionaryInternal 但计数为 0

4

1 回答 1

0

我不确定如何解决此特定问题，但出于您的目的，您可能想查看 UdpSingleSourceMulticastClient ，它与 7.1 一样是 lib 的一部分。

见 msdn： http: //msdn.microsoft.com/en-us/library/system.net.sockets.udpsinglesourcemulticastclient (v=vs.95).aspx

祝你好运！

于 2011-09-04T20:30:16.880 回答