【正文】 l)。 strcpy(log_buf,接受客戶端連接請(qǐng)求失敗 )。 } if(pid==0) //創(chuàng)建子進(jìn)程成功 { close(listen_fd)。 printf(銀行賬號(hào) :%s\n,send_buf+17)。 memcpy(p_send+2,send_buf+2,15)。 char t[1024]。) { printf(充值成功 \n)。 } else if(b_rcv[2]==39。B39。 memcpy(tmp,E,2)。 printf(%s\n,tmp_r+4)。 printf(%s\n,send_buf)。 DataSend(argv[4],argv[5],tmp,tmp_r)。 } } } exit(0)。//連接描述符 //獲取服務(wù)端口號(hào) if((sp=getservbyname(service,tcp))==NULL) { fprintf(stderr,Error: getservbyname)。 =hph_addrtype。 } //發(fā)送數(shù)據(jù) //fprintf(stderr,%s is sending request message: %s\n,argv[0],sed_buf)。 //printf(%s get reply: %s\n,argv[0],sed_buf)。 exit(1)。 char tmp[64]。 write(fd,\n,2)。//通信套接字描述符 int len。//MySQL 連接 MYSQL_ROW row。 exit(5)。 if(ret==1) { perror(綁定服務(wù)套接字失敗 )。 log(log_file,log_buf)。 } if(!mysql_real_connect(amp。 while(1) { len=sizeof(clt_addr)。 return 1。) { printf(收到充值請(qǐng)求，信息如下 \n)。mysql),mysql_errno(amp。mysql))。 log(log_file,log_buf)。 if(mysql_query(amp。 } memcpy(buff,H,2)。 printf(銀行密碼： %s\n,send_buf+21)。mysql))。 mysql_free_result(result)。 } row=mysql_fetch_row(result)。 memcpy(tmp,B,2)。 close(_fd)。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。 close(fd)。//請(qǐng)求方地址長(zhǎng)度 int ret。//MySQL 連接 MYSQL_ROW row。 exit(5)。 if(ret==1) { perror(綁定服務(wù)套接字失敗 )。 log(log_file,log_buf)。 } if(!mysql_real_connect(amp。 exit(2)。 log(log_file,log_buf)。//關(guān)閉監(jiān)聽(tīng)套接字 char send_buf[1024]。 printf(手機(jī)號(hào)碼 %s\n,send_buf+2)。 return 1。 if(_fd0) { perror(接受客戶端連接請(qǐng)求失敗 )。 mysql_close(amp。 log(log_file,log_buf)。 //監(jiān)聽(tīng)客戶連接 if(ret==1) { perror(監(jiān)聽(tīng)客戶請(qǐng)求失敗 )。 //綁定服務(wù)套接字 ret=bind(listen_fd,(struct sockaddr*)amp。 return 1。//創(chuàng)建監(jiān)聽(tīng)套接 字 char buff[1024]。//監(jiān)聽(tīng)套接字描述符 int _fd。 write(fd,buff,strlen(buff))。 time_t t = time(0)。 write(_fd,tmp,1024)。 printf(%s\n,row[3])。 strcat(log_buf,用戶不存在 !)。mysql),mysql_errno(amp。mysql,myl_buf)!=0) { fprintf(stderr, 數(shù) 據(jù) 查 詢 錯(cuò) 誤 ： %s [%d]\n,mysql_error(amp。 printf(%s\n,send_buf)。 exit(3)。 if(money=0) { char buff[1024]。 if((mysql_num_rows(result))==0) { printf(用戶不存在 !\n)。mysql))==NULL) { fprintf(stderr, 存 放 數(shù) 據(jù) 失 敗 : %s [%d]\n,mysql_error(amp。 if(mysql_query(amp。 if(len=read(_fd,send_buf,1024)0) { if(send_buf[0]==39。 log(log_file,log_buf)。 exit(2)。 log(log_file,log_buf)。 if(ret==1) { perror(監(jiān)聽(tīng)客戶請(qǐng)求失敗 )。 //綁定服務(wù)套接字 ret=bind(listen_fd,(struct sockaddr*)amp。 return 1。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。//日志文件描述符 //網(wǎng)絡(luò)通信信息 int listen_fd。 write(fd,:,2)。 } 銀行 端 ： int log(char *filepath,char *buff ) { int fd。t) )。 exit(2)。 close(s)。 bcopy(hph_addr,amp。//指明連接地址信息 struct servent *sp。 printf(%s\n,tmp_r+57)。 memcpy(tmp+2,send_buf+4,15)。P39。 printf(%s\n,tmp_r)。 char tmp[1024]。) { printf(收到查詢請(qǐng)求： \n)。 memcpy(t+4,p_rcv+4,50)。 if(p_rcv[2]==39。 DataSend(argv[2],argv[3],b_send,b_rcv)。 char b_rcv[1024]。 printf(%s\n,send_buf)。 log(log_file,log_buf)。len)。mysql))。 }//連接 users 數(shù)據(jù)庫(kù) if(mysql_init(amp。 close(listen_fd)。//將 srv_addr 初始化為全 0 //設(shè)定地址參數(shù) =AF_INET。 log(log_file,log_buf)。//客戶端地址 listen_fd=socket(PF_INET,SOCK_STREAM,0)。 //網(wǎng)絡(luò)通信信息 int listen_fd。 主要問(wèn)題： （ 1） 對(duì) Mysql 數(shù)據(jù)庫(kù)不夠了解，對(duì)很多數(shù)據(jù)結(jié)構(gòu)和算法也理解不夠牢固，因此我們參考了《 Linux+php+Mysql 基礎(chǔ)與提高》這本書(shū)，學(xué)到一些關(guān)于Mysql 的基礎(chǔ)知識(shí)，才使工作能順利的進(jìn)行下去。它的過(guò)程是接收從中間件過(guò)來(lái)的信息，在客戶所輸入的銀行賬戶上扣除相應(yīng)的手機(jī)費(fèi)用；如果在手機(jī)的服務(wù)器那一塊出現(xiàn)問(wèn)題，繳費(fèi)不成功，銀行服務(wù)器還負(fù)責(zé)把之前所扣除的話費(fèi)給加上，具體實(shí)現(xiàn)流程如下： 查詢用戶信息 繳費(fèi)金額 中間件處理 更新銀行數(shù)據(jù)庫(kù) client Service2 (手機(jī)服務(wù)器 ） middle 選擇銀行服務(wù)器后整個(gè)系統(tǒng)的工作流程圖 ： 5 4 7 1 6 2 3 虛線表示在手機(jī)服務(wù)器出錯(cuò)，繳費(fèi)失敗，向銀行服務(wù)器返回所 交的話費(fèi)。通過(guò)服務(wù)器反饋回來(lái)信息的特殊字符來(lái)判斷此信息是由哪個(gè)服務(wù)器發(fā)送而來(lái)。 本設(shè)計(jì)的目的是使參與設(shè)計(jì)者掌握利用軟件工程的思想方法和 TCP/IP 設(shè)計(jì)出用于不同行業(yè)和部門間的通訊轉(zhuǎn)發(fā)或協(xié)議轉(zhuǎn)換軟件 — 中間件，尤其掌握這種設(shè)計(jì)的思想和方法。針對(duì)現(xiàn)有系統(tǒng)中實(shí)時(shí)性不足而造成用戶欠費(fèi)太多使公司企業(yè)蒙受損失的問(wèn)題。在 Linux 環(huán)境下使用 GNU C 或者 GNU C++，在 Linux make 開(kāi)發(fā)工具的管理和控制下，利用 Linux 系統(tǒng)提供的 Socket 庫(kù)和 MySQL 數(shù)據(jù)庫(kù)在網(wǎng)絡(luò)底層開(kāi)發(fā)交易型中間件，同時(shí)簡(jiǎn)要介紹了客戶端和服務(wù)器的工作模式。 手機(jī)繳費(fèi)系統(tǒng)是基于 UNIX Socket 和 MySQL 數(shù)據(jù)庫(kù)設(shè)計(jì)一個(gè)交易型中間件系統(tǒng)。