0

wp7（クライアント）とWPF（サーバー）でソケットベースのアプリケーションを開発しようとしていますが、理解できない問題があります。

クライアントとの接続と文字列の受信を処理する「Server」クラスを作成しました。

問題は、サーバーがクライアントから送信された最初の文字列だけを受信し、次に接続が切断されていることです。クライアントアプリ（クライアントのみ）をリセットする必要があります。非同期呼び出しを使用してサーバーアプリケーションを書き換えているため、サーバー側の問題だと思います。そのクライアントがうまく機能する前に。私のサーバー側コード：

public class StateObject
    {
        public byte[] Buffer { get; set; }
        public Socket WorkSocket { get; set; }
    }

    public class MessageRecievedEventArgs : EventArgs
    {
        public string Message { get; set; }
    }

    public class Server
    {
        ManualResetEvent _done;
        TcpListener _listener;

        public event EventHandler<MessageRecievedEventArgs> OnMessageRecieved;
        public Server()
        {
            _done = new ManualResetEvent(false);
            _listener = new TcpListener(IPAddress.Any, 4124);
        }

        public void Start()
        {
            Thread th = new Thread(StartListening);
            th.IsBackground = true;
            th.Start();
        }

        private void StartListening()
        {
            _listener.Start();
            while (true)
            {
                _done.Reset();
                _listener.BeginAcceptTcpClient(new AsyncCallback(OnConnected), _listener);
                _done.WaitOne();
            }

        }
        private void OnConnected(IAsyncResult result)
        {
            TcpListener listener = result.AsyncState as TcpListener;
            Socket socket = listener.EndAcceptSocket(result);
            byte[] buffer = new byte[256];
            StateObject state = new StateObject { Buffer = buffer, WorkSocket = socket };
            socket.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, new AsyncCallback(OnRead), state);
        }

        private void OnRead(IAsyncResult result)
        {
            var state = (StateObject)result.AsyncState;
            int buffNum = state.WorkSocket.EndReceive(result);
            string message = Encoding.UTF8.GetString(state.Buffer, 0, buffNum);
            if (OnMessageRecieved != null)
            {
                MessageRecievedEventArgs args = new MessageRecievedEventArgs();
                args.Message = message;
                OnMessageRecieved(this, args);
            }
            _done.Set();
        }
    }

クライアント：

protected override void OnNavigatedTo(System.Windows.Navigation.NavigationEventArgs e)
        {
            try
            {
                base.OnNavigatedTo(e);
                _socketEventArgs = new SocketAsyncEventArgs() { RemoteEndPoint = App.Connection.RemoteEndPoint };
                Send("{ECHO}");
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }

        }
        private void Send(string key)
        {
            var bytes = Encoding.UTF8.GetBytes(key + "$");
            _socketEventArgs.SetBuffer(bytes, 0, bytes.Count());
            if (Socket.Connected)
                Socket.SendAsync(_socketEventArgs);
            else
                MessageBox.Show("Application is not connected. Please reset connection (press 'back' key and 'connect' button). It may be needed to restart server application"); 
        }

「{ECHO}」メッセージはクライアントによって送信され、サーバーによって受信されます。次の各メッセージは送信されますが、受信されません。私はソケット非同期呼び出しメカニズムを理解していないと思います...誰かが私を教えてくれますか？:)

4

1 に答える 1

0

あなたは一度だけ読んでいるようです。おそらく、readを繰り返し呼び出して、ストリーム全体を使い果たす必要があります。

于 2012-09-11T11:25:53.027 に答える