socket编程(一)使用SOCK_STREAM建立可靠通信

2024-04-12 03:18

本文主要是介绍socket编程(一)使用SOCK_STREAM建立可靠通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

socket是我们用来进行网络编程的基本API,一般系统都提供了socket,unix以及类unix(Linux、mac)它们都提供了socket,不过不同平台还是有那点区别的,其中Windows区别最大了。本文的代码是在mac上测试通过的。

socket是一个应用层编程API,提供了tcp/ip四层模型的第三层传输层的TCP、UDP协议的数据传输方式。第二层网际层有IP协议,它本来是不可靠的协议,而TCP在它的基础上提供了可靠传输。UDP仍然提供不可靠传输。

两个进程若想通信,可以通过socket来进行,不管这两个进程在什么位置,只要它们的主机都实现了TCP/IP协议栈。

我们用网络地址(ip)+port来标识一个通信实体,A要找到B,只需要知道B的ip:port即可。若B处理的是TCP报文,那么A应该指定传输协议是tcp,要是指定个udp或则其它协议,那么B得到了传输层发给应用层的报文将是一个非TCP报文,B在传输层会丢弃这个报文。

传输层TCP报文只用到了port,网际层IP报文用到了ip地址,同时把TCP报文作为它的部分报文内容。

下面是TCP报文,有源port与目的port。报文本身说明了它是TCP报文,在socket中我们如果用TCP协议,那么我们要指定socket用TCP协议。

下面是ip报文,有源ip与目的ip。

根据上面两个报文我们可以看出socket不是一个工作在哪个层上的API,而是一个跨层的网络编程API,为应用层提供服务,我们可以开发一些网络层协议。

服务器端:

socket编程,流程很固定。TCP传输模式是服务器端先创建一个socket,然后把这个socket绑定到一个地址上。这个时候socket可以工作了,让它向tcp/ip协议栈请求一个监听服务并创建一个服务队列来接受那些请求。这个服务队列是什么样子的,我们看下服务器怎么跟客户端通过三次握手接受请求并且建立连接的。

第一次

第一次握手:建立连接时,客户端发送syn包(syn=j)到服务器,并进入SYN_SENT状态,等待服务器确认;SYN:同步序列编号(Synchronize Sequence Numbers)。

第二次

第二次握手:服务器收到syn包,必须确认客户的SYNack=j+1),同时自己也发送一个SYN包(syn=k),即SYN+ACK包,此时服务器进入SYN_RECV状态;

第三次

第三次握手:客户端收到服务器的SYN+ACK包,向服务器发送确认包ACK(ack=k+1),此包发送完毕,客户端和服务器进入ESTABLISHEDTCP连接成功)状态,完成三次l握手。

上面三次握手后,客户端与服务器可以开始通信了,而且通信是可靠的。那么服务队列到底是什么呢?它实际是一个未连接队列。这个队列如果每次跟客户端只有第一次握手,

后面客户端不给它第二次握手,而且大量的客户端都这样做,你猜会这么样?哈哈,未连接队列里将都是Syn_RECV状态,它达不到ESTABLISHED状态,不会被删除,

这个队列就会满了,然后其它客户端不能跟服务器通信了,这个其实是一种dos攻击。

在三次握手协议中,服务器维护一个未连接队列,该队列为每个客户端的SYN包(syn=j)开设一个条目,该条目表明服务器已收到SYN包,

并向客户发出确认,正在等待客户的确认包。这些条目所标识的连接在服务器处于 Syn_RECV状态,当服务器收到客户的确认包时,

删除该条目,服务器进入ESTABLISHED状态。

未连接队列:

在三次握手协议中,服务器维护一个未连接队列,该队列为每个客户端的SYN包(syn=j)开设一个条目,该条目表明服务器已收到SYN包,

并向客户发出确认,正在等待客户的确认包。这些条目所标识的连接在服务器处于 Syn_RECV状态,当服务器收到客户的确认包时,

删除该条目,服务器进入ESTABLISHED状态。

监听服务好了后,你可以在任何你高兴的时候去检查未连接队列,看哪个条目是ESTABLISHED状态的,你可以删除这个条目,跟这个3次握手完成的客户端进程进行通信,

进行数据的接受与发送,同样任何时刻可以终止通信。3次握手后,队列里存的是客户端的地址信息以及ESTABLISHED状态,如果进程不去接受请求,tcp/ip协议栈不会去删除

条目的,一旦队列满了,后面就没位置放完成三次握手的请求了。完成三次握手表示建立了连接,这个是相对于tcp/ip协议栈的,并不表示我们的进程就接受了客户端的通信

请求,如果你想接受一个客户端的通信请求,那么需要主动去查询,然后去接受请求,最后才可以通信。查询的时候一般都是以阻塞方式进行的,没人完成3次握手的通信实体时,

