Question

C语言socket编程怎么实现2个客户端之间通信

网上找了些，没看到什么具体答案
求高人指点
我知道是需要服务器转发的。比如client A,B server C
A想要和B通信，先将数据发送到C，C接受到后怎么转发给B呢，该数据包中应该是自定义协议，里面有

类似可以确定B的信息吧，比如说B的ip地址，这样可以通过ip地址将信息转发给B

但是不知道这样对不对，另外我也不知道这怎么实现

Answer 1

1. 网络的Socket数据传输是一种特殊的I/O，Socket也是一种文件描述符。Socket也具有一个类似于打开文件的函数调用Socket()，该函数返回一个整型的Socket描述符，随后的连接建立、数据传输等操作都是通过该Socket实现的。

2. 下面用Socket实现一个windows下的c语言socket()通信例子，这里我们客户端传递一个字符串，服务器端进行接收。

   【服务器端】
   #include "stdafx.h"
   #include <stdio.h>
   #include <winsock2.h>
   #include <winsock2.h>
   #define SERVER_PORT 5208 //侦听端口
   void main()
   {
       WORD wVersionRequested;
       WSADATA wsaData;
       int ret, nLeft, length;
       SOCKET sListen, sServer; //侦听套接字，连接套接字
       struct sockaddr_in saServer, saClient; //地址信息   
       char *ptr;//用于遍历信息的指针   
       //WinSock初始化
       wVersionRequested=MAKEWORD(2, 2); //希望使用的WinSock DLL 的版本
       ret=WSAStartup(wVersionRequested, &wsaData);
       if(ret!=0)
       {
           printf("WSAStartup() failed!\n");
           return;
       }
       //创建Socket,使用TCP协议
       sListen=socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
       if (sListen == INVALID_SOCKET)
       {
           WSACleanup();
           printf("socket() faild!\n");
           return;
       }
       //构建本地地址信息
       saServer.sin_family = AF_INET; //地址家族
       saServer.sin_port = htons(SERVER_PORT); //注意转化为网络字节序
       saServer.sin_addr.S_un.S_addr = htonl(INADDR_ANY); //使用INADDR_ANY 指示任意地址
    
       //绑定
       ret = bind(sListen, (struct sockaddr *)&saServer, sizeof(saServer));
       if (ret == SOCKET_ERROR)
       {
           printf("bind() faild! code:%d\n", WSAGetLastError());
           closesocket(sListen); //关闭套接字
           WSACleanup();
           return;
       }
    
       //侦听连接请求
       ret = listen(sListen, 5);
       if (ret == SOCKET_ERROR)
       {
           printf("listen() faild! code:%d\n", WSAGetLastError());
           closesocket(sListen); //关闭套接字
           return;
       }
    
       printf("Waiting for client connecting!\n");
       printf("Tips: Ctrl+c to quit!\n");
       //阻塞等待接受客户端连接
    while(1)//循环监听客户端，永远不停止，所以，在本项目中，我们没有心跳包。
    {
     length = sizeof(saClient);
     sServer = accept(sListen, (struct sockaddr *)&saClient, &length);
     if (sServer == INVALID_SOCKET)
     {
      printf("accept() faild! code:%d\n", WSAGetLastError());
      closesocket(sListen); //关闭套接字
      WSACleanup();
      return;
     }       
     char receiveMessage[5000];
      nLeft = sizeof(receiveMessage);
     ptr = (char *)&receiveMessage;
     while(nLeft>0)
     {
      //接收数据
      ret = recv()(sServer, ptr, 5000, 0);
      if (ret == SOCKET_ERROR)
      {
       printf("recv() failed!\n");
       return;
      }
      if (ret == 0) //客户端已经关闭连接
      {
       printf("Client has closed the connection\n");
       break;
      }
      nLeft -= ret;
      ptr += ret;
     }  
       printf("receive message:%s\n", receiveMessage);//打印我们接收到的消息。
    
    }
     //  closesocket(sListen);
     //  closesocket(sServer);
     //  WSACleanup();
   }
   【客户端】
   #include "stdafx.h"
   #include <stdio.h>
   #include <stdlib.h>
   #include <winsock2.h>
   #define SERVER_PORT 5208 //侦听端口
   void main()
   {
      WORD wVersionRequested;
      WSADATA wsaData;
      int ret;
      SOCKET sClient; //连接套接字
      struct sockaddr_in saServer; //地址信息
      char *ptr;
      BOOL fSuccess = TRUE;
      //WinSock初始化
      wVersionRequested = MAKEWORD(2, 2); //希望使用的WinSock DLL的版本
      ret = WSAStartup(wVersionRequested, &wsaData);
      if(ret!=0)
      {
           printf("WSAStartup() failed!\n");
           return;
      }
      //确认WinSock DLL支持版本2.2
      if(LOBYTE(wsaData.wVersion)!=2 || HIBYTE(wsaData.wVersion)!=2)
      {
           WSACleanup();
           printf("Invalid WinSock version!\n");
           return;
      }
      //创建Socket,使用TCP协议
      sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
      if (sClient == INVALID_SOCKET)
      {
           WSACleanup();
           printf("socket() failed!\n");
           return;
      }
      //构建服务器地址信息
      saServer.sin_family = AF_INET; //地址家族
      saServer.sin_port = htons(SERVER_PORT); //注意转化为网络节序
      saServer.sin_addr.S_un.S_addr = inet_addr("192.168.1.127");
      //连接服务器
      ret = connect(sClient, (struct sockaddr *)&saServer, sizeof(saServer));
      if (ret == SOCKET_ERROR)
      {
           printf("connect() failed!\n");
           closesocket(sClient); //关闭套接字
           WSACleanup();
           return;
      }
    
    
      char sendMessage[]="hello this is client message!";
      ret = send (sClient, (char *)&sendMessage, sizeof(sendMessage), 0);
      if (ret == SOCKET_ERROR)
      {
           printf("send() failed!\n");
      }
      else
           printf("client info has been sent!");
      closesocket(sClient); //关闭套接字
      WSACleanup();
   }

