【導(dǎo)讀】化知識(shí)，還需要把所學(xué)到的知識(shí)合理的運(yùn)用到現(xiàn)實(shí)生活中來(lái)。科學(xué)技術(shù)是第一生。也給帶給了我們各種各樣的不同類(lèi)型和不同層次的科技的領(lǐng)先發(fā)展的成果。在中間件誕生之前，多采用傳統(tǒng)C/S二層結(jié)構(gòu)。件技術(shù)發(fā)展的一大進(jìn)步。一般而言，服務(wù)器是一個(gè)進(jìn)程，它等待客戶(hù)機(jī)與其聯(lián)系，提出某種類(lèi)型的服務(wù)要求。C/S模式在操作過(guò)程中采取的是主動(dòng)請(qǐng)求方式。服務(wù)對(duì)客戶(hù)機(jī)服務(wù)可將結(jié)果?；蛐畔⒎祷亟o客戶(hù)機(jī)(雙向)，也可不返回(單向)。的現(xiàn)象，并且拓展性也較差，無(wú)法跨越不同的業(yè)務(wù)部門(mén)和業(yè)務(wù)系統(tǒng)。在技術(shù)上有難度，更重要的是在制度和安全方面。所謂三層結(jié)構(gòu)，就是在原有的兩層結(jié)構(gòu)之間，增加一個(gè)中間層。即使它們具有不同的接口，但通過(guò)中間件相互之間仍能交換信息。C/S應(yīng)用程序中負(fù)責(zé)尋找數(shù)據(jù)的部分只需訪(fǎng)問(wèn)一個(gè)中。重組答復(fù)信息，最后將結(jié)果送回應(yīng)用程序的任務(wù)。本次設(shè)計(jì)的中間件是交易型中間件。發(fā)和協(xié)議轉(zhuǎn)換的橋梁作用。本次設(shè)計(jì)不是基于WEB的，不需要很多與WEB開(kāi)發(fā)

　　

【正文】 opdb(cmd,buf,1)。 printf(buf=%s\n,buf)。 n=write(ns,buf,strlen(buf))。 if(n=0) { printf(write error!\n)。 break。 } printf(send n=%d\n,n)。 break。 case 39。R39。: getm(buf,rec)。 sprintf(cmd,delete from borrow where 30 r_id=\%s\amp。amp。b_id=\%s\,rec[0][0],rec[0][1])。 opdb(cmd,buf,0)。 sprintf(cmd,update books set storage=storage+1 where id=\%s\,rec[0][1])。 opdb(cmd,buf,0)。 checkstat(rec[0][0])。 buf[0]=39。039。 if(write(ns,buf,strlen(buf))=0){ printf(Write wrong!\n)。 exit(1)。 } break。 case 39。m39。: getm(buf,rec)。 printf(One moretime request!\n)。 sprintf(cmd,select ,date_add(,interval 30 day), from borrow,books where =amp。amp。=\%s\,rec[0][0])。 opdb(cmd,buf,1)。 printf(buf=%s\n,buf)。 n=write(ns,buf,strlen(buf))。 if(n=0){ printf(write error!\n)。 break。 } printf(send n=%d\n,n)。 break。 case 39。M39。: getm(buf,rec)。 sprintf(cmd,update borrow set status=\0\ where r_id=\%s\amp。amp。b_id=\%s\,rec[0][0],rec[0][1])。 opdb(cmd,buf,0)。 sprintf(cmd,update borrow set b_date=date_add(b_date,interval 30 day) where r_id=\%s\amp。amp。b_id=\%s\,rec[0][0],rec[0][1])。 opdb(cmd,buf,0)。 checkstat(rec[0][0])。 buf[0]=39。039。 if(write(ns,buf,strlen(buf))=0){ printf(Write wrong!\n)。 exit(1)。 } break。 case 39。a39。: getm(buf,rec)。 sprintf(cmd,select * from books where id=\%s\,rec[0][0])。 if(opdb(cmd,buf,1)!=0) { 31 if(write(ns,buf,strlen(buf))=0) { printf(Write wrong!\n)。 break。 } break。 } sprintf(cmd,insert into books values (\%s\,\%s\,\%s\,\%s\),rec[0][0],rec[0][1],rec[0][2],rec[0][3])。 opdb(cmd,buf,0)。 buf[0]=39。039。 if(write(ns,buf,strlen(buf))=0) { printf(Write wrong!\n)。 exit(1)。 } break。 case 39。d39。: getm(buf,rec)。 printf(One del request!\n)。 sprintf(cmd,select * from books)。 opdb(cmd,buf,1)。 n=write(ns,buf,strlen(buf))。 if(n=0){ printf(write error!\n)。 break。 } printf(buf=%s\n,buf)。 printf(send n=%d\n,n)。 break。 case 39。D39。: getm(buf,rec)。 sprintf(cmd,delete from books where id=\%s\,rec[0][0])。 opdb(cmd,buf,0)。 buf[0]=39。039。 if(write(ns,buf,strlen(buf))=0) { printf(Write wrong!\n)。 break。 } break。 default: break。 } } } 32 close(ns)。 exit(0)。 } } } 中間件程序 include include include include sys/ include sys/ include i/ include define rec_length 20 main(int argc, char **argv ) { // structure defined for request as a client struct hostent *hp1。 struct sockaddr_in sin1。 struct servent *sp1。 char sbuf[128]。 int ss,spid。 char *sservice,*sdest。 // structure defined for request as a server struct sockaddr_in sin。 struct servent *sp。 int s,ns,pid,n。 char buf[128]。 char *service。 // test the environment parameter: lservice, dservice, server_name if(argc==4){ service=argv[1]。 sservice=argv[2]。 sdest=argv[3]。 } else { fprintf(stderr,Parameter assigned Error!\nUsage:\n)。 fprintf(stderr,\t%s lservice dservice server_name!\n,argv[0])。 fprintf(stderr,Note: server_name is defined in file /etc/hosts\n)。 fprintf(stderr,and: lservice dservice are defined in file /etc/services\n)。 exit(1)。 } if((sp=getservbyname(service,tcp))==NULL){ fprintf(stderr,Error: getservbyname)。 exit(5)。 } 33 if((s=socket(AF_INET,S