C++socket网络编程(跨平台)实战HTTP服务器(二)

         使用Socket创建TCP服务器

      1首先了解一下TCP

1TCP是面向连接的,必须是三次握手之后

2TCP提供可靠连接,实现丢失重传,RTT的估算物理 网卡 网线都会影响 这个丢包

3TCP通过给所发数据的每一个段管理一个序列号进行排序. 没一个包都有一个序号,由底层按照序列号发送给你

4TCP提供流量控制和拥塞控制:通过窗口拥塞窗口可以限制流量的,1000个客户TCP可以限定他能够是以多块的速度来接收你的数据TCP的连接是全双工的. 互相不干扰发送和接收是同时进行的

首先我们配置一下Linux环境非常简单哦

Linux需要安装g++ gcc makefile

1开始写代码在windows上编码,但是我们的工程是在linux目录下的

<a href="https://s3.51cto.com/wyfs02/M00/9B/F3/wKioL1lpfh3hHBReAAAQ6OptOho664.png-wh_500x0-wm_3-wmp_4-s_2623743358.png" target="_blank"></a>

1初始化

1

2

3

4

5

<code>/初始化windows网络库,这里就会载入动态库文件</code>

<code>所以我们要载入lib文件,可以在vs载入也可以代码</code>

<code>#pragma comment(lib,"ws2_32.lib")</code>

<code>WSADATA ws;</code>

<code>WSAStartup(MAKEWORD(2,2),&amp;ws);</code>

2 初始化完成就是创建一个socket了,socket反回的

是一个int型,是与客户建立建立的socket,第一个参数是使用的

协议是tcp/ip,应为socket还可以用来蓝牙的通信协议

第二个参数是使用TCP还是UDP这里SOCK_STREAM是TCP

第三个参数是原始套接字的时候用到的为0就行

6

7

<code>int</code> <code>sock = socket(AF_INET, SOCK_STREAM, 0);</code>

<code>if</code> <code>(sock == -1)</code>

<code>{</code>

<code>printf</code><code>(</code><code>"create err\n"</code><code>);</code>

<code>return</code> <code>-1;</code>

<code>}</code>

<code>printf</code><code>(</code><code>"[%d]"</code><code>, sock);</code>

3绑定

sockaddr_in是一个结构体,他记录端口和ip地址以及协议族.

1需要指定端口。

2绑定本地的ip地址,如果绑定127.0.0.1就只能本地访问

这个网络,如果绑定外网ip那只能从外部访问,内部不能访问

一台机器可以有两个网卡，如果要任意都可以访问那就直接htonl(0),将ip和杜端口绑定到哪个socket，

bind()如果不等于0会失败,而且很容易失败,最好判断一下。

8

9

10

11

12

13

<code>        </code><code>enum</code><code>{PORT=8017}</code>

<code> </code> 

<code>    </code><code>sockaddr_in sa;</code>

<code>    </code><code>sa.sin_family = AF_INET;</code>

<code>    </code><code>sa.sin_port = htons(PORT);</code>

<code>    </code><code>sa.sin_addr.s_addr = htonl(0);</code>

<code>    </code><code>if</code> <code>(bind(sock, (sockaddr*)&amp;sa, </code><code>sizeof</code><code>(sa)) != 0)</code>

<code>    </code><code>{</code>

<code>        </code><code>printf</code><code>(</code><code>"bind port err\n"</code><code>);</code>

<code>        </code><code>return</code> <code>-2;</code>

<code>    </code><code>}</code>

<code>    </code><code>printf</code><code>(</code><code>"bind port ok!!!\n"</code><code>);</code>

4侦听

绑定只是做了一个标识,还没有等待客户的连接.

这个函数一调用开始接收用户的连接了。第二个参数

是该套接字使用的队列长度，指定在请求队列总允许的最大请求

数，意思就是如果你接收10个连接还没有用Accept进行接待就会把新的连接扔掉。

<code>listen(socket,10);</code>

4获得连接用户信息

这个函数是获得获得用户的连接信息,他反回一个int是用来真正

和用户进行收发数据的,第一个参数之前创建的sock是和用户建立连接的,第二个参数是输出的参数,就是你穿进去之后,在里面进行赋值，

