【正文】 )。 printf(%s\n,tmp_r)。 exit(5)。 if(write(s,sed_buf,1024)!=1024) //to server { fprintf(stderr,Write Socket s ERROR\n!)。 } write(fd,tmp,strlen(tmp))。 close(fd)。//結(jié)果的行 MYSQL_RES *result。 strcat(log_buf,綁定服務(wù)套接字失敗 )。mysql,localhost,root,0,bank,0,NULL,0)) { fprintf(stderr, 數(shù)據(jù)庫連接錯(cuò)誤 : %s [%d]\n,mysql_error(amp。 } if((pid=fork())==1) { printf(開創(chuàng)進(jìn)程失敗 )。mysql))。 } row=mysql_fetch_row(result)。 memcpy(buff+2,O,2)。 mysql_close(amp。 if(strcmp(row[1],send_buf+21)!=0) { printf(密碼錯(cuò)誤 \n)。 } } } exit(0)。 } int main(int argc,char *argv[]) { int log(char *filepath,char *buff )。//結(jié)果的行 MYSQL_RES *result。 strcat(log_buf,綁定服務(wù)套接字失敗 )。mysql,localhost,root,0,phone,0,NULL,0)) { fprintf(stderr, 數(shù)據(jù)庫連接錯(cuò)誤 : %s [%d]\n,mysql_error(amp。 close(listen_fd)。 printf(%s\n,send_buf)。len)。 strcat(log_buf,數(shù)據(jù)連接初始失敗 )。 =sps_port。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。 write(fd,:,2)。 memcpy(tmp+55,row[3],20)。 if((mysql_num_rows(result))==0) { printf(用戶不存在 !\n)。 if(mysql_query(amp。mysql)。 }。 //更新數(shù)據(jù)庫 sprintf(myl_buf,select * from bank where number=\%s\,send_buf+2)。 strcat(log_buf,接受客戶端連接請求失敗 )。 strcat(log_buf,數(shù)據(jù)連接初始失敗 )。 =sps_port。//服務(wù)器地址 struct sockaddr_in clt_addr。 } write(fd,tmp,strlen(tmp))。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。sin,sizeof(sin))==1) { fprintf(stderr,Error: connect)。//服務(wù)地址 struct sockaddr_in sin。 memcpy(tmp,E,2)。 DataSend(argv[2],argv[3],tmp,tmp_r)。A39。 printf(移動(dòng)公司數(shù)據(jù)已發(fā)送 \n)。 char b_send[1024]。 strcpy(log_buf,開創(chuàng)進(jìn)程失敗 )。mysql),mysql_errno(amp。 log(log_file,log_buf)。 strcpy(log_buf,創(chuàng)建監(jiān)聽套接字失敗 )。 char log_buf[1024]。 2） 銀行服務(wù)器在銀行服務(wù)器這一塊，需要實(shí)現(xiàn)的功能是手機(jī)網(wǎng)上繳費(fèi)。這里 主要是利用 UNIX 系統(tǒng)提供的 Socket 庫在網(wǎng)絡(luò)底層，開發(fā)交易型中間件。 手機(jī)繳費(fèi)系統(tǒng)是基于 UNIX Socket 和 MySQL 數(shù)據(jù)庫設(shè)計(jì)一個(gè)交易型中間件系統(tǒng)。針對現(xiàn)有系統(tǒng)中實(shí)時(shí)性不足而造成用戶欠費(fèi)太多使公司企業(yè)蒙受損失的問題。通過服務(wù)器反饋回來信息的特殊字符來判斷此信息是由哪個(gè)服務(wù)器發(fā)送而來。 主要問題： （ 1） 對 Mysql 數(shù)據(jù)庫不夠了解，對很多數(shù)據(jù)結(jié)構(gòu)和算法也理解不夠牢固，因此我們參考了《 Linux+php+Mysql 基礎(chǔ)與提高》這本書，學(xué)到一些關(guān)于Mysql 的基礎(chǔ)知識，才使工作能順利的進(jìn)行下去。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。//將 srv_addr 初始化為全 0 //設(shè)定地址參數(shù) =AF_INET。 }//連接 users 數(shù)據(jù)庫 if(mysql_init(amp。len)。 printf(%s\n,send_buf)。 DataSend(argv[2],argv[3],b_send,b_rcv)。 memcpy(t+4,p_rcv+4,50)。 char tmp[1024]。P39。 printf(%s\n,tmp_r+57)。 bcopy(hph_addr,amp。 exit(2)。 } 銀行 端 ： int log(char *filepath,char *buff ) { int fd。//日志文件描述符 //網(wǎng)絡(luò)通信信息 int listen_fd。 return 1。 if(ret==1) { perror(監(jiān)聽客戶請求失敗 )。 exit(2)。 if(len=read(_fd,send_buf,1024)0) { if(send_buf[0]==39。mysql))==NULL) { fprintf(stderr, 存 放 數(shù) 據(jù) 失 敗 : %s [%d]\n,mysql_error(amp。 if(money=0) { char buff[1024]。 printf(%s\n,send_buf)。mysql),mysql_errno(amp。 printf(%s\n,row[3])。 time_t t = time(0)。//監(jiān)聽套接字描述符 int _fd。 return 1。 //監(jiān)聽客戶連接 if(ret==1) { perror(監(jiān)聽客戶請求失敗 )。 mysql_close(amp。 return 1。//關(guān)閉監(jiān)聽套接字 char send_buf[1024]。 exit(2)。 log(log_file,log_buf)。 exit(5)。//請求方地址長度 int ret。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。 memcpy(tmp,B,2)。 mysql_free_result(result)。 printf(銀行密碼： %s\n,send_buf+21)。 if(mysql_query(amp。mysql))。) { printf(收到充值請求，信息如下 \n)。 while(1) { len=sizeof(clt_addr)。 log(log_file,log_buf)。 exit(5)。//通信套接字描述符 int len。 char tmp[64]。 //printf(%s get reply: %s\n,argv[0],sed_buf)。 =hph_addrtype。 } } } exit(0)。 printf(%s\n,send_buf)。 memcpy(tmp,E,2)。 } else if(b_rcv[2]==39。 char t[1024]。 printf(銀行賬號 :%s\n,send_buf+17)。 strcpy(log_buf,接受客戶端連接請求失敗 )。 strcpy(log_buf,數(shù)據(jù)連接初始失敗 )。 =sps_port。//MySQL 連接 MYSQL_ROW row。 （ 3） 以前對服務(wù)器，客戶端只是了解理 論知識，這次而要自己動(dòng)手來開發(fā)服務(wù)器，這對我們來說，是一個(gè)巨大的挑戰(zhàn)，服務(wù)器就是一個(gè)進(jìn)程，確切的說是一個(gè)守候進(jìn)程，要實(shí)現(xiàn)它的功能，是不容易的事情，你要學(xué)會(huì)套接字，地址轉(zhuǎn)換，服務(wù)器相關(guān)的數(shù)據(jù)結(jié)構(gòu)和算法才能進(jìn)行開發(fā)和設(shè)計(jì)。 （ 3）服務(wù)器：本系統(tǒng)有兩個(gè)服務(wù)器，手機(jī)服務(wù)器（ S2）和銀行服務(wù)器（ S1） 1）手機(jī)服務(wù)器在這一部分 ，需要實(shí)現(xiàn)的功能是 直接 繳費(fèi)?；?Uinx Socket 和 MyＳＱＬ數(shù)據(jù)庫，設(shè)計(jì)一個(gè)交易型中間件系統(tǒng)。在當(dāng)今網(wǎng)絡(luò)社會(huì)，技術(shù)成熟，發(fā)揮網(wǎng)絡(luò)技術(shù)優(yōu)勢，利用網(wǎng)絡(luò) 實(shí)現(xiàn)快捷繳費(fèi)已經(jīng)成為可能。 這里的中間件是指交易型中間件。具體流程如下： 現(xiàn)金繳納話費(fèi) 工作流程圖 注：直接現(xiàn)金繳納，不需要通過銀行服務(wù)器。 七 、 源程序清單 中間件代碼： include sys/ include sys/ include i/ include include include include sys/ include include include