【正文】 de netinet/include include include include sys/include include include include int main(int argc,char *argv[]){ int log(char *filepath,char *buff )。 char log_buf[1024]。//監(jiān)聽套接字描述符 int _fd。//請求方地址長度 int ret。//處理請求進程id struct servent *sp。//服務器地址 struct sockaddr_in clt_addr。//創(chuàng)建監(jiān)聽套接字 //數(shù)據(jù)庫連接信息 MYSQL mysql。//結果的行 MYSQL_RES *result。//存放sql語句 //初始化網(wǎng)絡連接參數(shù) int DataSend(char *service,char *dest,char sed_buf[1024],char rcv_buf[1024])。 strcpy(log_buf,創(chuàng)建監(jiān)聽套接字失敗)。 return 1。 strcpy(log_buf,參數(shù)錯誤)。 exit(5)。srv_addr,0,sizeof(srv_addr))。 =htonl(INADDR_ANY)。 //綁定服務套接字 ret=bind(listen_fd,(struct sockaddr*)amp。 if(ret==1) { perror(綁定服務套接字失敗)。 log(log_file,log_buf)。 return 1。 if(ret==1) { perror(監(jiān)聽客戶請求失敗)。 log(log_file,log_buf)。 return 1。mysql)==NULL) { fprintf(stderr,數(shù)據(jù)連接初始失敗)。 log(log_file,log_buf)。 } if(!mysql_real_connect(amp。mysql),mysql_errno(amp。 mysql_close(amp。 exit(2)。 while(1) { len=sizeof(clt_addr)。clt_addr,amp。 if(_fd0) { perror(接受客戶端連接請求失敗)。 log(log_file,log_buf)。 return 1。 strcpy(log_buf,開創(chuàng)進程失敗)。 return 1。//關閉監(jiān)聽套接字 //處理接受到的數(shù)據(jù) char send_buf[1024]。 if(len=read(_fd,send_buf,1024)0) { if(send_buf[0]==39。) { printf(收到充值請求，信息如下\n)。 printf(手機號碼：%s\n,send_buf+2)。 printf(銀行密碼:%s\n,send_buf+36)。 char p_send[1024]。 char b_send[1024]。 //繳費封包 memcpy(p_send,G,2)。 memcpy(p_send+17,send_buf+46,20)。 memcpy(b_send+2,send_buf+17,19)。 memcpy(b_send+31,send_buf+46,20)。 printf(銀行數(shù)據(jù)已發(fā)送\n)。 memcpy(t,D,2)。O39。 printf(移動公司數(shù)據(jù)已發(fā)送\n)。O39。 memcpy(t+2,O,2)。 } else if(p_rcv[2]==39。) { memcpy(t+2,E,2)。 write(_fd,t,1024)。E39。 memcpy(t+4,b_rcv+4,50)。A39。 if(send_buf[2]==39。) { printf(收到銀行查詢,信息如下\n)。 printf(%s\n,send_buf+2)。 printf(銀行密碼：%s\n,send_buf+23)。 char tmp_r[1024]。 memcpy(tmp+2,send_buf+4,19)。 printf(銀行賬號:%s\n,tmp+2)。 DataSend(argv[2],argv[3],tmp,tmp_r)。 printf(%s\n,tmp_r+2)。 printf(%s\n,tmp_r+6)。 printf(%s\n,tmp_r+55)。 } else if(send_buf[2]==39。) { printf(收到手機查詢,信息如下\n)。 printf(%s\n,send_buf+2)。 char tmp[1024]。 memcpy(tmp,E,2)。 printf(手機賬號:%s\n,tmp+2)。 printf(%s\n,tmp_r)。 printf(%s\n,tmp_r+4)。 printf(%s\n,tmp_r+21)。 write(_fd,tmp_r,1024)。 } //回到父進程 if(pid0) { wait(0)。//關閉通信套接字 continue。//服務地址 struct sockaddr_in sin。//服務端口 int s。 exit(5)。 exit(6)。sin,sizeof(sin))。,hph_length)。 =sps_port。 exit(6)。sin,sizeof(sin))==1) { fprintf(stderr,Error: connect)。 exit(6)。 if(write(s,sed_buf,1024)!=1024) //to server { fprintf(stderr,Write Socket s ERROR\n!)。 exit(1)。 close(s)。 } printf(%s\n,rcv_buf)。 close(s)。 time_t t = time(0)。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。 if((fd=open(filepath,O_WRONLY|O_CREAT|O_APPEND,0644))==1) { fprintf(stderr,Log file %s open error!\a\n,log)。 } write(fd,tmp,strlen(tmp))。 write(fd,buff,strlen(buff))。 close(fd)。 time_t t = time(0)。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。 if((fd=open(filepath,O_WRONLY|O_CREAT|O_APPEND,0644))==1) { fprintf(stderr,Log file %s open error!\a\n,log)。 } write(fd,tmp,strlen(tmp))。 write(fd,buff,strlen(buff))。 close(fd)。 char log_file[10]=。 int fd。//監(jiān)聽套接字描述符 int _fd。//請求方地址長度 int ret。//處理請求進程id struct servent *sp。//服務器地址 struct sockaddr_in clt_addr。//創(chuàng)建監(jiān)聽套接字 //數(shù)據(jù)庫連接信息 MYSQL mysql。//結果的行 MYSQL_RES *result。//存放sql語句 //初始化網(wǎng)絡連接參數(shù) if(listen_fd0) { perror(創(chuàng)建監(jiān)聽套接字失敗)。 log(log_file,log_buf)。 } //從services文件中獲取服務器端口號 if((sp=getservbyname(argv[1],tcp))==NULL) { fprintf(stderr,參數(shù)錯誤)。 } memset(amp。//將srv_addr初始化為全0 //設定地址參數(shù) =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數(shù)據(jù)庫 if(mysql_init(amp。 strcat(log_buf,數(shù)據(jù)連接初始失敗)。 exit(1)。mysql,localhost,root,0,bank,0,NULL,0)) { fprintf(stderr,數(shù)據(jù)庫連接錯誤: %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=