然后输出出来, 在访问结构体的成员就可以获得ip和端口了。

如果不需要ip地址和端口,只需要直接传人0就行。

这个时候就可以创建线程和用户进行通信了,

14

15

16

17

18

<code>sockaddr_in sadd;</code>

<code>socklen_t len = </code><code>sizeof</code><code>(sadd);</code>

<code>int</code> <code>client = accept(sock, (sockaddr*)&amp;sadd, &amp;len);</code>

<code>if</code> <code>(client &gt; 0)</code>

<code>    </code><code>printf</code><code>(</code><code>"client connect ok\n"</code><code>);</code>

<code>    </code><code>printf</code><code>(</code><code>"sockeid: %d\n"</code><code>, client);</code>

<code>    </code> 

<code>    </code><code>//输出端口号和信息</code>

<code>    </code><code>char</code> <code>*ip = inet_ntoa(sadd.sin_addr);</code>

<code>    </code><code>//网络字节序转本地字节序哦</code>

<code>    </code><code>unsigned </code><code>short</code> <code>port = ntohs(sadd.sin_port);</code>

<code>    </code><code>printf</code><code>(</code><code>"IP: %s\n"</code><code>, ip);</code>

<code>    </code><code>printf</code><code>(</code><code>"port: %d\n"</code><code>, port);</code>

<code>    </code><code>closesocket(client);</code>

一般情况下每建立一个连接,会把他传到一个新的线程当中,简单的方案是把他来的时候就创建一个新的线程复杂的方案是创建一个线程池,每来一个连接,把他扔给闲置的线程.

我们在linux进行编译首先打卡这个工程路劲

<a href="https://s1.51cto.com/wyfs02/M01/9B/F4/wKiom1lphByAcaDzAAAI6F4dDMs617.png-wh_500x0-wm_3-wmp_4-s_3093762570.png" target="_blank"></a>

编写一个makefile

<a href="https://s4.51cto.com/wyfs02/M02/9B/F4/wKioL1lphDSikCNcAAAFOp-XjBE140.png-wh_500x0-wm_3-wmp_4-s_2277294869.png" target="_blank"></a>

简单说下makefile

上面的4个类似预定义

CC是编译器

SRC是源文件

OBJ是编译的文件

EXEC编译连接可执行文件

$(OBJ)代表简单点就是使用这个预定义一样类似

start: $(OBJ)  

    $(CC) -o $(EXEC) $(OBJ)

上面依赖OBJ他会先执行这个

$(OBJ):

    $(CC) -o $(OBJ) -c $(SRC)//这里只编译

//删除只编译的文件

clean:

    rm -f $(OBJ)

//执行 可执行文件

run:

    ./$(EXEC)

<a href="https://s1.51cto.com/wyfs02/M00/9B/F4/wKiom1lphEmiAx0wAABCRjOB8XY461.png-wh_500x0-wm_3-wmp_4-s_1035654349.png" target="_blank"></a>

启动make start 

<a href="https://s5.51cto.com/wyfs02/M01/9B/F5/wKiom1lphavQ32lyAABDivf7H78455.png-wh_500x0-wm_3-wmp_4-s_315776401.png" target="_blank"></a>

这时候会出现很多错误,

<a href="https://s4.51cto.com/wyfs02/M00/9B/F5/wKiom1lphd2wMjiLAABB9Y4rAnM276.png-wh_500x0-wm_3-wmp_4-s_938615570.png" target="_blank"></a>

原因:

    linux,用不到windows的库文件,也不需要初始化

,还有一些api不一致。

解决方案: 

#ifdef WIN32  如果是 WIN32情况下调用哪些

#else    就是不再windows环境下用到的

#else

man socket 查看需要的头文件

<a href="https://s3.51cto.com/wyfs02/M00/9B/F4/wKioL1lphnaj5oHvAAAL8OatXSU238.png-wh_500x0-wm_3-wmp_4-s_1527445518.png" target="_blank"></a>

用起来很方便

<a href="https://s2.51cto.com/wyfs02/M01/9B/F5/wKiom1lphqawuhyJAABXbU3EvU0657.png-wh_500x0-wm_3-wmp_4-s_3526728051.png" target="_blank"></a>

