今天我們來(lái)實(shí)現(xiàn)一個(gè)簡(jiǎn)單的小項(xiàng)目，在這個(gè)項(xiàng)目中，我們將實(shí)現(xiàn)一個(gè)終端版的簡(jiǎn)易Linux聊天室。  

實(shí)現(xiàn)的效果：服務(wù)器啟動(dòng)，監(jiān)測(cè)客戶(hù)端連接的個(gè)數(shù)，監(jiān)測(cè)每個(gè)客戶(hù)端的IP地址以及端口號(hào)，當(dāng)每個(gè)客戶(hù)端發(fā)送消息時(shí)，服務(wù)器上會(huì)有線程專(zhuān)門(mén)將每個(gè)客戶(hù)端發(fā)送的信息記錄在界面上，就類(lèi)似平時(shí)使用QQ群聊一樣。我們來(lái)看看這個(gè)簡(jiǎn)易的Linux聊天室如何來(lái)實(shí)現(xiàn)吧。如圖4-5-12所示。

1

2

3

1、實(shí)現(xiàn)一個(gè)基本的服務(wù)器和客戶(hù)端的步驟

一、創(chuàng)建服務(wù)器的流程

(1)調(diào)用socket函數(shù)創(chuàng)建一個(gè)套接口，并返回描述符。

(2)調(diào)用bind函數(shù)使服務(wù)器進(jìn)程與一個(gè)端口號(hào)綁定。

(3)調(diào)用listen設(shè)置客戶(hù)端如隊(duì)列的大小。

(4)調(diào)用accept接收一個(gè)連接，如果接入隊(duì)列不為空的話。并且相應(yīng)返回一個(gè)已連接的套接口描述符。

(5)調(diào)用send和recv用來(lái)在已連接的套接口間進(jìn)行發(fā)送和接收數(shù)據(jù)。

二、創(chuàng)建客戶(hù)端流程

(1)調(diào)用socket函數(shù)創(chuàng)建一個(gè)套接口，并返回描述符。

(2)調(diào)用connect向服務(wù)器發(fā)送連接請(qǐng)求，返回一個(gè)已連接的套接口。

(3)調(diào)用send和recv在已連接的套接口間發(fā)送和接收數(shù)據(jù)。

1.1服務(wù)器將要完成的工作

(1)獲取套接字

(2)設(shè)置端口復(fù)用

(3)綁定連接的IP還有端口號(hào)

(4)監(jiān)聽(tīng)

(5)創(chuàng)建一條線程用于顯示客戶(hù)端連接信息，具體連接的人數(shù)，順便將客戶(hù)連接的IP以及端口號(hào)打印出來(lái)。

(6)開(kāi)始接收

(7)創(chuàng)建一條線程用于將客戶(hù)端直接收發(fā)的信息分發(fā)到客戶(hù)端處進(jìn)行顯示。

下面具體看看服務(wù)器代碼的實(shí)現(xiàn) server.c

