由于深度學習任務的需要,要在程序里面嵌入一個module。
這個module 的功能是接收來自ios客戶端的圖片。并且傳送給深度學習分類器進行處理。
于是看了看各種各樣的 module 實現方案。
先是用IO函數把圖片以數組的方式存起來。
再和服務器建立連接,socket傳這個數組。
然后服務器接收完數組以后就再運用IO函數 把數組以圖片的方式存起來!
然后用各種網絡編程和操作系統的技巧,多線程接收多線程發送來改善速度。
?
現在先講述一種最原始的 圖片傳輸的module
??這是服務端進程運行
它將接收fish-bike.jpg 并且將之存到/root/photo_out這目錄下!
這是客戶端進程運行
它將發送/root/photo_in/fish-bike.jpg 給服務進程。同時在本地/root/photo_in/復制一個fish-bike.jpg(這是本地測試的demo)
?傳送成功!但是慢!
以下是客戶端代碼
#include <stdio.h> #include <stdlib.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <string.h> #define SERVER_IP "127.0.0.1" #define PORT 6675int main() {int socket_fd;socket_fd=socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in server_addr;//initialize sockfd memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family=AF_INET;server_addr.sin_port=htons(PORT);//6675server_addr.sin_addr.s_addr=inet_addr(SERVER_IP);//127.0.0.1 local?memset(&(server_addr.sin_zero),0,8);//clean server addr int res =connect(socket_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));//connect server_addr printf("connect res is %d\n",res); /*while(1){printf("send send ---->\n");char input[100];char output[100]; memset(input,0,sizeof(input));gets(input);res=write(socket_fd,input,strlen(input));printf("the write resoult is %d\n",res);res=read(socket_fd,output,100);output[res]=0;printf("server says:'%s'\n",output);sleep(1);}*/char path[100];printf("please give the path of photo!\n");char input[100];gets(input);sprintf(path,"/root/photo_in/%s",input);printf("begin to write");write(socket_fd,input,strlen(input));printf("write %s success",input);FILE *out=fopen(path,"r");printf("read %s success",path);FILE *new=fopen("/root/photo_in/new.jpg","w");printf("open /root/photo_in/new.jpg success");int c;sleep(1);printf("ready to open!");while((c=fgetc(out))!=EOF)//open /root/photo_in/cat.jpg { //get c of cat.jpgchar photo[100];sprintf(photo,"%d",c);//write c into photo[]int b=atoi(photo);fputc(b,new);// printf("data %s\n",photo); write(socket_fd,photo,strlen(photo)); //write photo[]to serverusleep(1500);//sleep(?) }char *end="#";write(socket_fd,end,strlen(end));close(socket_fd);}
以下是服務端代碼
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> //sockaddr_in#define PORT 6675int main() {int socket_fd;int new_fd; //建立套接字 socket_fd=socket(AF_INET,SOCK_STREAM,0);// int socket(int domain, int... printf("socket_fd is %d\n",socket_fd);//初始化設置地址和端口號struct sockaddr_in server_addr; memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family=AF_INET;server_addr.sin_port=htons(PORT);server_addr.sin_addr.s_addr=htonl(INADDR_ANY);memset(&(server_addr.sin_zero),0,8);//設置端口可重用int contain;setsockopt(socket_fd,SOL_SOCKET, SO_REUSEADDR, &contain, sizeof(int)); //綁定fd和本機地址int res=bind(socket_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));printf("bind res is %d\n",res);if(res==-1) return -1;if(listen(socket_fd,20)==-1){printf("Failed to listen!\n");return -1;}printf("after listen\n");while(1){struct sockaddr_in client_addr;int size=sizeof(client_addr);new_fd=accept(socket_fd, (struct sockaddr *)&client_addr, &size);if(new_fd==-1){printf("wait for client to connect!\n");sleep(1);continue;}printf("A connect and the new fd is %d\n",new_fd);/*while(1){ char input[100];char output[100];res=read(new_fd,input,100);input[res]=0;printf("client says '%s'\n",input); gets(output);res=write(new_fd,output,strlen(output));}*///while(1) {FILE *in;char input[100];res=read(new_fd,input,100);input[res]=0;char path[100];sprintf(path,"/root/photo_out/%s",input);printf("the path is %s\n",path);in=fopen(path,"w");printf("after path\n");char photo[10];while(1){memset(photo,0,10);res=read(new_fd,photo,10);if(res==0){printf("read nothing"); return 0;}photo[res]=0;int d=atoi(photo);// printf("data %s\n",photo);fputc(d,in);}}}close(socket_fd);close(new_fd); }
?
所以接下來是不放在本地測試,而是放在騰訊云服務器上測試!
放在遠端服務器上測試沒想到套接字阻塞的現象比本地測試更加嚴重!
就是 客戶端傳4 18 3過去?
結果?服務端把4183 當做一個點的像素值寫了進去!
?