在红色部分,填写linux需要的东西,这个东西会

在编译的时候就会执行,他发现不是windows就是会执行#else

里的代码.  

<a href="https://s5.51cto.com/wyfs02/M01/9B/F5/wKiom1lphsSw_lkPAAAdyDnuAUM606.png-wh_500x0-wm_3-wmp_4-s_819094601.png" target="_blank"></a>

其他的也是一样的。 clossocket 缓冲 close就行

然后就可以编译成功了。

make start编译生成一下

然后make run执行一下

<a href="https://s1.51cto.com/wyfs02/M00/9B/F5/wKiom1lph2bx88nRAAA5HspBT0s739.png-wh_500x0-wm_3-wmp_4-s_1979248057.png" target="_blank"></a>

启动另外一个linux测试一下

telnet 192.168.1.125 8013 测试连接一些

然后左边我们看到把

连接的用户的 IP和端口都打印了。

<a href="https://s2.51cto.com/wyfs02/M00/9B/F4/wKioL1lph6fgsbCVAAGONiicwFY745.png-wh_500x0-wm_3-wmp_4-s_152942287.png" target="_blank"></a>

基本流程都有了,后面的话,只需要照着编译就行。

我们开始recv接收客户端发送数据

第一个参数是用户和你连接之后,返回的

那个socket哦,第二个参数是存储数据的缓冲,

第三个参数是缓冲大小-1是为了留意味放/0结束符

第四个0就行了,跟系统有关的东西

返回值就是收到数据的大小

实际返回值有时候会大于1024 但是发送方会

有一些数据的切割,所以很容易造成错误

<code>char</code> <code>buf[1024];</code>

<code>memset</code><code>(buf, 0, </code><code>sizeof</code><code>(buf));</code>

<code>int</code> <code>len = recv(client, buf, </code><code>sizeof</code><code>(buf) - 1, 0);</code>

<code>print(</code><code>"recv %s\n"</code><code>,buf);</code>

在Linux编译执行一下

在发送端连接后发送数据

<a href="https://s2.51cto.com/wyfs02/M02/9B/F5/wKiom1lpi7DxK6dJAABpq1EDpx8815.png-wh_500x0-wm_3-wmp_4-s_763954218.png" target="_blank"></a>

服务器收到数据通信成功

<a href="https://s4.51cto.com/wyfs02/M02/9B/F5/wKiom1lpi93D8TciAADeoDa2OAE328.png-wh_500x0-wm_3-wmp_4-s_546600093.png" target="_blank"></a>

循环接收用户的信息,在死循环里接收,如果收到的数据&lt;=就退出

如果用户发送的里面有 "quit"就会退出

<code>for</code> <code>(;;)</code>

<code>int</code> <code>recv_len = recv(client, buf, </code><code>sizeof</code><code>(buf) - 1, 0);</code>

<code>if</code> <code>(recv_len &lt;= 0)</code><code>break</code><code>;</code>

<code>if</code><code>(</code><code>strstr</code><code>(buf, </code><code>"quit"</code><code>)!= NULL) </code><code>break</code><code>;</code>

<code>printf</code><code>(</code><code>"recv %s\n"</code><code>, buf);</code>

<a href="https://s3.51cto.com/wyfs02/M02/9B/F5/wKioL1lpjPOjWlzeAADMPaPMpag632.png-wh_500x0-wm_3-wmp_4-s_3584078235.png" target="_blank"></a>

多线程并发处理 直接用c++11的线程库。不需要考虑跨平台

的问题.

创建线程的地方就是,accept然后会返回的一个socket

给这个线程用

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

<code>#include &lt;thread&gt;</code>

<code>using</code> <code>namespace</code> <code>std;</code>

<code>class</code> <code>TcpThread</code>

<code>public</code><code>:</code>

<code>    </code><code>//线程入口函数 创建一个</code>

<code>    </code><code>void</code> <code>Main()</code>

<code>        </code><code>char</code> <code>buf[1024];</code>

<code>      </code><code>for</code> <code>(;;)</code>

