目次 1. DB 更新情報受信 SW 仕様書 構成および機能 全体の構成 DB 更新情報受信 SW の機能 ソフトウェアの設計仕様 DB 更新情報受信 SW の仕様 資料編... 5

Transcription

1 書類トレースシステム DigiTANAlog メインサーバマシン DB 更新情報受信 SW 仕様書 Create on 良知洋志 (RACHI, Hiroshi) Date: 2006/02/08 Last Update: 2006/02/15

2 目次 1. DB 更新情報受信 SW 仕様書 構成および機能 全体の構成 DB 更新情報受信 SW の機能 ソフトウェアの設計仕様 DB 更新情報受信 SW の仕様 資料編 資料 1. ソフトウェアのソースコード DB 更新情報受信 SW のソースコード

3 1. DB 更新情報受信 SW 仕様書 1-1. 構成および機能 書類トレースシステム DigiTANAlog ( 以下 本システム ) におけるメインサーバマシン上 で動作する DB 更新情報受信 SW の構成および機能を以下に記す 全体の構成メインサーバ上で動作している DB 更新情報受信 SW がトレース用端末 BookShelf ( 以下 BookShelf ) から情報を受信した際 その抜差し口番号およびカード ID 番号から同マシン上で動作している DB 更新 SW にアクセスするための URL を生成し それを HTTP リクエストとして同マシン上で動作している HTTP サーバへ送信することで データベースの更新を完了する DB 更新情報受信 SW の機能 DB 更新情報受信 SW は トレース用端末 BookShelf ( 以下 BookShelf ) から送信されたカード状態変化情報を受信し DB 更新 SW にアクセスするソフトウェアである DB 更新情報受信 SW はメインサーバマシン上で動作している メインサーバ上で動作している DB 更新情報受信 SW がトレース用端末 BookShelf ( 以下 BookShelf ) から情報を受信した際 その抜差し口番号およびカード ID 番号から同マシン上で動作している DB 更新 SW にアクセスするための URL を生成し それを HTTP リクエストとして同マシン上で動作している HTTP サーバへ送信する 情報受信の際には 通信プロトコルは TCP を ポート番号は 番を用いる BookShelf から送信される情報は まずは文字列であり バッファに格納されるため それを抜差し口番号およびカード ID 番号の数値に変換する この際の各番号は BookShelf 上の H8 マイコンですでにデータベースの仕様に合わせたものであるため 手を加えることを必要とせずに DB 更新 SW にアクセスするための URL を生成することが出来る 生成された URL をバッファに格納し HTTP リクエスト送信 関数にその文字列を渡すことで HTTP リクエストの送信を完了する プログラムの起動は 本システム構築時に行う なお 実行時にはコマンドプロンプトウィンドウが表示され 動作確認用に送信 URL と HTTP サーバからの応答が表示される - 2 -

4 1-2. ソフトウェアの設計仕様 本システムにおけるメインサーバマシン上で動作する DB 更新情報受信 SW の仕様を以下に記 す なお ソースコードは資料 1. を参照していただきたい DB 更新情報受信 SW の仕様 DB 更新情報受信 SW は トレース用端末 BookShelf ( 以下 BookShelf ) から送信されたカード状態変化情報を受信し DB 更新 SW にアクセスするソフトウェアである DB 更新情報受信 SW はメインサーバマシン上で動作している メインサーバ上で動作している DB 更新情報受信 SW がトレース用端末 BookShelf ( 以下 BookShelf ) から情報を受信した際 その抜差し口番号およびカード ID 番号から同マシン上で動作している DB 更新 SW にアクセスするための URL を生成し それを HTTP リクエストとして同マシン上で動作している HTTP サーバへ送信する BookShelf から送信される情報は BookShelf 上の H8 マイコンですでにデータベースの仕様に合わせたものであるため DB 更新情報受信 SW では受信した抜差し口番号およびカード ID 番号に手を加えることを必要とせずに DB 更新 SW にアクセスするための URL を生成することが出来る DB 更新情報受信 SW の流れ図は 以下の通りである 情報受信の際には 通信プロトコルは TCP を ポート番号は 番を用いる 受信した文字列から数値へと変換された抜差し口番号およびカード ID 番号より 以下の文字列にその数値を埋め込むことで 送信するべき HTTP リクエストの URL とする &book_id= 上記 URL の の箇所に抜差し口番号を の箇所にカード ID 番号をそれぞれ埋め込む - 3 -

