多个线程写入同一个套接字导致问题

Question

我编写了一个客户端/服务器应用程序，其中服务器根据来自客户端的请求生成多个线程。

这些线程应该向客户端（字符串）发送一些数据。

问题是，数据在客户端被覆盖。我该如何解决这个问题？

我已经阅读了一些关于类似问题的其他主题，但无法找到确切的解决方案。

这是我接收数据的客户端代码。

while(1)
    {
            char buff[MAX_BUFF];
            int bytes_read = read(sd,buff,MAX_BUFF);
            if(bytes_read == 0)
            {
                    break;
            }
            else if(bytes_read > 0)
            {
                    if(buff[bytes_read-1]=='$')
                    {
                            buff[bytes_read-1]='\0';
                            cout<<buff;
                    }
                    else
                    {
                            cout<<buff;
                    }
            }
    }

服务器线程代码：

void send_data(int sd,char *data)
{
    write(sd,data,strlen(data));
    cout<<data;
}

void *calcWordCount(void *arg)
{
    tdata *tmp = (tdata *)arg;
    string line = tmp->line;
    string s = tmp->arg;
    int sd = tmp->sd_c;
    int line_no = tmp->line_no;
    int startpos = 0;
    int finds = 0;
    while ((startpos = line.find(s, startpos)) != std::string::npos)
    {
            ++finds;
            startpos+=1;
            pthread_mutex_lock(&myMux);
            tcount++;
            pthread_mutex_unlock(&myMux);
    }
    pthread_mutex_lock(&mapMux);
    int t=wcount[s];
    wcount[s]=t+finds;
    pthread_mutex_unlock(&mapMux);


    char buff[MAX_BUFF];
    sprintf(buff,"%s",s.c_str());
    sprintf(buff+strlen(buff),"%s"," occured ");
    sprintf(buff+strlen(buff),"%d",finds);
    sprintf(buff+strlen(buff),"%s"," times on line ");
    sprintf(buff+strlen(buff),"%d",line_no);
    sprintf(buff+strlen(buff),"\n",strlen("\n"));
    send_data(sd,buff);
    delete (tdata*)arg;
}

Answer 1

你应该在你的套接字上放一些互斥锁。

当线程使用套接字时，它应该阻塞套接字。

一些mutex 的例子。

如果没有服务器代码，我无法为您提供更多帮助。因为问题很可能出在服务器上。

Answer 2

1. 在服务器端确保共享资源（套接字及其关联的内部缓冲区）受到保护，防止并发访问。
2. 定义并实现服务器使用的应用程序级协议，使客户端能够区分不同线程发送的内容。

另外说明： 不能依赖read()/write() 读取/写入与这两个函数被告知读取/写入一样多的字节。检查它们的返回值以了解这些函数实际读/写了多少字节并围绕它们循环直到所有打算读/写的数据都被读/写是必不可少的。