#pragma comment(lib,"Ws2_32.lib")
#include <stdio.h>
#include <Winsock2.h>
SOCKET sockClient;
//设置接收数据和发送数据的缓存数组
char recvBuf[];
char sendBuf[];
SOCKADDR_IN addrClient;
DWORD WINAPI funB(LPVOID lp); void main(){
//要求使用的版本
WORD wVersionRequested;
//
WSADATA wsaData;
int err; wVersionRequested = MAKEWORD(,);
//初始化WinSock dll库 WSAStartup 函数返回0表示初始化成功
err = WSAStartup(wVersionRequested,&wsaData);
//测试版本获取结果
//printf("%d\n",err);
if(err!=){
printf("WinSock初始化失败\n");
return; } if(LOBYTE(wsaData.wVersion)!=||HIBYTE(wsaData.wVersion)!=){
WSACleanup();
return;
}
printf("......客户端程序已启动......\n");
char addr[];
int port;
printf("请输入服务器的IP地址:");
scanf("%s",addr);
printf("请输入服务器的端口号:");
scanf("%d",&port);
//创建Socket套接字
sockClient = socket(AF_INET,SOCK_STREAM,); //通讯的IP地址
addrClient.sin_addr.S_un.S_addr=inet_addr(addr);
//使用IP地址族
addrClient.sin_family=AF_INET;
//通讯的端口号
addrClient.sin_port=htons(port); connect(sockClient,(SOCKADDR*)&addrClient,sizeof(SOCKADDR)); strcpy(recvBuf,"");
//从服务器中获得IP地址 并向服务器发送建立连接的消息
recv(sockClient,recvBuf,,);
send(sockClient,"已经建立通讯连接",strlen("已经建立通讯连接")+,); if( strlen(recvBuf)==){
printf("警告:服务器未启动,请先启动服务器!!!\n");
//system("pause");
exit();
}else{
printf("服务器信息:%s\n",recvBuf);
} HANDLE a;
DWORD dwT;
//参数1:使用默认的安全性;参数2:与调用线程一样的栈大小;
//参数3:线程入口函数地址;参数4:传递给线程的参数;参数5:线程创建标记;参数6:新线程的ID
a=CreateThread(NULL,,funB,,,&dwT);
//循环接收和发送消息
//关闭新线程的句柄
CloseHandle(a); while(){
//从控制台接收用户输入数据发送到客户端
//printf("客户端说:");
scanf("%s",sendBuf);
send(sockClient,sendBuf,strlen(sendBuf)+,);
} //关闭套接字和连接
closesocket(sockClient);
WSACleanup(); } DWORD WINAPI funB(LPVOID lp)
{
char Message[];
while (TRUE)
{
//从服务器接收数据显示到控制台
if(recv(sockClient,Message,,) != -){
printf("服务器说:%s\n",Message);
}else{
printf("连接已经中断.....请检查服务端是否启动并重试。");
system("pause");
exit();
}
}
return ;
}
05-04 06:07