java聊天室源代码

/*---------------------------------------------------- * 程序： client.c * 目的： 创建一个套接字，通过网络连接一个服务器，并打印来自服务器的信息 * 语法： client [ host [ port ] ] * host - 运行服务器的计算机的名字 * port - 服务器监听套接字所用协议端口号 * 注意：两个参数都是可选的。如果未指定主机名，客户使用localhost；如果未指定端口号， * 客户将使用PROTOPORT中给定的缺省协议端口号 *---------------------------------------------------- */ #include <sys/types.h> #include <stdio.h> #include <string.h> #include<winsock.h> #include<winsock2.h>  #define PROTOPORT 5188 /*缺省协议端口号*/ void clear() { WORD wVersionRequested;// 应用程序所需的Winsock版本号 WSADATA wsaData;// 用来返回Winsock 实现的细节信息。 int err;// 出错代码。 wVersionRequested = MAKEWORD(1, 1);// 生成版本号1.1。 err = WSAStartup(wVersionRequested, &wsaData); // 调用初始化函数。 if (err != 0) { return; } //通知用户找不到合适的DLL文件。 // 确认返回的版本号是客户要求的1.1 if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { WSACleanup(); return; } /* 至此，可以确认初始化成功，Winsock.DLL可用。*/ } DWORD WINAPI fasong(LPVOID clientfd) { char buf[1000]; gets(buf); if (strcmp(buf, "close")) { printf("\t\t\t\t\tclient recv:\n"); printf("\t\t\t\t\t%s\n", buf); send(clientfd, buf, 1000, 0); /* 向客户端发送信息 */ } else { send(clientfd, buf, 1000, 0); /* 向客户端发送信息 */ exit(0); } } DWORD WINAPI jieshou(LPVOID clientfd) { char buf[1000]; recv(clientfd, buf, sizeof(buf), 0); if (strcmp(buf, "close")) { printf("sever:\n"); printf("%s\n", buf); } else { exit(0); } } extern int errno; char localhost[20] = "localhost"; /*缺省主机名*/ main(argc, argv) int argc; char *argv[]; { struct hostent *ptrh; /* 指向主机列表中一个条目的指针 */ struct sockaddr_in servaddr; /* 存放服务器端网络地址的结构 */ int sockfd; /* 客户端的套接字描述符 */ int port; /* 服务器端套接字协议端口号*/ char* host; /* 服务器主机名指针 */ int n; /* 读取的字符数 */ char buf[1000]; /* 缓冲区，接收服务器发来的数据 */ clear(); memset((char*)& servaddr, 0, sizeof(servaddr)); /* 清空sockaddr结构 */ servaddr.sin_family = AF_INET; /* 设置为因特网协议族 */ //printf("%d\n",sizeof(buf)); /* 检查命令行参数，如果有，就抽取端口号。否则使用内定的缺省值*/ if (argc>2) { port = atoi(argv[2]); /* 如果指定了协议端口，就转换成整数 */ } else { port = PROTOPORT; /* 否则，使用缺省端口号 */ } if (port>0) /* 如果端口号是合法的数值，就将它装入网络地址结构 */ servaddr.sin_port = htons((u_short)port); else { /* 否则，打印错误信息并退出*/ fprintf(stderr, "bad port number %s\n", argv[2]); exit(1); } /* 检查主机参数并指定主机名 */ if (argc>1) { host = argv[1]; /* 如果指定了主机名参数，就使用它 */ } else { host = localhost; /* 否则，使用缺省值 */ } printf("please input host:\n"); gets(host); /* 将主机名转换成相应的IP地址并复制到servaddr 结构中 */ ptrh = gethostbyname(host); /* 从服务器主机名得到相应的IP地址 */ if ((char *)ptrh == NULL) { /* 检查主机名的有效性，无效则退出 */ fprintf(stderr, "invalid host: %s\n", host); exit(1); } memcpy(&servaddr.sin_addr, ptrh->h_addr, ptrh->h_length); /* 创建一个套接字*/ sockfd = socket(AF_INET, SOCK_STREAM, 0); printf("%d\n", sockfd); if (sockfd < 0) { fprintf(stderr, "socket creation failed\n"); exit(1); } printf("connect start\n"); /* 请求连接到服务器 */ if (connect(sockfd, (struct sockaddr *)& servaddr, sizeof(servaddr)) < 0) { fprintf(stderr, "connect failed\n"); /* 连接请求被拒绝，报错并退出 */ getchar(); exit(1); } /* 从套接字反复读数据，并输出到用户屏幕上 */ recv(sockfd, buf, sizeof(buf), 0); printf("%s\n", buf); while (1) { HANDLE hthread1 = CreateThread(NULL, 0, fasong, (LPVOID)sockfd, 0, NULL); CloseHandle(hthread1); HANDLE hthread2 = CreateThread(NULL, 0, jieshou, (LPVOID)sockfd, 0, NULL); CloseHandle(hthread2); } /* 关闭套接字*/ closesocket(sockfd); getchar(); /* 终止客户程序*/ exit(0); }