2015年6月22日月曜日

開発環境

Head First C ―頭とからだで覚えるCの基本(David Griffiths (著)、Dawn Griffiths (著) 中田 秀基(監訳)(翻訳)、木下 哲也 (翻訳)、オライリージャパン)の11章(ソケットとネットワーキング: 127.0.0.1という場所はない)、自分で考えてみよう(p.473)を解いてみる。

その他参考書籍

自分で考えてみよう(p.473)

コード(BBEdit, Emacs)

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>

int main(int argc, char **argv) {
  char *advice[] = {
    "食べる量を減らしなさい\r\n",
    "タイトなジーンズにしなさい。\r\n",
    "一言: 不適切\r\n",
    "今日だけは正直になりなさい。「本当に」思っていることを上司に言いなさい\r\n",
    "そのヘアスタイルは考え直したほうがいいでしょう\r\n"
  };
  int listener_d = socket(PF_INET, SOCK_STREAM, 0);

  struct sockaddr_in name;
  name.sin_family = PF_INET;
  name.sin_port = (in_port_t)htons(30000);
  name.sin_addr.s_addr = htonl(INADDR_ANY);
  bind(listener_d, (struct sockaddr *) &name, sizeof(name));
  listen(listener_d, 10);
  printf("接続を待っています\n");
  while (1) {
    struct sockaddr_storage client_addr;
    unsigned int address_size = sizeof(client_addr);
    int connect_d = accept(listener_d, (struct sockaddr *)&client_addr,
                           &address_size);
    char *msg = advice[rand() % 5];
    send(connect_d, msg, strlen(msg), 0);
    close(connect_d);
  }  
}
/* このプログラムはエラー処理を忘れている */

入出力結果(Terminal)

サーバー

$ crun.sh sample473
clang ...
接続を待っています
  C-c C-c
$  

クライアント

$ telnet 127.0.0.1 30000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
一言: 不適切
Connection closed by foreign host.
$ telnet 127.0.0.1 30000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
そのヘアスタイルは考え直したほうがいいでしょう
Connection closed by foreign host.
$ 

ZeroMQ (ZMQ) 版(REQ - REP(Request - Reply))

コード(BBEdit, Emacs)

サーバー

#include <zmq.h>
#include <stdlib.h>
#include <string.h>

int main() {
  char *advice[] = {
    "食べる量を減らしなさい",
    "タイトなジーンズにしなさい",
    "一言: 不適切",
    "今日だけは正直になりなさい。「本当に」思っていることを上司に言いなさい",
    "そのヘアスタイルは考え直したほうがいいでしょう"
  };  
  void *context = zmq_ctx_new();
  void *responder = zmq_socket(context, ZMQ_REP);  
  zmq_bind(responder, "tcp://*:30000");
  
  printf("接続を待っています\n");
  while (1) {
    zmq_msg_t request;
    zmq_msg_init(&request);
    zmq_msg_recv(&request, responder, 0);
    zmq_msg_close(&request);
    
    sleep(1);
    
    char *msg = advice[rand() % 5];
    zmq_msg_t reply;
    zmq_msg_init_size(&reply, strlen(msg));
    memcpy(zmq_msg_data (&reply), msg, strlen(msg));
    zmq_msg_send(&reply, responder, 0);
    zmq_msg_close(&reply);
  }
  zmq_close(responder);
  zmq_ctx_destroy(context);
}

クライアント

#include <stdio.h>
#include <stdlib.h>
#include <zmq.h>

int main() {
  void *context = zmq_ctx_new();
  void *requester = zmq_socket(context, ZMQ_REQ);
  zmq_connect(requester, "tcp://localhost:30000");

  zmq_msg_t request;
  zmq_msg_init_size(&request, 5);
  memcpy(zmq_msg_data(&request), "Hello", 5);
  zmq_msg_send(&request, requester, 0);
  zmq_msg_close(&request);
  
  zmq_msg_t message;  
  zmq_msg_init(&message);
  int size = zmq_msg_recv(&message, requester, 0);  
  char *string = malloc(size + 1);
  memcpy(string, zmq_msg_data(&message), size);
  zmq_msg_close(&message);
  string[size] = '\0';  
  printf("%s\n", string);
  free(string);
  zmq_close(requester);
  zmq_ctx_destroy(context);
}

入出力結果(Terminal)

サーバー

$ crun.sh sample473_zmq_server
clang ...
接続を待っています
  C-c C-c
$  

クライアント

$ crun.sh sample473_zmq_client
clang ...
今日だけは正直になりなさい。「本当に」思っていることを上司に言いなさい
$ ./sample473_zmq_client
今日だけは正直になりなさい。「本当に」思っていることを上司に言いなさい
$ ./sample473_zmq_client
食べる量を減らしなさい
$ ./sample473_zmq_client
一言: 不適切
$ ./sample473_zmq_client
そのヘアスタイルは考え直したほうがいいでしょう
$

0 コメント:

コメントを投稿