【文章內(nèi)容簡(jiǎn)介】 。 DataSend(argv[2],argv[3],b_send,b_rcv)。 printf(銀行數(shù)據(jù)已發(fā)送 \n)。 char t[1024]。 memcpy(t,D,2)。 if(b_rcv[2]==39。O39。) { DataSend(argv[4],argv[5],p_send,p_rcv)。 printf(移動(dòng)公司數(shù)據(jù)已發(fā)送 \n)。 if(p_rcv[2]==39。O39。) { printf(充值成功 \n)。 memcpy(t+2,O,2)。 write(_fd,t,1024)。 } else if(p_rcv[2]==39。E39。) { memcpy(t+2,E,2)。 memcpy(t+4,p_rcv+4,50)。 write(_fd,t,1024)。 } else if(b_rcv[2]==39。E39。) { memcpy(t+2,E,2)。 memcpy(t+4,b_rcv+4,50)。 } } if(send_buf[0]==39。A39。) { printf(收到查詢請(qǐng)求： \n)。 if(send_buf[2]==39。B39。) { printf(收到銀行查詢 ,信息如下 \n)。 printf(%s\n,send_buf)。 printf(%s\n,send_buf+2)。 printf(銀行賬號(hào) :%s\n,send_buf+4)。 printf(銀行密碼： %s\n,send_buf+23)。 char tmp[1024]。 char tmp_r[1024]。 memcpy(tmp,E,2)。 memcpy(tmp+2,send_buf+4,19)。 memcpy(tmp+21,send_buf+23,10)。 printf(銀行賬號(hào) :%s\n,tmp+2)。 printf(銀行密碼： %s\n,tmp+21)。 DataSend(argv[2],argv[3],tmp,tmp_r)。 printf(%s\n,tmp_r)。 printf(%s\n,tmp_r+2)。 printf(%s\n,tmp_r+4)。 printf(%s\n,tmp_r+6)。 printf(%s\n,tmp_r+36)。 printf(%s\n,tmp_r+55)。 write(_fd,tmp_r,1024)。 } else if(send_buf[2]==39。P39。) { printf(收到手機(jī)查詢 ,信息如下 \n)。 printf(%s\n,send_buf)。 printf(%s\n,send_buf+2)。 printf(手機(jī)號(hào)碼 :%s\n,send_buf+4)。 char tmp[1024]。 char tmp_r[1024]。 memcpy(tmp,E,2)。 memcpy(tmp+2,send_buf+4,15)。 printf(手機(jī)賬號(hào) :%s\n,tmp+2)。 DataSend(argv[4],argv[5],tmp,tmp_r)。 printf(%s\n,tmp_r)。 printf(%s\n,tmp_r+2)。 printf(%s\n,tmp_r+4)。 printf(%s\n,tmp_r+6)。 printf(%s\n,tmp_r+21)。 printf(%s\n,tmp_r+57)。 write(_fd,tmp_r,1024)。 } } } exit(0)。 } //回到父進(jìn)程 if(pid0) { wait(0)。 close(_fd)。//關(guān)閉通信套接字 continue。 } } int DataSend(char *service,char *dest,char sed_buf[1024],char rcv_buf[1024])//參數(shù)為服務(wù)端口端口號(hào)和主機(jī)名及需要發(fā)送的數(shù)據(jù) { struct hostent *hp。//服務(wù)地址 struct sockaddr_in sin。//指明連接地址信息 struct servent *sp。//服務(wù)端口 int s。//連接描述符 //獲取服務(wù)端口號(hào) if((sp=getservbyname(service,tcp))==NULL) { fprintf(stderr,Error: getservbyname)。 exit(5)。 } //獲取目的主機(jī) if((hp=gethostbyname(dest))==0) { fprintf(stderr,Error: gethostbyname)。 exit(6)。 } //初始化服務(wù)套接字 bzero(amp。sin,sizeof(sin))。 bcopy(hph_addr,amp。,hph_length)。 =hph_addrtype。 =sps_port。 if((s=socket(AF_INET,SOCK_STREAM,0))==1) { fprintf(stderr,Error: socket)。 exit(6)。 } if(connect(s,amp。sin,sizeof(sin))==1) { fprintf(stderr,Error: connect)。 close(s)。 exit(6)。 } //發(fā)送數(shù)據(jù) //fprintf(stderr,%s is sending request message: %s\n,argv[0],sed_buf)。 if(write(s,sed_buf,1024)!=1024) //to server { fprintf(stderr,Write Socket s ERROR\n!)。 close(s)。 exit(1)。 } if(read(s,rcv_buf,1025)==0) //get replay from server { fprintf(stderr,Read Socket s Error\n)。 close(s)。 exit(2)。 } printf(%s\n,rcv_buf)。 //printf(%s get reply: %s\n,argv[0],sed_buf)。 close(s)。 } } int log(char *filepath,char *buff ) { int fd。 time_t t = time(0)。 char tmp[64]。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。t) )。 if((fd=open(filepath,O_WRONLY|O_CREAT|O_APPEND,0644))==1) { fprintf(stderr,Log file %s open error!\a\n,log)。 exit(1)。 } write(fd,tmp,strlen(tmp))。 write(fd,:,2)。 write(fd,buff,strlen(buff))。 write(fd,\n,2)。 close(fd)。 } 銀行 端 ： int log(char *filepath,char *buff ) { int fd。 time_t t = time(0)。 char tmp[64]。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。t) )。 if((fd=open(filepath,O_WRONLY|O_CREAT|O_APPEND,0644))==1) { fprintf(stderr,Log file %s open error!\a\n,log)。 exit(1)