Answer 2

如果只是两个客户端和一个服务器，可通过服务器转发即可，两个客户端连接到服务器，服务器把从A接收到的发给B，把从B接收到的发给A即可，如果要做成多个客户端的，则要给各个客户端分配ID，服务端好根据各个客户端和消息要转发送给客户端的ID来确定消息发送对象。

追问

说了等于没说，服务器怎么将数据发送给指定的客户端呢

追答

服务端给各个客户端分配一个独立不重复的ID，在客户端登陆时根据认证参数来查找ID。客户端发送消息时要指定客户端的一个独立身份信息，可以是ID，也可以是其他，服务端可通过查询来获取ID以及客户端当前是否连接上等来对客户端发送的消息进行响应或者存储等客户端上线后再转发。

追问

我就是不明白一个write函数怎么做到指定发送的客户端

追答

首先你要明白C/S结构，你把通信当成打电话就行了，作为服务器你就把它当成移动联通电信之类的，拿着手机的就是客户端，当你要给某某打电话时，你先拨号，先是建立和移动联通电信之间的通信链路，然后移动联通电信收到你拨的号码然后再看这个号码在不在服务区，就是看客户端在线否，在线就建立与客户端的连接，给你提示，你说什么，它就把与你之间建立的连接上收到的数据转发给你拨号的那个，你呼叫的对方也是如此了。

追问

你说的这些我都明白啊，就是不知道怎么用write去实现，将一个客户端发来的消息转发给另一个客

户端

追答

char s8Buffer[1024];
int  s32RetVal = 0;
s32RetVal = recv(s32FdToClientA, s8Buffer, sizeof(s8Buffer), 0);
if (s32RetVal > 0)
{
    send(s32FdToClientB, s8Buffer, s32RetVal);
}

上面就是最简单的了，这是从客户端A接收数据，然后发送给客户端B，只是一个示意的代码片断，要功能更强大，就得自己去完善。

追问

s32FdToClientA 和s32FdToClientB 这两个是服务器从监听队列中accept的socket吧？

是要把这些个接收到的socket放入链表或者数组中？

追答

就是accept的socket连接，要怎么存放按照你自己的需求来设计处理了。

追问

老兄辛苦了，非常感谢

Answer 3

11111111111111111111