ローカルホスト間での計算機通信をしたい（Linax）

Question

C言語でLinax上で計算機間のチャット幼なものを作りたいです。一度だけ送信できるコードをwhile文で回して一方的に送り続けるものは作れたのですが、交互に送りあうチャットのようなものを作ろうとした際、1回目に受け取った側が初めて送るときのconnect関数でエラーが出ます。(Connection refused)以下がそのコードです。解決方法が知りたいです。

//server(初めに受け取る方)
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <unistd.h>
#include <strings.h>

#define SERVICE_PORT 3500
#define SERVICE_PORT1 2999
#define BUF_LEN  1024 

int main(int argc, char **argv) {
  struct hostent *host;
  struct sockaddr_in okuserver,ukeserver, client;
  int soc, soc1,soc2,string_length, oku_data_length;
  socklen_t uke_data_size;
  char buf[BUF_LEN];
  int f = 1;

  host = gethostbyname("localhost");

  while(1){
    bzero((char *)&ukeserver, sizeof(ukeserver));//client->server(recv)
    ukeserver.sin_family=AF_INET;
    ukeserver.sin_port=htons(SERVICE_PORT);
    ukeserver.sin_addr.s_addr = INADDR_ANY;
    soc1=socket(AF_INET,SOCK_STREAM,0);
    if(bind(soc1,(struct sockaddr *)&ukeserver,sizeof(ukeserver))==-1){
      perror("bind");        exit(-1);    }
    if(listen(soc1,5)==-1){
      perror("listen");            exit(-1);        }
    uke_data_size=sizeof(client);
    if(f == 1){
      printf("Waiting for connection request.\n");
      f = 0;
    }

    if((soc2=accept(soc1,(struct sockaddr *)&client,&uke_data_size))<0){
      perror("accept");	exit(-1);        }
    string_length=read(soc2,buf,BUF_LEN);
    write(1,"From client:",12);
    write(1,buf,string_length);
    write(soc2,buf,string_length);
    if(string_length == 1){
      break;
    }
    close(soc2);    close(soc1);//recv end

    bzero((char *)&okuserver, sizeof(okuserver));//server->client(send)
    okuserver.sin_family=AF_INET;
    okuserver.sin_port=htons(SERVICE_PORT1);
    bcopy((char *)host->h_addr,(char *)&okuserver.sin_addr,host->h_length);
    oku_data_length=sizeof(okuserver);
    soc=socket(AF_INET,SOCK_STREAM,0);

    printf("1\n");
    if(connect(soc,(struct sockaddr *)&okuserver,oku_data_length)<0){
      perror("connect");
      exit(-1);
    }
    printf("2\n");
    bzero(buf,BUF_LEN);
    printf("server:");
    fflush(stdout);
    string_length=read(0,buf,BUF_LEN);
    write(soc,buf,string_length);
    string_length=read(soc,buf,BUF_LEN);
    if(string_length == 1){
      break;
    }
    close(soc);//send end


  }
  return(0);
}



//client(初めに送る方)
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <unistd.h>
#include <strings.h>


#define SERVICE_PORT 3500
#define SERVICE_PORT1 2999
#define BUF_LEN 1024

int main(int argc,char **argv)
{
  struct hostent *host;
  struct sockaddr_in okuserver,ukeserver,  client;
  int soc,soc1, soc2, oku_data_length,string_length;
  socklen_t uke_data_size;
  char buf[BUF_LEN];

  if(argc<2) {
    printf("Usage: %s server_name\n",argv[0]);        
    exit(-1);    
  }
  if((host=gethostbyname(argv[1]))==NULL){
    perror("gethostbyname");        
    exit(-1);           
  }  
  while(1){ 
    bzero((char *)&okuserver, sizeof(okuserver));//client->server(send)
    okuserver.sin_family=AF_INET;
    okuserver.sin_port=htons(SERVICE_PORT);
    bcopy((char *)host->h_addr,(char *)&okuserver.sin_addr,host->h_length);
    oku_data_length=sizeof(okuserver);

    soc=socket(AF_INET,SOCK_STREAM,0);



    if(connect(soc,(struct sockaddr *)&okuserver,oku_data_length)<0){//一度目のここでエラーが出る
      perror("connect");        
      exit(-1);
    }



    bzero(buf,BUF_LEN);
    printf("client:");
    fflush(stdout);
    string_length=read(0,buf,BUF_LEN);
    write(soc,buf,string_length);
    string_length=read(soc,buf,BUF_LEN);
    if(string_length == 1){
      break;
    }
    close(soc);//send end

    bzero((char *)&ukeserver, sizeof(ukeserver));//server->client(recv)
    ukeserver.sin_family=AF_INET;//
    ukeserver.sin_port=htons(SERVICE_PORT1);
    ukeserver.sin_addr.s_addr = INADDR_ANY;
    soc1=socket(AF_INET,SOCK_STREAM,0);
    if(bind(soc1,(struct sockaddr *)&ukeserver,sizeof(ukeserver))==-1){
      perror("bind");        exit(-1);    }
    if(listen(soc1,5)==-1){
      perror("listen");            exit(-1);        }
    uke_data_size=sizeof(client);

    if((soc2=accept(soc1,(struct sockaddr *)&client,&uke_data_size))<0){
      perror("accept");	exit(-1);        }
    string_length=read(soc2,buf,BUF_LEN);
    write(1,"From server:",12);
    write(1,buf,string_length);
    write(soc2,buf,string_length);
    if(string_length == 1){
      break;
    }
    close(soc2);    close(soc1);//recv end




  }
  return(0);
}

Comments

[y_waiwai]

エラーが出たなら、エラーメッセージを提示しましょう
エラーメッセージは、いらぬ翻訳省略しないで、出たそのママをコピペで提示してください

