【正文】 og_file[10]=。 char log_buf[1024]。//網(wǎng)絡(luò)通信信息 int fd。//日志文件描述符 int listen_fd。//監(jiān)聽(tīng)套接字描述符 int _fd。//通信套接字描述符 int len。//請(qǐng)求方地址長(zhǎng)度 int ret。 pid_t pid。//處理請(qǐng)求進(jìn)程id struct servent *sp。//存放服務(wù)器端口信息，從services文件讀取 struct sockaddr_in srv_addr。//服務(wù)器地址 struct sockaddr_in clt_addr。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。//創(chuàng)建監(jiān)聽(tīng)套接字 char buff[1024]。 //數(shù)據(jù)庫(kù)連接信息 MYSQL mysql。//MySQL連接 MYSQL_ROW row。//結(jié)果的行 MYSQL_RES *result。//查詢結(jié)果 char myl_buf[1024]。//存放sql語(yǔ)句 //初始化網(wǎng)絡(luò)連接參數(shù) if(listen_fd0) { perror(創(chuàng)建監(jiān)聽(tīng)套接字失敗)。 strcat(log_buf,創(chuàng)建監(jiān)聽(tīng)套接字失敗)。 log(log_file,log_buf)。 return 1。 } //從services文件中獲取服務(wù)器端口號(hào) if((sp=getservbyname(argv[1],tcp))==NULL) { fprintf(stderr,參數(shù)錯(cuò)誤)。 exit(5)。 } memset(amp。srv_addr,0,sizeof(srv_addr))。//將srv_addr初始化為全0 //設(shè)定地址參數(shù) =AF_INET。 =htonl(INADDR_ANY)。 =sps_port。 //綁定服務(wù)套接字 ret=bind(listen_fd,(struct sockaddr*)amp。srv_addr,sizeof(srv_addr))。 if(ret==1) { perror(綁定服務(wù)套接字失敗)。 strcat(log_buf,綁定服務(wù)套接字失敗)。 log(log_file,log_buf)。 close(listen_fd)。 return 1。 } ret=listen(listen_fd,1024)。 //監(jiān)聽(tīng)客戶連接 if(ret==1) { perror(監(jiān)聽(tīng)客戶請(qǐng)求失敗)。 strcat(log_buf,監(jiān)聽(tīng)客戶請(qǐng)求失敗)。 log(log_file,log_buf)。 close(listen_fd)。 return 1。 } if(mysql_init(amp。mysql)==NULL) //連接users數(shù)據(jù)庫(kù) { fprintf(stderr,數(shù)據(jù)連接初始失敗)。 strcat(log_buf,數(shù)據(jù)連接初始失敗)。 log(log_file,log_buf)。 exit(1)。 } if(!mysql_real_connect(amp。mysql,localhost,root,0,phone,0,NULL,0)) { fprintf(stderr,數(shù)據(jù)庫(kù)連接錯(cuò)誤: %s [%d]\n,mysql_error(amp。mysql),mysql_errno(amp。mysql))。 strcat(log_buf,數(shù)據(jù)庫(kù)連接錯(cuò)誤)。 log(log_file,log_buf)。 mysql_close(amp。mysql)。 exit(2)。 } //開(kāi)始接受客戶請(qǐng)求 printf(等待客戶連接\n)。 while(1) { len=sizeof(clt_addr)。 _fd=accept(listen_fd,(struct sockaddr*)amp。clt_addr,amp。len)。 if(_fd0) { perror(接受客戶端連接請(qǐng)求失敗)。 strcat(log_buf,接受客戶端連接請(qǐng)求失敗)。 log(log_file,log_buf)。 close(listen_fd)。 return 1。 } if((pid=fork())==1) { printf(開(kāi)創(chuàng)進(jìn)程失敗)。 strcat(log_buf,開(kāi)創(chuàng)進(jìn)程失敗)。 log(log_file,log_buf)。 return 1。 } //創(chuàng)建子進(jìn)程成功 if(pid==0) { close(listen_fd)。//關(guān)閉監(jiān)聽(tīng)套接字 char send_buf[1024]。 int len。 if(len=read(_fd,send_buf,1024)0) { if(send_buf[0]==39。G39。) { printf(收到繳費(fèi)請(qǐng)求，信息如下\n)。 printf(%s\n,send_buf)。 printf(手機(jī)號(hào)碼%s\n,send_buf+2)。 printf(繳費(fèi)金額%s\n,send_buf+17)。 sprintf(myl_buf,select *from phone where number=\%s\,send_buf+2)。 if(mysql_query(amp。mysql,myl_buf)!=0) { fprintf(stderr,數(shù)據(jù)查詢錯(cuò)誤： %s [%d]\n,mysql_error(amp。mysql),mysql_errno(amp。mysql))。 mysql_close(amp。mysql)。 memcpy(buff,H,2)。 memcpy(buff+2,E,2)。 memcpy(buff+4,銀行服務(wù)器錯(cuò)誤,14)。 exit(3)。 } if((result=mysql_store_result(amp。mysql))==NULL) { fprintf(stderr,存放數(shù)據(jù)失敗: %s [%d]\n,mysql_error(amp。mysql),mysql_errno(amp。mysql))。 mysql_free_result(result)。 mysql_close(amp。mysql)。 exit(4)。 memcpy(buff,H,2)。 memcpy(buff+2,E,2)。 memcpy(buff+4,銀行服務(wù)器錯(cuò)誤,20)。 strcat(log_buf,銀行服務(wù)器錯(cuò)誤)。 log(log_file,log_buf)。 }。 row=mysql_fetch_row(result)。 if((mysql_num_rows(result))==0) { printf(手機(jī)號(hào)碼不存在!\n)。 memcpy(buff,H,2)。 memcpy(buff+2,E,2)。 memcpy(buff+4,手機(jī)號(hào)碼不存在!,20)。 strcat(log_buf,手機(jī)號(hào)碼不存在!)。 log(log_file,log_buf)。 } else { float money。 money=atof(row[2])+atof(send_buf+17)。 if(money=0) { printf(余額變更為：%f\n,money)。 sprintf(myl_buf,update phone set money=%f where number=\%s\,money,row[0])。 if(mysql_query(amp。mysql,myl_buf)!=0) { fprintf(stderr,數(shù)據(jù)查詢錯(cuò)誤： %s [%d]\n,mysql_error(amp。mysql),mysql_errno(amp。mysql))。 mysql_close(amp。mysql)。 exit(3)。 }else { printf(更新成功\n)。 memcpy(buff,H,2)。 memcpy(buff+2,O,2)。 } } } //printf(錯(cuò)誤信息:%s\n,buff+4)。 write(_fd,buff,1024)。 } } if(send_buf[0]==39。E39。) { printf(收到手機(jī)余額查詢,信息如下\n)。 printf(%s\n,send_buf)。 printf(手機(jī)號(hào)碼：%s\n,send_buf+2)。 char number[19]。//銀行賬號(hào) char name[30]。//戶主姓名 sprintf(myl_buf,select * from phone where number=\%s\,send_buf+2)。 if(mysql_query(amp。mysql,myl_buf)!