微信公眾號(hào)：嵌入式開發(fā)圈
關(guān)注可了解更多的教程。問題或建議，請(qǐng)公眾號(hào)留言;
如果你覺得本文對(duì)你有幫助，歡迎贊賞

▲長(zhǎng)按圖片保存可分享至朋友圈

簡(jiǎn)易Linux終端聊天室

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

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

一、創(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è)置客戶端如隊(duì)列的大小。

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

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

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

(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)聽

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

(6)開始接收

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

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

 1#include 
 2#include 
 3#include 
 4#include 
 5#include 
 6#include 
 7#include 
 8#include 
 9//設(shè)置客戶端最大的個(gè)數(shù)為40個(gè)
 10#define   MAXCONNECTION        40
 11#define   msleep(x)     (usleep(x*1000))
 12struct  Data
 13{
 14    int  live ;   //0  無人用   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)聽所有的。
 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)聽
 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)建一條線程用于顯示已連接的客戶端的個(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ù)已滿
 84        if(i == MAXCONNECTION)
 85        {
 86            write(peersockfd , message , strlen(message));
 87            close(peersockfd);
 88            continue ; 
 89        }
 90        //創(chuàng)建一條線程用于顯示客戶端之間互相發(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ù)，用于顯示已連接的客戶端的個(gè)數(shù)。
100void *do_thread_showconnect(void *arg)
101{
102    int  i , count = 0; 
103    while(1)    
104    {
105        system("clear");
106        printf("客戶端連接信息:  連接人數(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ù)，用于顯示客戶端之間互相發(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è)置完畢，顯示就開始設(shè)置客戶端吧，客戶端就可以把它想象成我們的QQ群聊，只要每個(gè)人一發(fā)信息，那么整個(gè)群都可以看得到。

1.2客戶端將要完成的工作

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

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

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

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

 1#include 
 2#include 
 3#include 
 4#include 
 5#include 
 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        //按下回車后將buffer中的內(nèi)容寫到文件描述符
46        //通過服務(wù)器轉(zhuǎn)發(fā)給其它正在連接的客戶端
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ù)并顯示在客戶端上
60        ret = read(sd , buffer , 1024);
61        if(ret <= 0)
62            break;
63        buffer[ret] = '\0' ; 
64        printf("recv:%s" , buffer);
65    }
66}

源碼編寫完畢，接下來測(cè)試一下這個(gè)簡(jiǎn)單聊天室的功能：編譯過程省略，注意，該程序在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的客戶端，找多一臺(tái)電腦即可測(cè)試。在我方47服務(wù)器上執(zhí)行客戶端./client，如圖4-5-14所示?？蛻舳诉B接成功了！  

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

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

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

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

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

VT100控制碼表

 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í), 也可以用 ^[來代替.
 9VT100  控制碼
10VT100 控制碼歸類如下。
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)于顏色的說明:
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);

下一節(jié)，我將帶領(lǐng)大家使用VT100控制碼來實(shí)現(xiàn)一個(gè)好玩的方塊。

另外推薦相關(guān)課程:

  韋東山老師優(yōu)質(zhì)嵌入式學(xué)習(xí)干貨推薦：包括ARM裸機(jī)開發(fā)、Linux設(shè)備驅(qū)動(dòng)程序、Linux應(yīng)用程序開發(fā)、Android系統(tǒng)學(xué)習(xí)、Linux設(shè)備樹等。

在我這里購(gòu)買韋東山老師的課程還可得到本人的技術(shù)支持，手把手帶你學(xué)習(xí)嵌入式！

王爭(zhēng)老師優(yōu)秀數(shù)據(jù)結(jié)構(gòu)算法學(xué)習(xí)課程推薦

免責(zé)聲明：本文內(nèi)容由21ic獲得授權(quán)后發(fā)布，版權(quán)歸原作者所有，本平臺(tái)僅提供信息存儲(chǔ)服務(wù)。文章僅代表作者個(gè)人觀點(diǎn)，不代表本平臺(tái)立場(chǎng)，如有問題，請(qǐng)聯(lián)系我們，謝謝！