[dodox86]

どちらもクライアントでありサーバーにもなる（ことを目指している？）ようなコードですが、一般的にはこうは造らないですし、かなり無理・無茶しているかんじがします。C言語でのTCPの一般的なクライアント、サーバーのプログラムを学んでからの方が良いのでは。

[raiboz1115]

エラーメッセージは、質問文にも書いてある通り、Connection refusedのみです。perrorで出力されているものだと思います。
dodox86さん、意図をくみ取ってくださり、ありがとうございます。
ごり押ししてるのは承知済みですが、基礎がわからないので動けばいいかなという感じです。
このコードでは数か所かえるだけで起動しませんかね？

[jimbe]

ソケットは双方向の通信路ですので、送受信を 1 つのソケットで出来ます。
それだけでもコードが大分変わるのではないでしょうか。

[thkana]

一応(かどうか)ここはITエンジニア特化型のQ&Aサイトということなので...

> 基礎がわからないので動けばいいかな
これはエンジニア的には禁じ手ですね。絶体絶命でそういうケースが起こってしまうのはともかく、単に基礎を調べるのが面倒だから、で持ち出してよい手段ではないと思います。

で。
なぜそのようなものを作りたいのですか?
なにかの学習・練習であるなら、基礎を無視したものを作ってもメリットがないでしょうし、
何らかの実用に供したいなら、Cで苦労していないで他の(ソケットがきれいにラップされた)言語で作ったほうがよいと思いますが。

Answer 1

折角ご提示頂いているコードですが、動くように思われませんでしたので、コピペの材料のみとさせて頂いて以下のコードを構成してみました。
パラメータ無しでサーバモード(受信先行)、ホスト名を指定するとクライアントモード(送信先行) です。
慣れない windows/cygwin 環境で作りましたで NULL の定義が有ったりしますが、そこは無視でお願いします。

参考になれば・・・と思いましたが、「基礎がわからないので」と明言されますと難しいかもしれませんね・・・。

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <unistd.h>
#include <string.h>

#define SERVICE_PORT 3500
#define BUF_LEN  1024
#define STDOUT 1

#ifndef NULL
#define NULL (void*)0
#endif

int clientConnection(char *serverName) {
  struct hostent *host;
  if ((host = gethostbyname(serverName)) == NULL) {
    perror("gethostbyname");
    exit(-1);
  }

  int s = socket(AF_INET, SOCK_STREAM, 0);

  struct sockaddr_in server;
  bzero((char*) &server, sizeof(server)); //client->server(send)
  server.sin_family = AF_INET;
  server.sin_port = htons(SERVICE_PORT);
  bcopy((char*) host->h_addr,(char *)&server.sin_addr,host->h_length);
  int size = sizeof(server);
  if (connect(s, (struct sockaddr*) &server, size) < 0) {
    perror("connect");
    exit(-1);
  }

  return s;
}

int serverConnection() {

  int ss = socket(AF_INET, SOCK_STREAM, 0);

  struct sockaddr_in server;
  bzero((char*) &server, sizeof(server)); //client->server(recv)
  server.sin_family = AF_INET;
  server.sin_port = htons(SERVICE_PORT);
  server.sin_addr.s_addr = INADDR_ANY;
  if (bind(ss, (struct sockaddr*) &server, sizeof(server)) == -1) {
    perror("bind");
    close(ss);
    exit(-1);
  }

  if (listen(ss, 5) == -1) {
    perror("listen");
    close(ss);
    exit(-1);
  }

  printf("Waiting for connection request.\n");
  int s;
  struct sockaddr_in client;
  int size = sizeof(client);
  if ((s = accept(ss, (struct sockaddr*) &client, &size)) < 0) {
    perror("accept");
    close(ss);
    exit(-1);
  }

  close(ss);
  return s;
}

int writemsg(int fd, const char *msg) {
  return write(fd, msg, strlen(msg));
}
/** 改行までを読み込み(改行は付いたまま) */
int readmsg(int fd, char *buf, int size) {
  int index = 0;
  do {
    if(index >= size-1) return 0; //overflow
    int n = read(fd, &buf[index], size-index-1);
    if(n < 0) {
      perror("read");
      return 0;
    }
    index += n;
  } while(buf[index-1] != '\n');
  buf[index] = '\0';
  return index;
}

const char* prestr[] = { "client:", "server:" };

int main(int argc, char **argv) {
  //パラメータ解析
  opterr = 0; //getoptエラー表示 抑制
  int opt, help=0;
  while ((opt = getopt(argc, argv, "h")) != -1) {
    switch (opt) {
      case 'h':
      default:
        help = !0;
    }
  }
  char *hostname = (optind < argc ? argv[optind++] : NULL);
  if(help || optind < argc) {
    printf("Usage: %s [-h] [server_name]\n", argv[0]);
    exit(-1);
  }

  int s = (hostname == NULL ? serverConnection() : clientConnection(hostname));
  int initMode = (hostname == NULL ? 1 : 0); //1=サーバ:受信, 0=クライアント:送信

  char buf[BUF_LEN];
  //mode を切り替えることで送信/受信を交互に繰り返す
  for (int mode=initMode; ; mode ^= 1) {
    if(mode) {
      //受信
      if(readmsg(s, buf, BUF_LEN) == 0) break;
      writemsg(STDOUT, prestr[initMode^1]);
      writemsg(STDOUT, buf);
    } else {
      //送信
      writemsg(STDOUT, prestr[initMode]);
      if(fgets(buf, BUF_LEN, stdin) == NULL) break;
      writemsg(s, buf);
    }
  }

  close(s); //recv end

  return (0);
}