【正文】 ten_fd,(struct sockaddr*)amp。mysql,localhost,root,0,bank,0,NULL,0)) { fprintf(stderr, 數(shù)據(jù)庫連接錯(cuò)誤 : %s [%d]\n,mysql_error(amp。 close(listen_fd)。 strcat(log_buf,綁定服務(wù)套接字失敗 )。 } memset(amp。//結(jié)果的行 MYSQL_RES *result。//請求方地址長度 int ret。 close(fd)。 strftime( tmp, sizeof(tmp), %Y/%m/%d %X %A ,localtime(amp。 } write(fd,tmp,strlen(tmp))。 close(s)。 if(write(s,sed_buf,1024)!=1024) //to server { fprintf(stderr,Write Socket s ERROR\n!)。 =sps_port。 exit(5)。 } //回到父進(jìn)程 if(pid0) { wait(0)。 printf(%s\n,tmp_r)。 printf(%s\n,send_buf+2)。 printf(%s\n,tmp_r+6)。 memcpy(tmp+2,send_buf+4,19)。) { printf(收到銀行查詢 ,信息如下 \n)。E39。 memcpy(t+2,O,2)。 memcpy(t,D,2)。 memcpy(p_send+17,send_buf+46,20)。 printf(銀行密碼 :%s\n,send_buf+36)。//關(guān)閉監(jiān)聽套接字 //處理接受 到的數(shù)據(jù) char send_buf[1024]。 log(log_file,log_buf)。 exit(2)。 log(log_file,log_buf)。 if(ret==1) { perror(監(jiān)聽客戶請求失敗 )。 //綁定服務(wù)套接字 ret=bind(listen_fd,(struct sockaddr*)amp。 strcpy(log_buf,參數(shù)錯(cuò)誤 )。//結(jié)果的行 MYSQL_RES *result。//請求方地址長度 int ret。 （ 4） 還是很多基礎(chǔ)的東西沒有掌握好，基本的算法也沒有完全掌握，參考了教科書的相關(guān)內(nèi)容后，才開始了我們的課程設(shè)計(jì)。 show tables。它的過程是接收從中間件過來的信息，在 手機(jī)服務(wù)器的 客戶 賬戶上相應(yīng)加上對應(yīng)的話費(fèi)，即更新手機(jī)服務(wù)器數(shù)據(jù)庫。 ３． ２ ：中間件模型 ３．３ 流程圖 Socker（）建立服務(wù)方套接字，描述符為 s bingd（） 綁定套接字與本地地址和端口 Linsten（） 通知 TCP，準(zhǔn)備接受 Socker（） 建立服務(wù)方套接字，描述符為 s accept（）等待客戶方連接 Connect（） 建立與服務(wù)方鏈接 recv（） /read（）讀取客戶方數(shù)據(jù) Send（） /write（）向服務(wù)器方發(fā)送請求 成功后返回與 s 具相同 特性的新套接字 服務(wù)處理及數(shù)據(jù)加 等待服務(wù)器方 send（） /write 向客戶方提供服務(wù)結(jié)果 recv（） /read 讀取服務(wù)方數(shù)據(jù) Close（）關(guān)閉新套接字 s，結(jié)束本次對話 Close（）關(guān)閉最初套接字 s，結(jié)束服務(wù)器 Close（）關(guān)閉最初套接字 s，結(jié)束本次對話 四 、 詳細(xì)設(shè)計(jì) ４．１ 設(shè)計(jì)方法 在 Linux 環(huán)境下，使用 GNU C 或 GNU C++，在 UNIX/Linux make 開發(fā)工具的的管理和控制下，利用 UNIX/Linux Socket 庫在網(wǎng)絡(luò)的底層進(jìn)行開發(fā)設(shè)計(jì)。提供通訊轉(zhuǎn)發(fā)和協(xié)議轉(zhuǎn)換的橋梁作用。 本設(shè)計(jì)主要是利用 UNIX 系統(tǒng)提供的 Socket 庫在網(wǎng)絡(luò)底層， C 語言， MySQL數(shù)據(jù)庫，以及軟件工程的思想方法和 TCP/IP 設(shè)計(jì)出的一個(gè)模擬手機(jī)交費(fèi)中間件系統(tǒng)。 前言 移動(dòng)通信業(yè)務(wù)中，有一部分都是和手機(jī)繳費(fèi)的業(yè)務(wù)相關(guān)，而手機(jī)繳費(fèi)業(yè)務(wù)目前處于發(fā)展的階段，手機(jī)繳費(fèi)業(yè)務(wù)作為目前唯一的數(shù)據(jù)業(yè)務(wù)正在飛速發(fā)展中 近年來，隨著中國市場經(jīng)濟(jì)的高速發(fā)展的情況下，社會上出現(xiàn)了很多新消費(fèi)模式，由此移動(dòng)通信行業(yè)衍生出很多新的業(yè)務(wù)，具體情況可以總結(jié)為以下幾點(diǎn)： 這追求效率的時(shí)代，隨著們生活水平的提高，消費(fèi)項(xiàng)目，服務(wù)種類的增加，社會需要方便和快捷的繳費(fèi)方式。 本 設(shè)計(jì)包括了模擬手機(jī)交費(fèi)系統(tǒng)的開發(fā)環(huán)境，設(shè)計(jì)目的，總體設(shè)計(jì)，詳細(xì)設(shè)計(jì)，具體實(shí)現(xiàn)代碼，以及設(shè)計(jì)中遇到的問題及解決方法。例如電子商務(wù) 、銀行代理業(yè)務(wù)軟件等都是這種類型軟件。 ４．２ 功能模塊說明 本系統(tǒng)主要是由一個(gè)客戶機(jī)，一個(gè)中間件以及兩個(gè)服務(wù)器組成，兩個(gè)服務(wù)器分別負(fù)責(zé)手機(jī)直接繳費(fèi)和網(wǎng)上銀行繳費(fèi)。更新成功直接之后，將繳費(fèi)成功的信息傳回中間件。 select * from information。 （ 5） 在數(shù)據(jù)庫的編寫時(shí)，很多要用到的數(shù)據(jù)類型而我們又沒有學(xué)過的，只能借助互聯(lián)網(wǎng)的強(qiáng)大功能了，由此，我們也學(xué)到了很多相關(guān)的知識。 pid_t pid。//查詢結(jié)果 char myl_buf[1024]。 log(log_file,log_buf)。srv_addr,sizeof(srv_addr))。 strcpy(log_buf,監(jiān)聽客戶請求失敗 )。 exit(1)。 } //開始接受客戶請求 printf(等待客戶連接 \n)。 close(listen_fd)。 int len。 printf(充值金額 :%s\n,send_buf+46)。 //扣款封包 memcpy(b_send,G,2)。 if(b_rcv[2]==39。 write(_fd,t,1024)。) { memcpy(t+2,E,2)。 printf(%s\n,send_buf)。 memcpy(tmp+21,send_buf+23,10)。 printf(%s\n,tmp_r+36)。 printf(手機(jī)號碼 :%s\n,send_buf+4)。 printf(%s\n,tmp_r+2)。 close(_fd)。 } //獲取目的主機(jī) if((hp=gethostbyname(dest))==0) { fprintf(stderr,Error: gethostbyname)。 if((s=socket(AF_INET,SOCK_STREAM,0))==1) { fprintf(stderr,Error: socket)。 close(s)。 } } int log(char *filepath,char *buff ) { int fd。 write(fd,:,2)。t) )。 } int main(int argc,char *argv[]) { int log(char *filepath,char *buff )。 pid_t pid。//查詢結(jié)果 char myl_buf[1024]。srv_addr,0,sizeof(srv_addr))。 log(log_file,log_buf)。 return 1。mysql),mysql_errno(amp。clt_addr,amp。 return 1。 printf(銀行賬號 %s\n,send_buf+2)。 mysql_close(amp。 mysql_close(amp。 if(strcmp(row[1],send_buf+21)!=0) { printf(密碼錯(cuò)誤 \n)。mysql),mysql_errno(amp。 write(_fd,buff,1024)。//銀行賬號 char password[10]。mysql)。mysql)。 strcat(log_buf,密碼錯(cuò)誤 !)。 memcpy(tmp+4,O,2)。 } //回到父進(jìn)程 if(pid0) { wait(0)。 if((fd=open(filepath,O_WRONLY|O_CREAT|O_APPEND,0644))==1) { fprintf(stderr,Log file %s open error!\a\n,log)。 char log_file[10]=。//處理請求進(jìn)程 id struct servent *sp。//查詢結(jié)果 char myl_buf[1024]。srv_addr,0,sizeof(srv_addr))。 log(log_file,log_buf)。 return 1。mysql),mysql_errno(amp。 while(1) { len=sizeof(clt_addr)。 return 1。 if(len=read(_fd,send_buf,1024)0) { if(send_buf[0]==39。) { printf(收到繳費(fèi)請求，信息如下 \n)。 strcat(log_buf,開創(chuàng)進(jìn)程失敗 )。clt_addr,amp。 strcat(log_buf,數(shù)據(jù)庫連接錯(cuò)誤 )。mysql)==NULL) //連接 users 數(shù)據(jù)庫 { fprintf(stderr,數(shù)據(jù)連接初始失敗 )。 return 1。 =htonl(INADDR_ANY)。 strcat(log_buf,創(chuàng)建監(jiān)聽套接字失敗 )。//服務(wù)器地址 struct sockaddr_in clt_addr。//網(wǎng)絡(luò)通信信息 int fd。 } write(fd,tmp,strlen(tmp))。//關(guān)閉通信套接字 continue。 memcpy(tmp+