1#include <stdio.h>

  2#include <unistd.h>

  3#include <sys/socket.h>

  4#include <netinet/in.h>

  5#include <netinet/ip.h>

  6#include <string.h>

  7#include <pthread.h>

  8#include <sys/time.h>

  9//設(shè)置客戶(hù)端最大的個(gè)數(shù)為40個(gè)

 10#define   MAXCONNECTION        40

 11#define   msleep(x)     (usleep(x*1000))

 12struct  Data

 13{

 14    int  live ;   //0  無(wú)人用   1有人用

 15    int  sockfd ; 

 16    struct in_addr in ; 

 17    unsigned short  port ; 

 18};

 19

 20struct Data array[MAXCONNECTION] = {0} ; 

 21void *do_thread_showconnect(void *arg);

 22void *do_thread_clientopt(void *arg);

 23int main(void)

 24{

 25    int sockfd ; 

 26    //1.獲取套接字

 27    sockfd =  socket(AF_INET ,  SOCK_STREAM , 0);

 28    if(sockfd < 0)

 29    {

 30        perror("get socket fail");

 31        return -1 ; 

 32    }

 33    //2.設(shè)置端口復(fù)用

 34    int  on  = 4 ;  

 35    setsockopt(sockfd , SOL_SOCKET , SO_REUSEADDR , &on , sizeof(int));

 36    //3.綁定IP與端口

 37    struct  sockaddr_in  addr ; 

 38    addr.sin_family = AF_INET ; 

 39    addr.sin_port = htons(10086);

 40    //設(shè)置為INADDR_ANY，表示監(jiān)聽(tīng)所有的。

 41    addr.sin_addr.s_addr = INADDR_ANY ; 

 42    int ret ; 

 43    ret = bind(sockfd , (struct sockaddr *)&addr , sizeof(struct sockaddr_in)) ; 

 44    if(ret < 0)

 45    {

 46        perror("bind error");

 47        return  -2 ; 

 48    }

 49    //4.監(jiān)聽(tīng)

 50    listen(sockfd , 30);

 51    int  peersockfd ; 

 52    struct  sockaddr_in  peeraddr ; 

 53    socklen_t   len =   sizeof(struct sockaddr_in) ;    

 54    struct Data tmp ; 

 55    char *message = "too more connction , connect fail" ; 

 56    int i ; 

 57    pthread_t tid ; 

 58    //創(chuàng)建一條線程用于顯示已連接的客戶(hù)端的個(gè)數(shù)

 59    pthread_create(&tid , NULL , do_thread_showconnect , NULL);

 60    pthread_detach(tid);

 61

 62    while(1)

 63    {

 64        peersockfd = accept(sockfd , (struct sockaddr *)&peeraddr , &len);

 65        if(peersockfd < 0)

 66        {

 67            perror("accept fail");

 68            return  -3 ; 

 69        }

 70        tmp.sockfd = peersockfd ;   

 71        tmp.in = peeraddr.sin_addr ;

 72        tmp.port = ntohs(peeraddr.sin_port);    

 73        tmp.live = 1 ; 

 74

 75        for(i = 0 ; i < MAXCONNECTION ; i++)

 76        {

 77            if(array[i].live == 0)

 78            {

 79                array[i] = tmp ; 

 80                break;

 81            }

 82        }

 83        //判斷是否連接個(gè)數(shù)已滿(mǎn)

 84        if(i == MAXCONNECTION)

 85        {

 86            write(peersockfd , message , strlen(message));

 87            close(peersockfd);

 88            continue ; 

 89        }

 90        //創(chuàng)建一條線程用于顯示客戶(hù)端之間互相發(fā)送的即時(shí)信息

 91        pthread_create(&tid , NULL , do_thread_clientopt , (void *)i);

 92        pthread_detach(tid);

 93    }

 94

 95

 96    return 0 ; 

 97}

 98

 99//線程執(zhí)行函數(shù)，用于顯示已連接的客戶(hù)端的個(gè)數(shù)。

100void *do_thread_showconnect(void *arg)

101{

102    int  i , count = 0; 

103    while(1)    

104    {

105        system("clear");

106        printf("客戶(hù)端連接信息:  連接人數(shù):%d\n" , count);

107        count = 0 ; 

108        for(i = 0 ; i < MAXCONNECTION ; i++)

109        {

110            if(array[i].live == 1)

111            {

112                count++ ; 

113                printf("IP:%s   port:%d \n" , inet_ntoa(array[i].in) , array[i].port);

114            }

115        }

116        msleep(100);

117    }

118}

119//線程執(zhí)行函數(shù)，用于顯示客戶(hù)端之間互相發(fā)送的即時(shí)信息

120void *do_thread_clientopt(void *arg)

121{

122    //轉(zhuǎn)發(fā)信息

123    int num = (int)arg ;

124    char buffer[12240] = {0};

125    char tmp[10240] = {0}; 

126    int ret ; 

127    struct  timeval  tv ; 

128    struct  timezone tz ; 

129    struct  tm *tt ; 

130    int i ; 

131

132    while(1)

133    {

134        ret = read(array[num].sockfd , tmp , 1024);

135        if(ret <= 0)

136            break;

137        tmp[ret] = '\0'  ;

138        gettimeofday(&tv , &tz);

139        tt = localtime(&tv.tv_sec);

140        sprintf(buffer , "%s @ %d:%d:%d :\n%s" ,inet_ntoa(array[num].in) , tt->tm_hour , tt->tm_min , tt->tm_sec , tmp);

141

142        for(i = 0 ; i < MAXCONNECTION ; i++)

143        {

144            if(array[i].live == 1)

145            {

146                write(array[i].sockfd , buffer , strlen(buffer));

147            }

148        }

149    }

150    close(array[num].sockfd);

151    array[num].live = 0 ; 

152

153}

