【正文】 getm(buf,rec)。 opdb(cmd,buf,1)。 } printf(Login\n)。 checkstat(rec[0][0])。 n=opdb(cmd,buf,1)。 if((write(ns,buf,sizeof(buf)))=0) { printf(Write socket wrong!\n)。39。 if((n=read(ns,buf,sizeof(buf)))=0) { printf(read wrong!\n)。 while(1) { n=0。 char cmd[128],buf[128]。 } if(pid!=0){ //parent proce, nothing to do, and to the next loop close(ns)。 close(s)。 } bzero(amp。 else { fprintf(stderr,NO service assigned!\nUsage:\n)。 opdb(cmd,NULL,0)。amp。 mysql_free_result(result)。)。 mysql_close(amp。 if(mysql_query(amp。 } printf(Init db successfully!\n)。}int opdb(char *cmd,char *p,int flag) //operate database{ MYSQL mysql。op))!=NULL) { p=tmp。 temp=(char *)malloc(strlen(buf))。insert into books values (4,book4,d,10)。use library。平時我們都習慣了使用Windows的編輯器，開始的時候由于UNIX的文檔編輯和Windows有著很大的區(qū)別，UNIX是全字符編輯器，所以在初期使用UNIX進行的編輯的時候有點不知道該從那下手，后來經(jīng)過學習知道在其編輯過程中我們可以使用終端通過命令來實現(xiàn)。//保存結果result=mysql_store_result(amp。drop database db/ table tbl。close()的調用格式如下：int close(int s)； MySQL數(shù)據(jù)庫在Unix的使用 軟件包需要1）MySql服務器2）MySql客戶端3）MySql開發(fā)接口庫 MySQL服務配置◆ mysqyld服務要運行起來。 【5】數(shù)據(jù)傳輸：send()/write與recv()/read() 當一個連接建立以后,就可以傳輸數(shù)據(jù)了。默認值為5. 【4】connect()，accept()這兩個系統(tǒng)調用用于完成一個完整相關的建立,其中connect()用于客戶建立連接?！?】綁定本地地址—bind()當一個套接字用socket()創(chuàng)建后,存在一個名字空間(地址族),但它沒有被命名，bind()將套接字地址(包括本地主機地址和本地端口地址)與所創(chuàng)建的套接字號綁定起來,即將名字賦予套接字,以指定本地半相關。客戶端或中間件方可以使用文本文件或數(shù)據(jù)庫，但在服務器方必須使MySql數(shù)據(jù)庫?？蛻舳说沫h(huán)境可以是Windows系統(tǒng)，也可以的Linux系統(tǒng)。交易型中間件是指用在不同行業(yè)、不同部門間的通訊轉發(fā)和協(xié)議轉換的軟件，在不同的行業(yè)、不同的系統(tǒng)間提供通訊轉發(fā)和協(xié)議轉換的橋梁作用。 本次設計的中間件是交易型中間件。該中間層既包括服務也包括請求中間件是一種獨立的系統(tǒng)軟件或服務程序，分布式應用軟件借助這種軟件在不同的技術之間共享資源。在中間件誕生之前，多采用傳統(tǒng)C/S二層結構。C/S模式在操作過程中采取的是主動請求方式。相連接的系統(tǒng)，即使它們具有不同的接口，但通過中間件相互之間仍能交換信息。本次設計的目的是掌握利用軟件工程的思想方法和TCP/IP設計出用于不同行業(yè)和部門間的通訊轉發(fā)或協(xié)議轉換軟件—中間件，尤其掌握這種設計的思想和方法。本設計的目的是使參與設計者掌握利用軟件工程的思想方法和TCP/IP設計出用于不同行業(yè)和部門間的通訊轉發(fā)或協(xié)議轉換軟件—中間件，尤其掌握這種設計的思想和方法。具體地是：接收客戶方數(shù)據(jù)；組織服務器方所需數(shù)據(jù)；重組服務方返回數(shù)據(jù)，并返回給客戶方；留跡；本地業(yè)務統(tǒng)計。Server_mserver_1……MiddleClient_2Client_1…… 中間件服務框圖serverClient_nClient_1…… c/s客戶/服務器模式框圖socket（）建立服務方套接字描述符為sSocket（）建立服務方套接字，描述符為sConnect（）建立服務方連接Send（）和write（）向服務方發(fā)送請求客戶方等待服務方Recv（）和read（）讀取服務方數(shù)據(jù)Close（）關閉最初套接字s，結束服務器服務Close（）關閉套接字ns，結束本次對話進行服務處理成功后返回與s具有相同特性的套接字accept（s）等待客戶方鏈接Listen（s）通知TCP，準備接受bind（s）綁定套接字與本地地址和端口recv（）和read（）通過ns讀取客戶方數(shù)據(jù)Send（）和writer（）向客戶方提供服務結果Close（）關閉套接字s，結束本次通話 程序設計類圖 開始登錄結束查詢用戶管理員 輸入密碼續(xù)借刪除添加借書還書顯示借閱信息 請求服務中間件數(shù)據(jù)庫服務器 和數(shù)據(jù)庫交換數(shù)據(jù) 程序設計流程圖四、詳細設計 【1】創(chuàng)建套接字—socket() 應用程序在使用套接字前,必須擁有一個套接字,系統(tǒng)調用socket()向應用程序提供創(chuàng)建套接字的手段。my_addr為本方地址數(shù)據(jù)結構。 在面向連接的協(xié)議中,該調用導致本地系統(tǒng)和外部系統(tǒng)之間連接實際建立。int recv(int s,void *buf,int len,int flags)。其常用法為：mysql [OPTIONS] [database] 常用參數(shù)有：?, help： 幫助D, database=DB_name： 指定數(shù)據(jù)庫h, host=Host_name： 指定主機u, user=DB_user_name： 指定用戶p[…], password[=…]： 指定密碼 客戶端命令行 命令行提示符下輸入：mysql 或 mysql –u root進入mysql系統(tǒng)。mysql)。 }mysql_free_result(result)。在仔細研究代碼后，我在管理員增加圖書的代碼后添加了break語句，成功的解決了錯誤。create table admi(id char(10) not null primary key,name char(50) not null,password char(15))。insert into books values (7,book7,g,7)。 strtok_r(temp,。 p=NULL。 int i,j,n=0。 mysql_close(amp。mysql)。 } n=mysql_num_rows(result)。imysql_num_fields(result)。 printf(opdb successfully!\n)。 if((opdb(cmd1,NULL,1)==0)amp。 struct servent *sp。 exit(1)。 if(bind(s,(struct sockaddr *)amp。 if((ns=accept(s,0,0))==1) { // wait a connection */ fprintf(stderr,error: accept)。 } if(pid==0){ // entered child proccedure close(s)。 char id[50],password[50]。 bzero(password,sizeof(password))。\039。: //update user info getm(buf,rec)。 case 39。 break。password=\%s\,rec[0][0],rec[0][1])。L39。 break。b_id=\%s\,rec[0][0],rec[0][1])。 } break。 } break。 opdb(cmd,writer,0)。 break。 opdb(cmd,buf,1)。R39。 checkstat(rec[0][0])。: getm(buf,rec)。 if(n=0){ printf(write error!\n)。amp。 buf[0]=39。 sprintf(cmd,select * from books where id=\%s\,rec[0][0])。 if(write(ns,buf,strlen(buf))=0) { printf(Write wrong!\n)。 opdb(cmd,buf,1)。D39。 } break。 int ss,spid。 sservice=argv[2]。 exit(5)。 close(s)。 } if((pid=fork())==1){ // conneted, and then create child proc fprintf(stderr,server: fork error!)。 exit(5)。 =sp1s_port。 while(1) { bzero(buf,sizeof(buf))。 exit(1)。 if(write(ns,buf,strlen(buf))!=strlen(buf)){ fprintf(stderr,Write socket ns error!\n)。//通用地址結構sockaddr struct servent *s