使用socket进行通信代码,C代码库,德仔网

代码语言
代码分类
【C】使用socket进行通信
作者:写给巧克力的歌 / 发布于2015/7/9/ 1136
s.cpp为服务器端程序，c.cpp为客户端程序。源.cpp运行时调用前面两个cpp。

	#include<stdio.h>
	#include"InitSock.h"
	#include <iostream>
	
	using namespace std;
	int main(int argc, char* argv[])
	{ int a = 0;int i = 0;int n = 0;
	
	
	 for(i=0;i<3;i++)
	 {
	 cout<<"start\n1:serve 2:client\n"<<endl;
	 cout<<"please input:"<<endl;
	 scanf_s("%d",&a);
	
	 if(a == 1){
	 cout<<"send message please choose:1 send file please choose:2"<<endl;
	 main_s();
	
	
	
	 }
	 else if(a == 2){
	 main_c();
	 }
	 }
	
	 return 0;
	
	}

	

	

	

	//#include "InitSock.h"
	#include <stdio.h>
	#include <iostream>
	#include <windows.h>
	using namespace std;
	
	SOCKET sClient;
	//void tprocess4(void* args)
	DWORD WINAPI tprocess4(LPVOID lpParam)
	{
	 while(TRUE)
	 {
	 char buff[256] ;
	 int nRecv = ::recv(sClient, buff, 256, 0);
	 if(nRecv > 0)
	 {
	 buff[nRecv] = '\0';
	 printf(" 接收到数据：%s\n", buff);
	 }
	 }
	}
	int main_s()
	{
	 // 创建套节字
	 DWORD dwThread;
	 SOCKET sListen = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	 //用来指定套接字使用的地址格式，通常使用AF_INET
	 //指定套接字的类型，若是SOCK_DGRAM，则用的是udp不可靠传输
	 //配合type参数使用，指定使用的协议类型（当指定套接字类型后，可以设置为0，因为默认为UDP或TCP）
	 if(sListen == INVALID_SOCKET)
	 {
	 printf("Failed socket() \n");
	 return 0;
	 }
	
	 // 填充sockaddr_in结构 ,是个结构体
	 /* struct sockaddr_in {
	
	 short sin_family; //地址族（指定地址格式） ，设为AF_INET
	 u_short sin_port; //端口号
	 struct in_addr sin_addr; //IP地址
	 char sin_zero[8]; //空子节，设为空
	 } */
	
	 sockaddr_in sin;
	 sin.sin_family = AF_INET;
	 sin.sin_port = htons(4567); //1024 ~ 49151：普通用户注册的端口号
	 sin.sin_addr.S_un.S_addr = INADDR_ANY;
	
	 // 绑定这个套节字到一个本地地址
	 if(::bind(sListen, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR)
	 {
	 printf("Failed bind() \n");
	 return 0;
	 }
	
	 // 进入监听模式
	 //2指的是，监听队列中允许保持的尚未处理的最大连接数
	
	 if(::listen(sListen, 2) == SOCKET_ERROR)
	 {
	 printf("Failed listen() \n");
	 return 0;
	 }
	
	 // 循环接受客户的连接请求
	 sockaddr_in remoteAddr;
	 int nAddrLen = sizeof(remoteAddr);
	
	 //SOCKET sClient = 0;
	 char szText[] = " TCP Server Demo! \r\n";
	 while(sClient==0)
	 {
	 // 接受一个新连接
	 //（(SOCKADDR*)&remoteAddr）一个指向sockaddr_in结构的指针，用于获取对方地址
	 sClient = ::accept(sListen, (SOCKADDR*)&remoteAddr, &nAddrLen);
	 if(sClient == INVALID_SOCKET)
	 {
	 printf("Failed accept()");
	 }
	
	
	 printf("接受到一个连接：%s \r\n", inet_ntoa(remoteAddr.sin_addr));
	 continue ;
	 }
	 CreateThread(NULL,0,tprocess4,NULL,0,&dwThread);
	 while(TRUE)
	 { //cout<<"send message please choose:1 send file please choose:2"<<endl;
	 // 向客户端发送数据
	 gets_s(szText) ;
	 ::send(sClient, szText, strlen(szText), 0);
	
	 // 从客户端接收数据
	 /*char buff[256] ;
	 int nRecv = ::recv(sClient, buff, 256, 0);
	 if(nRecv > 0)
	 {
	 buff[nRecv] = '\0';
	 printf(" 接收到数据：%s\n", buff);
	 } */
	
	 }
	
	 //pthread_create(&t1,NULL,tprocess4,NULL);
	 //CreateThread(,a)
	 /*while(TRUE)
	 {
	 char buff[256] ;
	 int nRecv = ::recv(sClient, buff, 256, 0);
	 if(nRecv > 0)
	 {
	 buff[nRecv] = '\0';
	 printf(" 接收到数据：%s\n", buff);
	 }
	 }*/
	
	 // 关闭同客户端的连接
	 ::closesocket(sClient);
	
	 // 关闭监听套节字
	 ::closesocket(sListen);
	
	 return 0;
	}

	

	

	

	

	?//#include "InitSock.h"
	#include <stdio.h>
	#include <iostream>
	#include <windows.h>
	using namespace std;
	
	char szText[256];
	SOCKET s;
	DWORD WINAPI tprocess3(LPVOID lpParam)
	{
	 while(TRUE)
	 {
	 gets_s(szText) ;
	 //szText[255] = '\0';
	 ::send(s, szText, strlen(szText), 0) ;
	 }
	}
	int main_c()
	{
	 DWORD dwThread;
	 // 创建套节字
	 s = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	 if(s == INVALID_SOCKET)
	 {
	 printf(" Failed socket() \n");
	 return 0;
	 }
	
	 // 也可以在这里调用bind函数绑定一个本地地址
	 // 否则系统将会自动安排
	
	 // 填写远程地址信息
	 sockaddr_in servAddr;
	 servAddr.sin_family = AF_INET;
	 servAddr.sin_port = htons(4567);
	 // 注意，这里要填写服务器程序（TCPServer程序）所在机器的IP地址
	 // 如果你的计算机没有联网，直接使用127.0.0.1即可
	 servAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
	
	 if(::connect(s, (sockaddr*)&servAddr, sizeof(servAddr)) == -1)
	 {
	 printf(" Failed connect() \n");
	 return 0;
	 }
	
	 char buff[256];
	 //char szText[256] ;
	 CreateThread(NULL,0,tprocess3,NULL,0,&dwThread);
	 while(TRUE)
	 {
	 //从服务器端接收数据
	 int nRecv = ::recv(s, buff, 256, 0);
	 if(nRecv > 0)
	 {
	 buff[nRecv] = '\0';
	 printf("接收到数据：%s\n", buff);
	 }
	
	 // 向服务器端发送数据
	
	 /* gets(szText) ;
	 szText[255] = '\0';
	 ::send(s, szText, strlen(szText), 0) ; */
	
	 }
	
	 /*while(TRUE)
	 {
	 gets(szText) ;
	 szText[255] = '\0';
	 ::send(s, szText, strlen(szText), 0) ;
	 }*/
	 // 关闭套节字
	 ::closesocket(s);
	 return 0;
	}

	

	

	#include <winsock2.h>
	#include <stdlib.h>
	#include <conio.h>
	#include <stdio.h>
	int main_c();
	int main_s();
	
	#pragma comment(lib, "WS2_32") // 链接到WS2_32.lib
	#ifdef _InitSock
	#endif
	
	class CInitSock
	{
	public:
	 CInitSock(BYTE minorVer = 2, BYTE majorVer = 2)
	 {
	 // 初始化WS2_32.dll
	 WSADATA wsaData;
	 WORD sockVersion = MAKEWORD(minorVer, majorVer);
	 if(::WSAStartup(sockVersion, &wsaData) != 0)
	 {
	 exit(0);
	 }
	 }
	 ~CInitSock()
	 {
	 ::WSACleanup();
	 }
	};
	CInitSock initSock; // 初始化Winsock库
试试其它关键字
　socket　　通信　
同语言下
可能有用的
写给巧克力的歌贡献的其它代码(2)