socket服务器端接收不到数据

tan1301230147

客户端代码
void SocketSend(char *IpAddress, int Port, char *Type, char *parameter);

int _tmain(int argc, _TCHAR* argv[])
{
        SocketSend("127.0.0.1", 50, "1", "数据收到否？\n");

        return 0;

}


/******************************************************************************
*        void SocketSend 发送Socket数据
*        参数
*        IpAddress 接收服务器的IP地址
*        Port 端口号双方必须保持一致
*        Type 用于标识消息类型
*        parameter 具体参数
******************************************************************************/
void SocketSend(char *IpAddress, int Port, char *Type, char *parameter)
{
        char *msg[] = {NULL, NULL};
        msg[0] = Type;
        msg[1] = parameter;

        WSADATA wsaData;
        WSAStartup(MAKEWORD(2, 2), &wsaData);

        SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

        //定义结构体
        sockaddr_in sockAddr;
        sockAddr.sin_family = AF_INET;
        sockAddr.sin_addr.S_un.S_addr = inet_addr(IpAddress);
        sockAddr.sin_port = htons(Port);

        //建立连接
        int a= connect(s, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));

        //发送数据
        int b=send(s, *msg, sizeof(*msg), NULL);

        //销毁
        closesocket(s);
        WSACleanup();
}







服务器端代码
void SocketRecv(int Port, char *Type, char *Parameter);

int _tmain(int argc, _TCHAR* argv[])
{
        char *msg[] = {0, 0};
        SocketRecv(50, &*msg[0], &*msg[1]);

        printf_s(msg[0], msg[1]);

        return 0;
}


/******************************************************************************
*        void SocketRecv 接收Socket数据
*        参数
*        Port 端口号双方必须保持一致
*        Type 用于标识消息类型
*        parameter 具体参数
******************************************************************************/
void SocketRecv(int Port, char *Type, char *Parameter)
{
        char *msg[] = {0, 0};

        WSADATA wsaData;
        WSAStartup(MAKEWORD(2, 2), &wsaData);

        SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); //创建TCP套接字

        sockaddr_in sockaddr;
        sockaddr.sin_family = AF_INET;
        sockaddr.sin_addr.S_un.S_addr = INADDR_ANY;
        sockaddr.sin_port = htons(Port);

        bind(s, (SOCKADDR*)&sockaddr, sizeof(SOCKADDR));

        listen(s, 30);

        SOCKADDR ClientAddr;
        int nSize = sizeof(SOCKADDR);
        SOCKET ClientSock;
        ClientSock = accept(s, (SOCKADDR*)&ClientAddr, &nSize);

        char i = NULL;
        recv(s, *msg, sizeof(*msg), NULL);
        Type = msg[0];
        Parameter = msg[1];
         
        closesocket(ClientSock);
        closesocket(s);

        WSACleanup();
}

star_in_sky

char *msg = "";
...................
recv(ClientSock, Parameter, strlen(Parameter), NULL);
strlen(Parameter) 就是0，你给了一个长度为0的缓冲区, 当然收不到数据。

定义：char msg[80] = {'\0'};

Susake_

死循环都没,等服务器结束了,客户端才发来

tan1301230147

回复 2# Susake_


    不会啊 程序会在listen处一直等待

weishuo1999

呃,  char* msg[] = {0, 0};  这种也行?

tan1301230147

回复 4# weishuo1999


    恩 没把这个改变成方法的时候试过可行

star_in_sky

两个错误：

1. 客户端向50端口发送数据，SocketSend("127.0.0.1", 50, "1", "数据收到否？\n");
2. 服务端监听30端口：listen(s, 30);

还有：服务端按照常规流程写（至少在接收数据的地方加个循环）。

tan1301230147

回复 6# star_in_sky


    listen第二个参数是监听缓存设置把 不是设置端口的好不？ 大神 第一个是我自定义的方法名啊哪错了？ 能具体点不？

star_in_sky

回复 7# tan1301230147

抱歉。我搞错了。

有错误的地方是：；
recv(s, *msg, sizeof(*msg), NULL);

应该改为：
recv(ClientSock, *msg, sizeof(*msg), NULL);

s:  监听套接字。
ClientSock: 才是客户端的套接字。

不过在收数据的地方，你最好加个循环。

   

tan1301230147

回复 8# star_in_sky


    重新定义了一下 传过去的数据乱码了
客户端
int _tmain(int argc, _TCHAR* argv[])
{
        SocketSend("127.0.0.1", 80, "数据收到否？\n");

        return 0;

}


/******************************************************************************
*        void SocketSend 发送Socket数据
*        参数
*        IpAddress 接收服务器的IP地址
*        Port 端口号双方必须保持一致
*        Type 用于标识消息类型
*        parameter 具体参数
******************************************************************************/
void SocketSend(char *IpAddress, int Port, char parameter[])
{

        WSADATA wsaData;
        WSAStartup(MAKEWORD(2, 2), &wsaData);

        SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

        //定义结构体
        sockaddr_in sockAddr;
        sockAddr.sin_family = AF_INET;
        sockAddr.sin_addr.S_un.S_addr = inet_addr(IpAddress);
        sockAddr.sin_port = htons(Port);

        //建立连接
        int a= connect(s, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));

        //发送数据
        int b=send(s, parameter, sizeof(parameter), NULL);

        //销毁
        closesocket(s);
        WSACleanup();
}










服务器
int _tmain(int argc, _TCHAR* argv[])
{
        char *msg = "";
        SocketRecv(80, msg);




        return 0;
}


/******************************************************************************
*        void SocketRecv 接收Socket数据
*        参数
*        Port 端口号双方必须保持一致
*        Type 用于标识消息类型
*        parameter 具体参数
******************************************************************************/
void SocketRecv(int Port, char Parameter[])
{

        WSADATA wsaData;
        WSAStartup(MAKEWORD(2, 2), &wsaData);

        SOCKET s = socket(AF_INET, SOCK_STREAM, 0); //创建TCP套接字

        sockaddr_in sockaddr;
        sockaddr.sin_family = AF_INET;
        sockaddr.sin_addr.S_un.S_addr = INADDR_ANY;
        sockaddr.sin_port = htons(Port);

        bind(s, (SOCKADDR*)&sockaddr, sizeof(SOCKADDR));

        listen(s, 30);

        while(true)
        {
                SOCKADDR ClientAddr;
                int nSize = sizeof(SOCKADDR);
                SOCKET ClientSock;
                ClientSock = accept(s, (SOCKADDR*)&ClientAddr, &nSize);

                char i = NULL;
                recv(ClientSock, Parameter, sizeof(Parameter), NULL);
         
                closesocket(ClientSock);
                closesocket(s);

                WSACleanup();

        }


}