<code>        </code><code>{</code>

<code>        </code><code>memset</code><code>(buf, 0, </code><code>sizeof</code><code>(buf));</code>

<code>        </code><code>int</code> <code>recv_len = recv(client, buf, </code><code>sizeof</code><code>(buf) - 1, 0);</code>

<code>        </code><code>if</code> <code>(recv_len &lt;= 0)</code><code>break</code><code>;</code>

<code>        </code><code>if</code> <code>(</code><code>strstr</code><code>(buf, </code><code>"quit"</code><code>) != NULL)</code>

<code>            </code><code>char</code> <code>re[] = </code><code>"quit success\n"</code><code>;</code>

<code>            </code><code>int</code> <code>sendlen = send(client, re, </code><code>strlen</code><code>(re)+1, 0);</code>

<code>        </code><code>}</code>

<code>        </code><code>int</code> <code>sendlen = send(client, </code><code>"ok\n"</code><code>,4, 0);</code>

<code>        </code><code>printf</code><code>(</code><code>"recv %s\n"</code><code>, buf);</code>

<code>        </code><code>closesocket(client);</code>

<code>        </code> 

<code>    </code><code>//用户的socket</code>

<code>    </code><code>int</code> <code>client = 0;</code>

<code>};</code>

如何创建线程呢,获得用户信息accept应该放到死循环里

应为线程需要他的返回值.

创建一个线程  需要考虑什么时候清理

几种方案 1对象复用 2自己清理

<a href="https://s5.51cto.com/wyfs02/M01/9B/F6/wKiom1lplQbAEFq8AAAt_2cuuJM690.png-wh_500x0-wm_3-wmp_4-s_3006341758.png" target="_blank"></a>

<code>//这里会阻塞 只有等待有新的连接 才会执行下面的代码</code>

<code>printf</code><code>(</code><code>"client connect ok\n"</code><code>);</code>

<code>printf</code><code>(</code><code>"sockeid: %d\n"</code><code>, client);</code>

<code>//输出端口号和信息</code>

<code>char</code> <code>*ip = inet_ntoa(sadd.sin_addr);</code>

<code>//网络字节序转本地字节序哦</code>

<code>unsigned </code><code>short</code> <code>port = ntohs(sadd.sin_port);</code>

<code>printf</code><code>(</code><code>"IP: %s\n"</code><code>, ip);</code>

<code>printf</code><code>(</code><code>"port: %d\n"</code><code>, port);</code>

<code>else</code>

<code>break</code><code>;</code>

<code>//创建一个线程  需要考虑什么时候清理</code>

<code>//几种方案 1对象复用 2自己清理</code>

<code>TcpThread *th = </code><code>new</code> <code>TcpThread();</code>

<code>th-&gt;client = client; </code><code>//获得socket</code>

<code>//启动线程 第一个参数是入口函数的地址(函数指针)</code>

<code>//第二个参数调用的对象</code>

<code>std::</code><code>thread</code> <code>sth(&amp;TcpThread::Main,th);</code>

<code>//上面的调用完后 对象 会被销毁掉</code>

<code>//销毁不受影响 但是本线程还有一些资源没有被释放掉</code>

<code>// 我们可以直接让他直接释放调用,主线程不要控制子线程的处理,比如挂起啊 或者关闭</code>

<code>//这种操作是很危险的,因为 主线程不知道子线程运行到什么阶段 </code>

<code>//正常情况我们不去处理 detach()  释放主线程拥有的子线程的资源</code>

<code>sth.detach();</code>

然后移植到linux  makefile需添加 std c++11 才可以编译成功

<a href="https://s4.51cto.com/wyfs02/M01/9B/F6/wKioL1lpnAjQh2oiAAAe6pcoS18046.png-wh_500x0-wm_3-wmp_4-s_1071493355.png" target="_blank"></a>

还需要添加 -lpthread

<a href="https://s2.51cto.com/wyfs02/M00/9B/F7/wKiom1lpnbmiMxuLAAAYUTZY-IA850.png-wh_500x0-wm_3-wmp_4-s_680741025.png" target="_blank"></a>

上面的有点问题

$(CC) $(OBJ) -o $(EXEC) -std=c++11 -lthread

 本文转自超级极客51CTO博客，原文链接：http://blog.51cto.com/12158490/1947841，如需转载请自行联系原作者