一、TCP機械臂測試
代碼：
#include <myhead.h>
#define SER_IP "192.168.125.254" //服務器端IP
#define SER_PORT 8888 //服務器端端口號#define CLI_IP "192.168.199.131" //客戶端IP
#define CLI_PORT 9999 //客戶端端口號
/**********************TCP客戶端********************/
int main(int argc, const char *argv[])
{//1.創建用于通信的套接字int cfd=-1;if((cfd=socket(AF_INET,SOCK_STREAM,0))==-1){perror("socket error");return -1;}printf("cfd=%d\n",cfd);//2.綁定服務器IP地址和端口號(非必須)//2.1填充地址信息結構體struct sockaddr_in cin;cin.sin_family=AF_INET;cin.sin_port=htons(CLI_PORT);cin.sin_addr.s_addr=inet_addr(CLI_IP);//2.2綁定if(bind(cfd,(struct sockaddr*)&cin,sizeof(cin))==-1){perror("bind error");}printf("bind success\n");//3.連接服務器//3.1填充要連接的服務器的地址信息結構體struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//3.2連接到服務器if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("connect error");return -1;}//4.進行數據的收發操作char rbuf[5]={0xff,0x02,0x00,0x00,0xff}; //紅色機械臂unsigned char bbuf[5]={0xff,0x02,0x01,0x00,0xff}; //藍色機械臂//發送給服務器當做初始值send(cfd,rbuf,sizeof(rbuf),0);sleep(1); //防止沾包send(cfd,bbuf,sizeof(bbuf),0);char key=0; //定義鍵盤輸入的值while(1){scanf("%c",&key); getchar(); //吸收垃圾字符switch(key){case 'W':case 'w':{rbuf[3]+=3; //紅色機械臂每次增加3度if(rbuf[3]>=90){rbuf[3]=90;}send(cfd,rbuf,sizeof(rbuf),0); //將鍵盤控制的結果發送到服務器端}break;case 'S':case 's':{rbuf[3]-=3; //紅色機械臂每次減少3度if(rbuf[3]<=-90){rbuf[3]=-90;}send(cfd,rbuf,sizeof(rbuf),0);}break;case 'D':case 'd':{bbuf[3]+=3; //藍色機械臂每次增加3度if(bbuf[3]>=180){bbuf[3]=180;}send(cfd,bbuf,sizeof(bbuf),0);}break;case 'A':case 'a':{bbuf[3]+=3; //藍色機械臂每次減少3度if(bbuf[3]<=0){bbuf[3]=0;}send(cfd,bbuf,sizeof(bbuf),0);}break;default:printf("error\n");break;}}//5.關閉套接字close(cfd);return 0;
}
效果圖：
二、基于UDP的TFTP文件傳輸
代碼：
#include <myhead.h>
#define SER_IP "192.168.125.254" //服務端IP
#define SER_PORE 69 //TFTP協議使用的端口號//定義下載請求
int download(int cfd,struct sockaddr_in sin)
{//組件協議包:下載請求char pack[516]="";short *p1=(short *)pack;*p1=htons(1); //設置操作碼char file[20]="";printf("請輸入文件名:");fgets(file,sizeof(file),stdin);file[strlen(file)-1]=0; char *p2=(pack+2);strcpy(p2,file); //文件名char *p4=p2+strlen(p2)+1;strcpy(p4,"octet"); //模式位int packlen=4+strlen(p2)+strlen(p4); //請求包大小printf("%d\n",packlen);//向服務器發送請求包sendto(cfd,pack,packlen,0,(struct sockaddr*)&sin,sizeof(sin));//以只寫的形式打開文件int wfd=-1;if((wfd=open(file,O_WRONLY|O_CREAT|O_TRUNC,0664))==-1){perror("open error");return -1;}int res=0;struct sockaddr_in cin;socklen_t socklen=sizeof(cin);while(1){//收取服務器發來的數據包//判斷數據包的操作碼是否為3 以及 數據包數據內容是否為512字節//若為512字節，則讀取后，回復一個應答包，繼續接收下一個//如果小于512，則讀取數據后，回復一個應答包，結束接收數據//清空協議包bzero(pack,sizeof(pack));res=recvfrom(cfd,pack,sizeof(pack),0,(struct sockaddr*)&cin,&socklen); //接收數據包if(*p1==ntohs(3)) //數據包{write(wfd,pack+4,res-4);//回復應答包*p1=htons(4);sendto(cfd,pack,4,0,(struct sockaddr*)&cin,sizeof(cin));if(res-4<512){printf("下載完成\n");break;}}else if(*p1==ntohs(5)) //錯誤包{printf("error\n");return -1;}}close(wfd);return 0;
}//定義上傳函數
int upload(int cfd,struct sockaddr_in sin)
{//組件協議包:上傳請求char pack[516]="";unsigned short *p1=(unsigned short *)pack;*p1=htons(2); //設置操作碼char file[20]="";printf("請輸入文件名:");fgets(file,sizeof(file),stdin);file[strlen(file)-1]=0; char *p2=(pack+2);strcpy(p2,file); //文件名char *p4=p2+strlen(p2)+1;strcpy(p4,"octet"); //模式位int packlen=4+strlen(p2)+strlen(p4); //請求包大小printf("%d\n",packlen);//向服務器發送請求包sendto(cfd,pack,packlen,0,(struct sockaddr*)&sin,sizeof(sin));//以只讀的形式打開文件int rfd=-1;if((rfd=open(file,O_RDONLY,0664))==-1){perror("open error");return -1;}int res=0;struct sockaddr_in cin;socklen_t socklen=sizeof(cin);unsigned short num=0; //定義塊編號;while(1){//清空協議包bzero(pack,sizeof(pack));res=recvfrom(cfd,pack,sizeof(pack),0,(struct sockaddr*)&cin,&socklen);if(*p1==ntohs(4)) //接收應答包{//發送數據包*p1=htons(3);//填充塊編號num++;*(p1+1)=htons(num);//讀取數據res=read(rfd,p1+2,512);sendto(cfd,pack,sizeof(pack),0,(struct sockaddr*)&cin,sizeof(cin));if(res==0){printf("上傳完成\n");break;}else if(res<0){printf("error\n");return -1;}}else if(*p1==ntohs(5)) //錯誤包{printf("error\n");return -1;}}close(rfd);return 0;
}/*******************UDP客戶端********************/
int main(int argc, const char *argv[])
{/*//判斷是否外部傳參if(argc!=2){printf("unknow filename\n");return -1;}*///1.創建用于通信的套接字文件描述符int cfd=-1;if((cfd=socket(AF_INET,SOCK_DGRAM,0))==-1){perror("socket error");return -1;}//2.進行數據的收發//填充服務器的地址信息結構體struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORE);sin.sin_addr.s_addr=inet_addr(SER_IP);//創建小菜單int menu=0;while(1){system("clear"); //執行終端指令printf("\t*********1.下載********\t\n");printf("\t*********2.上傳********\t\n");printf("\t*********3.退出********\t\n");printf("請輸入選項:");scanf("%d",&menu);getchar();switch(menu){case 1:{//下載請求download(cfd,sin); }break;case 2:{//上傳請求upload(cfd,sin);}break;case 3:{//退出goto END;}break;default:printf("error\n");break;}}END://3.關閉套接字close(cfd);return 0;
}
效果圖：
下載文件：
?
上傳文件：
思維導圖：
)
)
