【正文】 exit(1)。 char *service。 struct servent *sp1。 if(write(ns,buf,strlen(buf))=0) { printf(Write wrong!\n)。 break。 printf(One del request!\n)。 buf[0]=39。a39。 opdb(cmd,buf,0)。: getm(buf,rec)。 printf(buf=%s\n,buf)。 case 39。 sprintf(cmd,update books set storage=storage+1 where id=\%s\,rec[0][1])。 break。amp。 break。 bzero(cmd,sizeof(cmd))。 if((write(ns,buf,strlen(buf)))=0){ printf(Write socket error!\n)。 if((write(ns,buf,strlen(buf)))=0) { printf(Write socket error!\n)。 sprintf(cmd,select * from borrow where r_id=\%s\amp。 printf(reply:%s\n,buf)。 break。 sprintf(cmd,select * from reader where id =\%s\amp。 printf(Reply:%s\n,buf)。 break。) { switch(buf[0]) { case 39。 break。 bzero(name,sizeof(name))。 char *info[3]。 wait(0)。 exit(6)。sin,sizeof(sin))。 fprintf(stderr,\t%s server_name!\n,argv[0])。 } printf(Check ok!\n)。r_id=\%s\,id)。 } mysql_close(amp。 strcat(buf,row[0])。mysql)。mysql,cmd)!=0) { printf(query database wrong!\n)。 if(!mysql_real_connect(amp。 MYSQL_RES *result。 while((tmp=strtok_r(p,amp。 strcpy(temp,buf)。 insert into books values (5,book5,e,9)。 create table books( id char(10) not null primary key, name char(50) not null, writer char(50), storage char(10) )。還有在數(shù)據(jù)庫的建立中，由于其基本程序中不帶有數(shù)據(jù)庫，一次我們必須自己建立一個(gè)數(shù)據(jù)庫來存儲(chǔ)信息，但是我們不知道怎樣在客戶端和主機(jī)程序中插入數(shù)據(jù)庫，以此來存儲(chǔ)圖書信息，在指導(dǎo)老師和同學(xué)的幫助下，還有借助網(wǎng)絡(luò)查了一些資料后終于解決了這一問題 ， 等等。mysql)。 select … from tbl … where … insert … into tbl … values … update … tbl … set … where … delete … from tbl … where … MySQL 開發(fā)接口 不同版本的 MySql有不同的目錄設(shè)置。最好是設(shè)為開機(jī)自動(dòng)啟動(dòng)。常用的系統(tǒng)調(diào)用有 send()和 recv()。 accept()用于使服務(wù)器等待來自某客戶進(jìn)程的實(shí)際連接。其調(diào)用格式 如下 : include sys/ int bind(int sockfd,const struct sockaddr *my_addr, int addrlen)。 三、總體設(shè)計(jì) 程序設(shè)計(jì)組成框圖 設(shè)計(jì)過程中借助了中間件來實(shí)現(xiàn)主機(jī)和客戶機(jī)之間的鏈接，它的工作機(jī)制是：當(dāng) 客戶端上的應(yīng)用程序需要從網(wǎng)絡(luò)中某個(gè)節(jié)點(diǎn)處獲取一定的數(shù)據(jù)或服務(wù)時(shí)，這些數(shù)據(jù)和服務(wù)可能處于一個(gè)運(yùn)行著和客戶端不同的硬、軟件、網(wǎng)絡(luò)或操作系統(tǒng)的平臺(tái)上。 （ 2） 中間件 中間件程序命名為 middle，要帶有三個(gè)參數(shù)，一個(gè)是用于服務(wù)器的服務(wù)（名字，與客戶端同），第二個(gè)作為請求的服務(wù)（自己定義，并保存在 /etc/services 中，要區(qū)別于客戶端，比如 mysvr2 5679），第三個(gè)為目的主機(jī)（定義在 /etc/hosts 內(nèi)），缺省時(shí)為本機(jī)。例如電子商務(wù)、銀行代理業(yè)務(wù)軟件等都是這種類型的軟件。交易型中間件是指用在不同行業(yè)、不同部門間的通訊轉(zhuǎn)發(fā)和協(xié)議轉(zhuǎn)換的軟件，在不同的行業(yè)、不同的系統(tǒng)間提供通訊轉(zhuǎn)發(fā)和協(xié)議轉(zhuǎn)換的橋梁作用。中間件位于客戶機(jī) / 服務(wù)器的操作系統(tǒng)之上，管理計(jì)算資源和網(wǎng)絡(luò)通訊 。這種二層結(jié)構(gòu)是計(jì)算機(jī)及軟件技術(shù)發(fā)展的一大進(jìn)步。一般而言，服務(wù)器是一個(gè)進(jìn)程，它等待客戶機(jī)與其聯(lián)系，提出某種類型的服務(wù)要求。是連接兩個(gè)獨(dú)立應(yīng)用程序或獨(dú)立系統(tǒng)的軟件。本次設(shè)計(jì)不是基于 WEB 的，不需要很多與 WEB 開發(fā)相關(guān)的知識(shí)，主要是利用 UNIX 系統(tǒng)提供的 Socket 庫在網(wǎng)絡(luò)底層，開發(fā)交易型中間件。本設(shè)計(jì)不是基于 WEB 的，不需要很多與 WEB 開發(fā)相關(guān)的知識(shí)，主要是利用 UNIX 系統(tǒng)提供的 Socket 庫在網(wǎng)絡(luò)底層，開發(fā)交易型中間件。 中間件要完成與客戶要求相符的功能：是本地的本地處理，否則發(fā)往服務(wù)器方。 C/S 應(yīng)用程序中負(fù)責(zé)尋找數(shù)據(jù)的部分只需訪問一個(gè)中間件系統(tǒng)，由中間件完成到網(wǎng)絡(luò)中找到數(shù)據(jù)源或服務(wù)，進(jìn)而實(shí)現(xiàn)傳輸客戶請求、重組答復(fù)信息，最后將結(jié)果送回應(yīng)用程序的任務(wù)。 說明： sockfd：為 socket 成功時(shí)的返回值 —套接字描述符。 7 ① connect 功能：客戶方調(diào)用發(fā)出的請求 用法： int connect(int sockfd,const structct sockaddr * server_addr, socklen_t addrlen)。send()調(diào)用用于在參數(shù) s 指定的已連接的數(shù)據(jù)報(bào)或流套接字上發(fā)送輸出數(shù)據(jù) ,格式如下 : int send(int s,void *buf,int len,int flags)。方法： ◆ chkconfig –level 2345 mysqld on ◆ ntsysv ◆ service mysqld start / stop /restart ◆ 圖形方式 MySQL 客戶端命令行工具 MySqyl客戶端命令行工具為 mysql。 ◆ 頭文件： 目錄： /usr/include/mysql 使用： include mysql/ 說明：必要時(shí)可使用 I 參數(shù) ◆ 庫文件： 9 靜態(tài)庫： /usr/lib/mysql/ 動(dòng)態(tài)庫： /usr/lib/mysql/ 使用參數(shù)： L/usr/lib/mysql lmysqlclient ◆ 初始化數(shù)據(jù)結(jié)構(gòu) mysql_init(amp。 ◆ 處理結(jié)果集 while((row=mysql_fetch_row(result))){ fprintf(stdout,%s|\t%s\n,row[0],row[2])。 在編寫好程序后，發(fā)現(xiàn)在 管理員增加圖書模塊，只能連續(xù)的增加圖書，不能退出該選項(xiàng)。 create table reader( id char(10) not null primary key, name char(50) not null, password char(15), enable char(2) default 1 )。 insert into books values (6,book6,f,4)。 p=temp。ip))!=NULL) { strcpy(result[i][j],tmp)。 MYSQL_ROW row。mysql,localhost,root,0,library,0,NULL,0)) { printf(Connect error!\n)。 mysql_close(amp。 return 1。 for(i=1。mysql)。 sprintf(cmd2,select * from borrow where r_id=\%s\,id)。 } main(int argc, char **argv ) { struct sockaddr_in sin。 fprintf(stderr,Note: server_name is defined in file /etc/services\n)。 =sps_port。 } while(1){ fprintf(stderr,\n\t\t\t Now wait connect ...\n)。 continue。 char name[50],writer[50]。 bzero(id,sizeof(id))。 } buf[n]=39。c39。 } break。 if((write(ns,buf,sizeof(buf)))=0){ 28 printf(Write socket wrong!\n)。amp。 case 39。 if((write(ns,buf,strlen(buf)))=0) { printf(Write socket error!\n)。amp。 break。 break。 sprintf(cmd,update books set storage=storage1 where id=\%s\,rec[0][1])。 } printf(Borrow successfully!\n)。=\%s\,rec[0][0])。 case 39。 opdb(cmd,buf,0)。m39。 n=write(ns,buf,strlen(buf))。 sprintf(cmd,update borrow set