【正文】 fd。//監(jiān)聽套接字描述符 int _fd。//請求方地址長度 int ret。//處理請求進程 id struct servent *sp。//服務器地址 struct sockaddr_in clt_addr。//創(chuàng)建監(jiān)聽套接字 //數據庫連接信息 MYSQL mysql。//結果的行 MYSQL_RES *result。//存放 sql語句 //初始化網絡連接參數 if(listen_fd0) { perror(創(chuàng)建監(jiān)聽套接字失敗 )。 log(log_file,log_buf)。 } //從 services 文件中獲取服務器端口號 if((sp=getservbyname(argv[1],tcp))==NULL) { fprintf(stderr,參數錯誤 )。 } memset(amp。//將 srv_addr 初始化為全 0 //設定地址參數 =AF_INET。 =sps_port。srv_addr,sizeof(srv_addr))。 strcat(log_buf,綁定服務套接字失敗 )。 close(listen_fd)。 } //監(jiān)聽客戶連接 ret=listen(listen_fd,1024)。 strcat(log_buf,監(jiān)聽客戶請求失敗 )。 close(listen_fd)。 } //連接 users 數據庫 if(mysql_init(amp。 strcat(log_buf,數據連接初始失敗 )。 exit(1)。mysql,localhost,root,0,bank,0,NULL,0)) { fprintf(stderr, 數據庫連接錯誤 : %s [%d]\n,mysql_error(amp。mysql))。mysql)。 } //開始接受客戶請求 printf(等待客戶連接 \n)。 _fd=accept(listen_fd,(struct sockaddr*)amp。len)。 strcat(log_buf,接受客戶端連接請求失敗 )。 close(listen_fd)。 } if((pid=fork())==1) { printf(開創(chuàng)進程失敗 )。 } //創(chuàng)建子進程成功 if(pid==0) { close(listen_fd)。 int len。G39。 printf(%s\n,send_buf)。 printf(銀行密碼 %s\n,send_buf+21)。 //更新數據庫 sprintf(myl_buf,select * from bank where number=\%s\,send_buf+2)。mysql,myl_buf)!=0) { fprintf(stderr, 數據查 詢 錯 誤 ： %s [%d]\n,mysql_error(amp。mysql))。mysql)。 } if((result=mysql_store_result(amp。mysql),mysql_errno(amp。 mysql_free_result(result)。mysql)。 }。 strcat(log_buf,用戶不存在 !)。 } row=mysql_fetch_row(result)。 } else { float money。 printf(余額變更為： %f\n,money)。 sprintf(myl_buf,update bank set money=%f where number=\%s\,money,row[0])。mysql,myl_buf)!=0) { fprintf(stderr, 數據查詢錯誤： %s [%d]\n,mysql_error(amp。mysql))。mysql)。 } else { printf(更新成功?。?)。 memcpy(buff+2,O,2)。 } } } if(send_buf[0]==39。) { printf(收到銀行查詢 ,信息如下 \n)。 printf(銀行賬號 :%s\n,send_buf+2)。 char number[19]。//密碼 char name[30]。 if(mysql_query(amp。mysql),mysql_errno(amp。 mysql_close(amp。 exit(3)。mysql))==NULL) { fprintf(stderr, 存 放 數 據 失 敗 : %s [%d]\n,mysql_error(amp。mysql))。 mysql_close(amp。 exit(4)。 if((mysql_num_rows(result))==0) { printf(用戶不存在 !\n)。 log(log_file,log_buf)。 if(strcmp(row[1],send_buf+21)!=0) { printf(密碼錯誤 \n)。 log(log_file,log_buf)。 printf(%s\n,row[0])。 char tmp[1024]。 memcpy(tmp+2,B,2)。 memcpy(tmp+6,row[2],30)。 memcpy(tmp+55,row[3],20)。 printf(%i,sizeof(tmp))。 } } } exit(0)。 close(_fd)。 } } } 手機端： int log(char *filepath,char *buff ) { int fd。 char tmp[64]。t) )。 exit(1)。 write(fd,:,2)。 write(fd,\n,2)。 } int main(int argc,char *argv[]) { int log(char *filepath,char *buff )。 char log_buf[1024]。//日志文件描述符 int listen_fd。//通信套接字描述符 int len。 pid_t pid。//存放服務器端口信息，從 services 文件讀取 struct sockaddr_in srv_addr。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。 //數據庫連接信息 MYSQL mysql。//結果的行 MYSQL_RES *result。//存放 sql語句 //初始化網絡連接參數 if(listen_fd0) { perror(創(chuàng)建監(jiān)聽套接字失敗 )。 log(log_file,log_buf)。 } //從 services 文件中獲取服務器端口號 if((sp=getservbyname(argv[1],tcp))==NULL) { fprintf(stderr,參數錯誤 )。 } memset(amp。//將 srv_addr 初始化為全 0 //設定地址參數 =AF_INET。 =sps_port。srv_addr,sizeof(srv_addr))。 strcat(log_buf,綁定服務套接字失敗 )。 close(listen_fd)。 } ret=listen(listen_fd,1024)。 strcat(log_buf,監(jiān)聽客戶請求失敗 )。 close(listen_fd)。 } if(mysql_init(amp。 strcat(log_buf,數據連接初始失敗 )。 exit(1)。mysql,localhost,root,0,phone,0,NULL,0)) { fprintf(stderr, 數據庫連接錯誤 : %s [%d]\n,mysql_error(amp。mysql))。 log(log_file,log_buf)。mysql)。 } //開始接受客戶請求 printf(等待客戶連接 \n)。 _fd=accept(listen_fd,(struct sockaddr*)amp。len)。 strcat(log_buf,接受客戶端連接請求失敗 )。 close(listen_fd)。 } if((pid=fork())==1) { printf(開創(chuàng)進程失敗 )。 log(log_file,log_buf)。 } //創(chuàng)建子進程成功 if(pid==0) { close(listen_fd)。 int len。G39。 printf(%s\n,send_buf)。