C# 套接字只是收到第一条消息答案

【问题标题】：C# socket just first message receivedC# 套接字只是收到第一条消息
【发布时间】：2015-03-10 20:36:08
【问题描述】：

我已经搜索了许多示例和教程，但我一生都无法弄清楚我在这里做错了什么......如果我向该服务器发送多条消息，我只在控制台中打印了第一条消息。 Writeline 命令，其余的从不打印...我一定是在做一些根本错误的事情，但我真的找不到它...：S

这是服务器代码：

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms.VisualStyles;

namespace HL7_Manager
{
public class MonitorServer
{
    private int _port;
    private Socket _serverSocket;
    private List<ClientObject> _clients;

    public bool IsConnected { get; set; }
    public MonitorServer(int port)
    {
        _port = port;
        _clients = new List<ClientObject>();
    }

    public void StartListening()
    {
        _serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        Thread listenThread = new Thread(new ThreadStart(ListenerThread));
        listenThread.IsBackground = true;
        listenThread.Start();
    }

    public void StopListening()
    {
        IsConnected = true;
        _serverSocket.Close();
        while (_clients.Count > 0)
        {
            _clients[0].KeepProcessing = false;
            _clients[0].ClientSocket.Close();
            _clients.RemoveAt(0);
        }
    }

    private void ListenerThread()
    {
        _serverSocket.Bind(new IPEndPoint(IPAddress.Any, _port));
        _serverSocket.Listen(100);

        Console.WriteLine("Listening on port 8000");

        while (true)
        {
            Socket clientSocket = _serverSocket.Accept();
            ClientObject client = new ClientObject();
            client.KeepProcessing = true;
            client.ClientSocket = clientSocket;
            _clients.Add(client);
            ParameterizedThreadStart ptStart = new ParameterizedThreadStart(ProcessClientThread);
            Thread processThread = new Thread(ptStart);
            processThread.IsBackground = true;
            processThread.Start(client);
            clientSocket = null;
            client = null;
        }
    }

    private void ProcessClientThread(object clientObj)
    {
        Console.WriteLine("Client connected");
        ClientObject client = (ClientObject) clientObj;
        Socket clientSocket = client.ClientSocket;
        byte[] buffer = new byte[clientSocket.ReceiveBufferSize];
        int receiveCount = 0;

        while (client.KeepProcessing)
        {
            try
            {
                receiveCount = clientSocket.Receive(buffer, 0, buffer.Length, SocketFlags.None);
                Console.WriteLine(Encoding.ASCII.GetString(buffer));
            }
            catch (Exception ex)
            {
                if (!client.KeepProcessing)
                    return;
                Console.WriteLine(ex.Message);
            }
        }
        clientSocket.Close();
        _clients.Remove(client);
    }
}
}

【问题讨论】：

检查您的接收计数，您可能在缓冲区中有一些 0 终止字符。使用 TCP，您可以一次收到所有内容。所以要确保一个一个地打印出每个字符。
一个常见的错误。 Encoding.ASCII.GetString(buffer));你不检查你收到了多少字节（receiveCount）

标签： c# sockets server

【解决方案1】：

这是你绝对应该改变的方法以及如何改变它。

    private void ProcessClientThread(object clientObj)
    {
        Console.WriteLine("Client connected");
        ClientObject client = (ClientObject)clientObj;
        Socket clientSocket = client.ClientSocket;
        byte[] buffer = new byte[clientSocket.ReceiveBufferSize];
        int receiveCount = 0;

        while (client.KeepProcessing)
        {
            try
            {
                receiveCount = clientSocket.Receive(buffer, 0, buffer.Length, SocketFlags.None);
                if (receiveCount == 0)
                    break; //the client has closed the stream
                var ret = Encoding.ASCII.GetString(buffer, 0, receiveCount);
                Console.WriteLine(ret);
            }
            catch (Exception ex)
            {
                if (!client.KeepProcessing)
                    return;
                Console.WriteLine(ex.Message);
            }
        }
        clientSocket.Close();
        _clients.Remove(client);
    }

【讨论】：

【解决方案2】：

检查您真正收到了多少字节。 TCP 是一种流协议，这意味着如果您的客户端一个接一个地发送多个小消息，您将在接收器处一次性接收它们。如果您的接收缓冲区中恰好有一个空字符，您可能会认为您没有收到所有这些字符串，但实际上您确实收到了。通过检查您收到的字节数并检查缓冲区内容来检查这一点。如果你犯了这个错误，你的代码中可能会有一些更深层次的问题。 TCP 是流式传输的事实使其更加复杂

【讨论】：