5 生成された URL をバッファに格納し HTTP リクエスト送信 関数にその文字列を渡すこと で HTTP リクエストの送信を完了する HTTP リクエスト送信引数に URL 文字列を与えて実行する 引数として与えた文字列から スキーム名 サーバ名 取得するページのパス ポート番号 を取得し HTTP サーバにアクセスする HTTP リクエスト送信 関数は以下の引数と返り値を持つ int http_c(char * argv) 引数概要 char 型 addr char * argv HTTP リクエストとして送信する URL 文字列へのアドレス int 型 返り値送信成功したとき 0 失敗したとき-1 HTTP リクエスト送信 関数の流れ図は以下の通りである - 4 -

6 2. 資料編 2-1. 資料 1. ソフトウェアのソースコード 本システムにおけるメインサーバマシン上で動作する DB 更新情報受信 SW のソースコードを 以下に記す DB 更新情報受信 SW のソースコード 以下に DB 更新情報受信 SW のソースコードを掲載する #include <winsock2.h> #include <stdio.h> #include <string.h> #define BUFSIZE 256 /* バッファサイズ */ #define RECVSIZE 4096 /* 受信バッファサイズ */ int http_c(char * argv); int main(){ WSADATA wsadata; SOCKET sock0; struct sockaddr_in addr; struct sockaddr_in client; int len; SOCKET sock; BOOL yes = 1; char inbuf[2048]; int pos = 0; int id = 0; WSAStartup(MAKEWORD(2,0), &wsadata); sock0 = socket(af_inet, SOCK_STREAM, 0); addr.sin_family = AF_INET; addr.sin_port = htons(12345); addr.sin_addr.s_un.s_addr = INADDR_ANY; setsockopt(sock0, SOL_SOCKET, SO_REUSEADDR, (const char *)&yes, sizeof (yes)); bind(sock0, (struct sockaddr *)&addr, sizeof(addr)); listen(sock0, 5); while (1) { len = sizeof(client); sock = accept(sock0, (struct sockaddr *)&client, &len); recv(sock, inbuf, sizeof(inbuf), 0); sscanf(inbuf,"%d %d",&pos,&id); sprintf(inbuf," s,id); closesocket(sock); printf("%s n",inbuf); - 5 -