线程会被阻塞,一旦该事件完成,进程会继续运行该线程。服务器在主线程中可以被阻塞,在子线程中进行数据收发,这样主线程阻塞了,不会影响子

线程。阻塞本来是进程的一种状态,但是现在线程也是可以的,线程阻塞并不代表进程就阻塞了。

下面是服务器代码, 格式很固定,就多了个用子线程与请求通信的实体进行通信。后面再详细的研究网络方面的编程,目的是为我写的2d回合角色扮演游戏(方块世界:图片就是

方块,现在画画太丑了,时间也不是很多。)提供一个服务端。


#include <stdio.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <signal.h>
#include <pthread.h>
#include <iostream>
#include <stdio.h>void* msgHandle(void *);int main (int argc, const char * argv[])
{//struct sockaddr_in : Socket address, internet stylestruct sockaddr_in server_addr;server_addr.sin_len = sizeof(struct sockaddr_in);server_addr.sin_family = AF_INET;//Address families AF_INET互联网地址簇server_addr.sin_port = htons(111332);server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");bzero(&(server_addr.sin_zero),8);//创建socketint server_socket = socket(AF_INET, SOCK_STREAM, 0);//SOCK_STREAM 有连接if (server_socket == -1) {perror("socket error");return 1;}//绑定socket:将创建的socket绑定到本地的IP地址和端口,此socket是半相关的,只是负责侦听客户端的连接请求,并不能用于和客户端通信int bind_result = bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr));if (bind_result == -1) {perror("bind error");return 1;}//listen侦听 第一个参数是套接字,第二个参数为等待接受的连接的队列的大小,在connect请求过来的时候,//完成三次握手后先将连接放到这个队列中,直到被accept处理。如果这个队列满了,且有新的连接的时候,对方可能会收到出错信息。if (listen(server_socket, 5) == -1) {perror("listen error");return 1;}while (true) {// 接受一个客户端的tcp连接 创建socket跟客户端通信printf("wait client\n");struct sockaddr_in client_address;socklen_t address_len;int client_socket = accept(server_socket, (struct sockaddr *)&client_address, &address_len);setsockopt(client_socket, SOL_SOCKET, SO_NOSIGPIPE, NULL, sizeof(int));if (client_socket == -1) {perror("accept error");return -1;}printf("accept client\n");// 启动一个线程跟客户端进行通信pthread_t id;pthread_create(&id, NULL, msgHandle, &client_socket);
//        pthread_join(id, NULL);pthread_detach(id);}return 0;
}void* msgHandle(void *arg){int client_socket = *(int*)arg;printf("client socket id:%d", client_socket);int i = 1;while (i< 10) {printf("%d", i);i+=1;}fflush(stdout);// 进行消息处理  接受客户端消息 然后处理消息return 0;
}

http://blog.csdn.net/beautyleaf/article/details/51171103


这篇关于socket编程(一)使用SOCK_STREAM建立可靠通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/895958

相关文章

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Pandas使用SQLite3实战

《Pandas使用SQLite3实战》本文主要介绍了Pandas使用SQLite3实战,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录1 环境准备2 从 SQLite3VlfrWQzgt 读取数据到 DataFrame基础用法:读

JSON Web Token在登陆中的使用过程

《JSONWebToken在登陆中的使用过程》:本文主要介绍JSONWebToken在登陆中的使用过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录JWT 介绍微服务架构中的 JWT 使用结合微服务网关的 JWT 验证1. 用户登录,生成 JWT2. 自定义过滤

Java中StopWatch的使用示例详解

《Java中StopWatch的使用示例详解》stopWatch是org.springframework.util包下的一个工具类,使用它可直观的输出代码执行耗时,以及执行时间百分比,这篇文章主要介绍... 目录stopWatch 是org.springframework.util 包下的一个工具类,使用它

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3

springboot security使用jwt认证方式

《springbootsecurity使用jwt认证方式》:本文主要介绍springbootsecurity使用jwt认证方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录前言代码示例依赖定义mapper定义用户信息的实体beansecurity相关的类提供登录接口测试提供一

go中空接口的具体使用

《go中空接口的具体使用》空接口是一种特殊的接口类型,它不包含任何方法,本文主要介绍了go中空接口的具体使用,具有一定的参考价值,感兴趣的可以了解一下... 目录接口-空接口1. 什么是空接口?2. 如何使用空接口?第一,第二,第三,3. 空接口几个要注意的坑坑1:坑2:坑3:接口-空接口1. 什么是空接

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》:本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景:内存吃得满满的类__slots__:你的内存管理小助手举个大概的例子:看看效果如何?1.