服務(wù)端的工作已經(jīng)設(shè)置完畢，顯示就開(kāi)始設(shè)置客戶(hù)端吧，客戶(hù)端就可以把它想象成我們的QQ群聊，只要每個(gè)人一發(fā)信息，那么整個(gè)群都可以看得到。

1

1.2客戶(hù)端將要完成的工作

(1)連接對(duì)應(yīng)的服務(wù)器，必須指定服務(wù)器的ip地址

(2)創(chuàng)建一條線程，用于讀取從服務(wù)器轉(zhuǎn)發(fā)過(guò)來(lái)的消息

(3)客戶(hù)端可以自由的輸入，通過(guò)服務(wù)器，發(fā)送給其它的客戶(hù)端，讓它們也可以看得到。

下面具體看看客戶(hù)端代碼的實(shí)現(xiàn) client.c

```c

 1#include <stdio.h>

 2#include <sys/socket.h>

 3#include <netinet/in.h>

 4#include <netinet/ip.h>

 5#include <pthread.h>

 6void *do_thread(void * arg);

 7int main(void)

 8{

 9    int sd ;    

10

11    sd = socket(AF_INET ,  SOCK_STREAM ,  0);

12    if(sd < 0)

13    {

14        perror("get socket  fail");

15        return -1 ;

16    }

17    //1.連接對(duì)應(yīng)的服務(wù)器

18    //connect

19    struct sockaddr_in   addr ; 

20    addr.sin_family = AF_INET ; 

21    addr.sin_port = htons(10086);

22    addr.sin_addr.s_addr  =  inet_addr("10.126.72.56");

23

24    int ret ; 

25    ret = connect(sd , (struct sockaddr *)&addr , sizeof(struct sockaddr_in));

26    if(ret != 0)

27    {

28        perror("connect fail");

29        return -3 ; 

30    }

31    printf("connect success ... \n");

32    pthread_t tid ; 

33    //創(chuàng)建一條線程用于接收從服務(wù)器端收到的數(shù)據(jù)

34    pthread_create(&tid , NULL , do_thread , (void *)sd);

35    pthread_detach(tid);

36

37    char buffer[1024] = {0}; 

38

39    while(1)

40    {

41        //阻塞從標(biāo)準(zhǔn)輸出讀取信息到buffer

42        ret = read(0 , buffer , 1024);  

43        if(ret > 1024)

44            continue ; 

45        //按下回車(chē)后將buffer中的內(nèi)容寫(xiě)到文件描述符

46        //通過(guò)服務(wù)器轉(zhuǎn)發(fā)給其它正在連接的客戶(hù)端

47        write(sd, buffer , ret);

48    }

49

50    return 0 ; 

51}

52void *do_thread(void * arg)

53{

54    int sd = (int)arg;

55    int ret ; 

56    char buffer[1024] = {0};

57    while(1)

58    {

59        //從服務(wù)器讀取數(shù)據(jù)并顯示在客戶(hù)端上

60        ret = read(sd , buffer , 1024);

61        if(ret <= 0)

62            break;

63        buffer[ret] = '\0' ; 

64        printf("recv:%s" , buffer);

65    }

66}

源碼編寫(xiě)完畢，接下來(lái)測(cè)試一下這個(gè)簡(jiǎn)單聊天室的功能：編譯過(guò)程省略，注意，該程序在32位操作系統(tǒng)上運(yùn)行，且要加上線程庫(kù)才可以編譯成功。分別編譯server.c和client.c

1gcc server.c  -o  server  -m32  -lpthread

2gcc client.c  -o  client  -m32  -lpthread

下面先運(yùn)行服務(wù)器，執(zhí)行./server如圖4-5-13所示。


下面啟動(dòng)不同IP的客戶(hù)端，找多一臺(tái)電腦即可測(cè)試。在我方47服務(wù)器上執(zhí)行客戶(hù)端./client，如圖4-5-14所示。客戶(hù)端連接成功了！  


接下來(lái)看看服務(wù)器上有什么變化，如圖4-5-15所示。


 在我方56服務(wù)器上執(zhí)行客戶(hù)端./client，如圖4-5-16所示。


接下來(lái)看看服務(wù)器上有什么變化，如圖4-5-17所示。


    在47服務(wù)器上的客戶(hù)端發(fā)送一條消息給56服務(wù)器上的客戶(hù)端，同樣的在56服務(wù)器上的客戶(hù)端也發(fā)送一條信息給47的服務(wù)器上的客戶(hù)端，觀察變化，如圖4-5-18所示。


    在這里我們看到，56服務(wù)器上的客戶(hù)端發(fā)送hello world的消息給47服務(wù)器上的客戶(hù)端，47服務(wù)器上的客戶(hù)端也收到了helloworld消息，同樣的，47服務(wù)器上的客戶(hù)端給56服務(wù)器上的客戶(hù)端發(fā)送I am 47 server的消息，56服務(wù)器上的客戶(hù)端也收到了I am 47 server的消息。這個(gè)簡(jiǎn)易版本的Linux聊天室就算完成了，接下來(lái)，請(qǐng)讀者發(fā)揮自己的想象力，結(jié)合VT100控制碼，寫(xiě)出一個(gè)更漂亮的終端版聊天工具吧。

VT100控制碼表

```c

 1具體格式有兩種，

 2?  一種數(shù)字形式，

 3\033[<數(shù)字>m .

 4如 \033[40m ，表示讓后面字符輸出用背景黑色輸出 \033[0m 表示取消前面的設(shè)置。

 5?  另一種是控制字符形式。

 6\033[K 清除從光標(biāo)到行尾的內(nèi)容

 7\033[nC 光標(biāo)右移 n 行

 8輸出時(shí), 也可以用 ^[來(lái)代替.

 9VT100  控制碼

10VT100 控制碼歸類(lèi)如下。

11\033[0m 關(guān)閉所有屬性 

12\033[1m 設(shè)置高亮度 

13\033[4m 下劃線 

14\033[5m 閃爍 

15\033[7m 反顯 

16\033[8m 消隱 

17\033[30m -- \033[37m 設(shè)置前景色 

18\033[40m -- \033[47m 設(shè)置背景色 

19\033[nA 光標(biāo)上移 n 行 

20\033[nB 光標(biāo)下移 n 行 

21\033[nC 光標(biāo)右移 n 行 

22\033[nD 光標(biāo)左移 n 行 

23\033[y;xH 設(shè)置光標(biāo)位置 

24\033[2J 清屏 

25\033[K 清除從光標(biāo)到行尾的內(nèi)容 

26\033[s 保存光標(biāo)位置 

27\033[u 恢復(fù)光標(biāo)位置 

28\033[?25l 隱藏光標(biāo) 

29\033[?25h 顯示光標(biāo)

30VT100   關(guān)于顏色的說(shuō)明:

31VT100 的顏色輸出分為，注意要同時(shí)輸出前景的字符顏色和背景顏色。

32字背景顏色范圍:40----49 

3340:黑 

3441:深紅 

3542:綠 

3643:黃色 

3744:藍(lán)色 

3845:紫色 

3946:深綠 

4047:白色 

41字顏色:30-----------39 

4230:黑 

4331:紅 

4432:綠 

4533:黃 

4634:藍(lán)色 

4735:紫色 

4836:深綠 

4937:白色

50這樣輸出一個(gè)字符串比較完整如下

51echo "\033[字背景顏色;字體顏色 m 字符串\033[0m"

52例：

53echo "\033[41;36m something here \033[0m"

1例如：

2C語(yǔ)言編程里可以這么用

3設(shè)置光標(biāo)位置 x=1 y=2

4printf("\033[%d;%dH\033[43m \033[0m" ,1, 2);