C - ソケットとネットワーキング(複数のクライアントの同時接続、プロセスをfork)

Head First C ―頭とからだで覚えるCの基本
(オライリージャパン)
David Griffiths (著) Dawn Griffiths (著)
中田 秀基(監訳)(翻訳) 木下 哲也 (翻訳)

開発環境

• OS X Mavericks - Apple(OS)
• Emacs (CUI)、BBEdit - Bare Bones Software, Inc. (GUI) (Text Editor)
• C (プログラミング言語)
• Clang (コンパイラ)

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

その他参考書籍

• プログラミング言語C 第2版 ANSI規格準拠 (B.W. カーニハン D.M. リッチー (著)、 石田 晴久 (翻訳)、共立出版)
• プログラミング言語Cアンサー・ブック 第2版 (クロビス・L．トンド、スコット・E．ギンペル(著)、矢吹 道郎(翻訳))
• C実践プログラミング 第3版 (Steve Oualline (著)、 望月 康司 (監訳) (翻訳)、 谷口 功 (翻訳)、 オライリージャパン)

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

コード(BBEdit, Emacs)

sample480.c

#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <sys/socket.h>
#include <string.h>
#include <unistd.h>
#include "header.h"

/* 修正箇所有り */
int read_in(int socket, char *buf, int len)
{
    char *s = buf;
    int slen = len;
    int c = recv(socket, s, slen, 0);
    while ((c > 0) && (s[c-1] != '\n')) {
        s += c;
        slen -= c;
        c = recv(socket, s, slen, 0);
    }
    if (c < 0) {
        return c;
    } else if (c == 0) {
        buf[0] = '\0';
    } else {
        /* c - 1ではなくc - 2に修正
         * s[c - 1] は'\n', s[c - 2] は'\r'
         */
        s[c - 2] = '\0';
    }
    return len - slen;
}

int main(int argc, char *argv[])
{
    if (catch_signal(SIGINT, handle_shudown) == -1) {
        fprintf(stderr, "ハンドラを設定できません。");
        exit (2);
    }
    listener_d = open_listener_socket();
    if (listener_d == -1) {
        error("ソケットを開けません。");
    }
    int reuse = 1;
    bind_to_port(listener_d, 30000);
    if (listen(listener_d, 10) == -1) {
        error("接続待ちできません");
    }
    puts("接続を待っています。");
    char buf[100];
    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);
        if (connect_d == -1) {
            error("第2のソケットを開けません。");
        }
        if (!fork()) {
            close(listener_d);
            if (say(connect_d, "Knock! Knock!\r\n") != -1) {
                read_in(connect_d, buf, sizeof(buf));
                if (strcmp("Who's there?", buf) != 0) {
                    say(connect_d, "「Who's there?」と入力してください。\r\n");
                } else {
                    if(say(connect_d, "Oscar\r\n") != -1) {
                        read_in(connect_d, buf, sizeof(buf));
                        if(strcmp("Oscar who?", buf) != 0) {
                            say(connect_d, "「Oscar who?」と入力してください。\r\n");
                        } else {
                            say(connect_d,
                                "oscar silly question, you get a silly answer.\r\n");
                        }
                    }
                }
            }
            close(connect_d);
            exit (0);
        }
        close(connect_d);
    }
    return (0);
}

Makefile

all: ikkp_server

ikkp_server: header.o ikkp_server.c
 cc -g -o ikkp_server ikkp_server.c header.o

header.o: header.c header.h
 cc -c header.c

clean:
 rm ikkp_server

サーバー

入出力結果(Terminal)

$ make && ./ikkp_server
cc -g -o ikkp_server ikkp_server.c header.o
接続を待っています。
^Cさようなら！
$

クライアント1

入出力結果(Terminal)

$ telnet 127.0.0.1 30000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Knock! Knock!
Who's there?
Oscar
Oscar who?
oscar silly question, you get a silly answer.
Connection closed by foreign host.
$

クライアント2

入出力結果(Terminal)

$ telnet 127.0.0.1 30000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Knock! Knock!
Who's there?
Oscar
Oscar who?
oscar silly question, you get a silly answer.
Connection closed by foreign host.
$

記念に撮ってみた。