ソケットプログラミングの文字列判断

Question

ソケットで配列に入れた文字を判断し、同じならそれに対応した文字列を返すプログラムを作っています
エラーは起きてないのですが、文字が表示されません

有識者の方々、是非ともよろしくお願いいたします。

#include <stdio.h>  /* printf()、fprintf()に必要 */
#include <sys/socket.h> /* recv()、send()に必要 */
#include <unistd.h> /* close()に必要 */
#include <string.h>
#define N 11 // 読み込み行数の上限値
#define RCVBUFSIZE 32 /* 受信バッファのサイズ */

void DieWithError(char *errorMessage);  /* エラー処理関数 */

void HandleTCPClient(int clntSocket)
{
  char echoBuffer[RCVBUFSIZE];  /* エコー文字列のバッファ */
  int recvMsgSize;  /* 受信メッセージのサイズ */
  /* クライアントからの受信メッセージ */
  if ((recvMsgSize = recv(clntSocket, echoBuffer, RCVBUFSIZE, 0)) < 0)
    DieWithError("recv() failed");
char qes[]= "年齢" ;
char qes1[]= "性別" ;

char ans[]= "19";
char ans1[]= "men";


  /* 受信した文字列を送信し、転送が終了していなければ次を受信する */
  while (recvMsgSize > 0) /* ゼロは転送の終了を意味する */
  {     //文字列の判定と送信
    if(strcmp(echoBuffer, qes)== 0{
    }else  if(strcmp(echoBuffer, qes1)== 0){
    if (send(clntSocket, ans1, recvMsgSize, 0) != recvMsgSize)
      DieWithError("send() failed");
    }
    /* 受信するデータが残っていないか確認する */
    if ((recvMsgSize = recv(clntSocket, echoBuffer, RCVBUFSIZE, 0)) < 0)
      DieWithError("recv() failed");
  }

  close(clntSocket);  /* クライアントソケットをクローズする */
}

Comments

[otn]

どこまでの部分で、期待通りの動きをして、どこから期待通りでないのか、確認してはどうでしょうか？

[episteme]

↑せやね。ともかくechoBufferに入ってる文字列(?)をどこかでプリントしてはいかがかと。

[jimbe]

> send(clntSocket, ans1, recvMsgSize, 0)

第三パラメータは間違っていると思います。

Answer 1

windows/cygwin でやってみました。
クライアント側は送信後に同一ソケットから受信するならソケットをクローズ出来ません（※）ので、サーバの recv が 0 で戻ることはありません。
ですので、 recv が 0 を返すまで読み込んでから送信するというコードは期待した動作にはならないでしょう。

※ shutdown システムコールのことをすっかり忘れていました。 shutdown を使えば送信側だけを閉じることが出来ますので、クライアント側が送信後にそうすることが決まっていれば、サーバ側は『切断まで受信する』形で出来ます。

以下では '\0' を区切りとしています。

tcptest.c

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

void tcpclient(int port, char *message) {
  int sock = socket(AF_INET, SOCK_STREAM, 0);
  if(sock < 0) {
    perror("socket");
    return;
  }

  struct sockaddr_in addr;
  addr.sin_family = AF_INET;
  addr.sin_port = htons(port);
  addr.sin_addr.s_addr = inet_addr("127.0.0.1");

  connect(sock, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));

  if(send(sock, message, strlen(message)+1, 0) < 0) { //'\0'まで送る
    perror("send");
    close(sock);
    return;
  }

  char buf[256];
  int len;
  for(int i=0; (len=recv(sock, &buf[i], sizeof(buf)-i,0)) > 0; i+=len); //切断まで

  if(len < 0) {
    perror("recv");
    close(sock);
    return;
  }

  printf(buf);

  close(sock);
}

void reply(int sock, char *message) {
  if(send(sock, message, strlen(message)+1, 0) < 0) {
    perror("send");
  }
}

struct {
  char *request;
  char *response;
} DATA[] = {
    { "年齢", "19" },
    { "性別", "men" },
    { NULL, NULL } //EOD
};

void echo(int sock) {
  char buf[256];

  for(int i=0, len; (len=recv(sock, &buf[i], sizeof(buf)-i,0)) > 0; i+=len) {
    for(int j=0; j<len; j++) {
      if(buf[i+j] == '\0') { //'\0'まで受け取っていたら
        printf(buf);
        for(int i=0; DATA[i].request != NULL; i++) {
          if(strcmp(buf, DATA[i].request) == 0) {
            reply(sock, DATA[i].response);
            return;
          }
        }
        reply(sock, "(error)");
        return;
      }
    }
  }
  perror("recv");
}

void tcpserver(int port) {
  int ss = socket(AF_INET, SOCK_STREAM, 0);
  if(ss < 0) {
    perror("socket");
    return;
  }

  struct sockaddr_in addr;
  addr.sin_family = AF_INET;
  addr.sin_port = htons(port);
  addr.sin_addr.s_addr = INADDR_ANY;
  if(bind(ss, (struct sockaddr *)&addr, sizeof(addr)) < 0) {
    perror("bind");
    close(ss);
    return;
  }

  if(listen(ss, 10) < 0) {
    perror("listen");
    close(ss);
    return;
  }

  struct sockaddr_in caddr;
  socklen_t csize = sizeof(caddr);

//  while(1) {
    int sock = accept(ss, (struct sockaddr *)&caddr, &csize);
    if(sock < 0) {
      perror("accept");
      close(ss);
      return;
    }

    echo(sock);
    close(sock);
//  }

  close(ss);
}

#define PORT 12345

int main(int argc, char **argv) {
  if(argc >= 2) tcpclient(PORT, argv[1]);
  else tcpserver(PORT);

  return 0;
}

サーバ

F:\teratail_c\Debug>tcptest.exe
年齢
F:\teratail_c\Debug>tcptest.exe
性別
F:\teratail_c\Debug>tcptest.exe
あいう

クライアント

F:\teratail_c\Debug>tcptest.exe 年齢
19
F:\teratail_c\Debug>tcptest.exe 性別
men
F:\teratail_c\Debug>tcptest.exe あいう
(error)