7 http_c(inbuf); if(inbuf[0] == '!') break; closesocket(sock0); WSACleanup(); return 0; int http_c(char * argv){ WORD wversionrequested; int nerrorstatus; WSADATA wsadata; char svname[bufsize]; /* サーバのドメイン名 */ char html[bufsize]; /* 取得するページのパス */ unsigned short port = 80; /* ポート番号 */ int soc; /* ソケット (Soket Descriptor) */ long serveraddr; /* サーバの IP アドレス */ struct hostent *serverhostent; /* サーバの情報を指すポインタ * / struct sockaddr_in serversockaddr; /* サーバのアドレス */ char sendbuf[bufsize]; /* 送信バッファ */ char recvbuf[recvsize]; /* 受信バッファ */ int buf_len; /* 受信したバイト数 */ char *p,*r,*t,wk[8]; /* 作業用領域 */ int i; /* */ /* 引数の URL からサーバ名とページのパスを取得する */ /* */ /* スキーム名を取得する */ for(i = 0;i < 7;i++){ wk[i] = argv[i]; wk[i] = ' 0'; if(strcmpi(wk," 0){ fprintf(stderr,"error: http の URL ではありません n"); /* サーバ名を取得する */ for(p = argv + i,r = svname;*p!= '/' && *p!= ' 0';p++,r++){ *r = *p; *r = ' 0'; /* 取得するページのパスを取得する */ for(r = html;*p!= ' 0';p++,r++){ *r = *p; *r = ' 0'; /* サーバ名 : ポートとなっている場合は分割する */ for(p = svname;*p!= ':' && *p!= ' 0';p++); - 6 -

8 if(*p == ':'){ for(t = p + 1,r = wk;*t!= ' 0';t++,r++){ *r = *t; *r = ' 0'; port = (unsigned short)atoi(wk); *p = ' 0'; /* ページの指定が無い場合は / ( ルート ) を設定する */ if(strcmp(html,"") == 0){ strcpy(html,"/"); /* */ /* 指定のサーバから指定のページを取得する */ /* */ /* WinSock の初期化を行う */ wversionrequested = MAKEWORD(1,1); /* バージョン 1.1 を要求する */ nerrorstatus = WSAStartup(wVersionRequested, &wsadata); if(atexit((void (*)(void))(wsacleanup))){ /* 終了時に WinSoc k のリソースを解放するようにしておく */ fprintf(stderr,"error: atexit(wsacleanup) 失敗 n"); if(nerrorstatus!= 0){ fprintf(stderr,"error: WinSock の初期化失敗 n"); /* soc にソケットを作成します */ soc = socket(pf_inet,sock_stream,0); if(soc == INVALID_SOCKET){ fprintf(stderr,"error: Socket 作成失敗 n"); /* svname にドットで区切った 10 進数の IP アドレスが入っている場合 serveraddr に 3 2bit 整数の IP アドレスが返ります */ serveraddr = inet_addr((char*)svname); if(serveraddr == -1) { /* サーバ名 (svname) からサーバの情報を取得します */ serverhostent = gethostbyname(svname); if(serverhostent == NULL) { fprintf(stderr,"error: ホストアドレス取得失敗 n"); /* ソケットを破棄する */ closesocket(soc); else{ /* サーバの情報から IP アドレスを serveraddr にコピーします */ serveraddr = *((unsigned long *)((serverhostent->h_addr_list) [0])); - 7 -

9 /* サーバのアドレスの構造体にサーバの IP アドレスとポート番号を設定します */ serversockaddr.sin_family = AF_INET; /* イン ターネットの場合 */ serversockaddr.sin_addr.s_addr = serveraddr; /* サ ーバの IP アドレス */ serversockaddr.sin_port = htons((unsigned short)port); /* ポート番号 */ memset(serversockaddr.sin_zero,(int)0,sizeof(serversockaddr.sin_zer o)); /* サーバへ接続します */ if(connect(soc,(struct sockaddr *)&serversockaddr,sizeof(serversockadd r)) == SOCKET_ERROR){ fprintf(stderr,"error: サーバへの接続失敗 n"); /* ソケットを破棄する */ closesocket(soc); /* サーバに GET リクエストを送信します */ /* 送信した文字列はサーバに届きます */ sprintf(sendbuf,"get %s HTTP/1.0 r nhost: %s:%d r nuser-agent: httpc/ 0.0 r n r n",html,svname,port); /* リクエストヘッダを作成する */ if(send(soc,sendbuf,strlen(sendbuf),0) == SOCKET_ERROR){ fprintf(stderr,"error: サーバへの送信失敗 n"); /* 送受信を無効にする */ shutdown(soc,2); /* ソケットを破棄する */ closesocket(soc); /* サーバからデータをすべて受信し終わるまで繰り返す */ while(1){ /* サーバからデータを受信します */ buf_len = recv(soc,recvbuf,recvsize - 1,0); if(buf_len == SOCKET_ERROR){ /* 受信失敗の場合 */ fprintf(stderr,"error: サーバからの受信失敗 n"); break; else if(buf_len == 0){ /* 受信終わり */ break; recvbuf[buf_len] = ' 0'; /* 受信バッファの後ろに NULL を付加する */ printf("%s",recvbuf); /* 標準出力する */ /* 送受信を無効にする */ shutdown(soc,2); /* ソケットを破棄する */ closesocket(soc); return 0; - 8 -