皮皮网

1.?网络网络???˿?Դ??
2.每日开源之 tftpserver
3.一个系统端口管理软件的制作
4.go源码解析之TCP连接（二）——Accept
5.技术干货！DPDK新手入门到网络功能深入理解
6.C++后端开发——POSIX网络API解析

?端口端口???˿?Դ??

       import java.io.BufferedReader;

       import java.io.DataInputStream;

       import java.io.DataOutputStream;

       import java.io.InputStreamReader;

       import java.net.Socket;

       public class Client {

        public static void main(String[] args) throws Exception {

        Socket clientSocket = new Socket(".0.0.1", );

        clientSocket.close();

        }

       }

       没有异常就是可以连接了。

每日开源之 tftpserver

       我探索了高通Q这款用于制作路由器的源码源码芯片，它配合的网络网络是存储在NandFlash上的OpenWrt系统。Q烧写系统方式较传统，端口端口在Uboot命令行模式下，源码源码mahout源码解读要通过tftp将系统镜像下载至内存，网络网络再将镜像写入NandFlash。端口端口

       TFTP简单文件传输协议使用UDP实现，源码源码提供高效、网络网络简洁的端口端口文件传输服务，端口号为。源码源码为了完成这次烧写任务，网络网络我需要在PC上安装tftp-server。端口端口

       考虑到tftp-hpa使用复杂、源码源码配置繁琐，我放弃了尝试其原因分析的过程。在Github上，我发现了一个名为tftpserver的出色项目。

       tftpserver是一款轻量级的tftp server，用C语言编写，其源代码仅包含一个包含行代码的.c文件，无任何依赖，易于部署。

       使用方式简洁：指定文件存放目录和端口号（通常为）即可启动服务。在Uboot命令行中，用户可用tftpboot命令从PC下载文件。

       接下来，我们将快速了解tftpserver的核心实现。其源代码由七个函数构成。主函数main()负责创建一个socket以监听可能到来的TFTP请求。当接收到请求时，会调用fork()函数创建子进程，由子进程处理请求。

       TFTP基于UDP，tftp_recv_message()函数通过调用recvfrom()进行消息接收。文章源码可+收费TFTP消息定义关键，必须理解其协议设计。

       具体而言，TFTP客户与TFTP服务器之间进行读请求通讯如下：服务器被动打开号端口等待连接；客户主动发起连接，以临时端口作为源端口，号端口作为目标端口，向服务器发送读请求报文；服务器主动响应，使用新的临时端口作为源端口，用收到的临时端口作为目标端口，向客户发送包含块号和字节数据的DATA报文；客户接收到报文后，回传ACK报文确认接收。

       继续理解TFTP协议，很容易通过Wireshark进行抓包分析。以读请求为例，包含读请求操作码及目标文件名。理解TFTP协议后，tftp_message结构更加直观，用于描述TFTP通讯的数据格式。

       核心处理函数tftp_handle_request()实现协议处理，解析请求确定发送或接收操作，然后读取或发送文件。

       总结而言，tftpserver是一款轻量级、高度可移植的tftp server，对于网络编程和学习TFTP协议设计感兴趣的开发者特别适用。它提供简洁、灵活的使用方式，不依赖额外配置，确实是提高工作效率的实用小工具。

一个系统端口管理软件的制作

       æ¯”如说你的电脑是一台服务器，服务器需要有Mail Server和WEB服务，还要有FTP服务，这些只需要开放、、、就足够了。其它的就应该全部关闭。

       å…³é—­çš„方法：点击“开始→控制面板→网络连接→本地连接→右键→属性”，然后选择“Internet(tcp/ip)”→“属性”，。在“Internet(tcp/ip)属性”对话框中选择“高级”选项卡。在“高级TCP/IP设置”对话框中点选“选项”→“TCP/IP筛选”→“属性”，。在这里分为3项，分别是TCP、UDP、IP协议。假设我的系统只想开放、、、这4个端口，只要在“TCP端口”上勾选“只允许”然后点击“添加”依次把这些端口添加到里面，然后确定。注意：修改完以后系统会提示重新启动，这样设置才会生效。这样，系统重新启动以后只会开放刚才你所选的那些端口 ，其它端口都不会开放。

       ä¸ç”¨è½¯ä»¶ï¼Œç³»ç»Ÿè‡ªå¸¦

go源码解析之TCP连接（二）——Accept

       go源码解析之TCP连接系列基于go源码1..5

       连接是如何建立的

       在上一章中，我们通过追踪net.Listen的调用，深入理解了socket的创建、端口绑定以及监听过程。最后，net.Listen返回了Listener（在具体情况下为TCPListener），以太币+挖矿+源码本章将通过该Listener的Accept方法的跟踪，揭示连接建立的过程。

       让我们逐步跟踪源码，探索连接建立的具体步骤：

       1. TCPListener的Accept方法

       此方法调用了TCPListener的内部方法accept。

       随后，我们跳过ln.fd.accept和newTCPConn方法的调用，回顾上一章中关于KeepAlive配置项的讨论：KeepAlive是ListenConfig的一个属性，而ListenConfig与创建成功的监听netFD相关联。

       如果KeepAlive值大于等于0，将设置socket开启KeepAlive功能。若为0，则默认设置TCP_KEEPINTVL和TCP_KEEPIDLE属性为秒，否则依据用户设定的时间。

       2. 设置KeepAlive

       setKeepAlive和setKeepAlivePeriod方法类似，负责设置socket属性。在这两个方法中，我们都执行了fd.pfd.SetsockoptInt操作，而pfd是netFD中的属性。

       继续深入，观察poll.FD的SetsockoptInt方法，进而理解进行socket属性设置的过程。fd.Sysfd是创建系统socket的fd。net包中涉及监听、主动connect成功以及accept建立的socket，均通过netFD进行包装，因此，记住层级关系：netFD对poll.FD进行包装，poll.FD对系统fd进行包装。

       额外知识：keepalive参数

       setKeepAlive方法中的SO_KEEPALIVE用于开启keepalive总开关，而setKeepAlivePeriod中的TCP_KEEPINTVL与tcp_keepalive_intvl相关，TCP_KEEPIDLE与tcp_keepalive_time相关。TCP_KEEPCNT对应tcp_keepalive_probes，但代码中未找到使用实例。

       回到accept主流程，继续追踪ln.fd.accept方法调用。小视频+源码

       3. netFD的accept方法

       通过调用pfd.Accept（即poll.FD的Accept方法），我们深入到accept的内部实现。最终，连接成功时返回新连接socket的fd及主机地址信息。遇到EAGAIN错误（非阻塞模式下，系统调用立即返回）且fd.pd.pollable为true时，当前goroutine阻塞等待新消息（即新连接），之后再次调用accept接收连接。

       简述pollDesc（即FD中的pd），它是IO多路复用在go语言中的集成，pd.waitRead等待io消息的到来。后续章节将详细探讨epoll在go语言网络库中的使用。

       最后，netFD的accept方法调用newFD创建了netFD，此过程在上一章已有详细解释。

       至此，连接建立的整个调用链路基本完成，我们通过下图回顾整个过程。

       4. newTCPConn

       conn实现了接口类型Conn，其唯一属性是netFD，核心方法是对netFD方法的封装。

       进一步，TCPConn继承自conn，它提供了ReadFrom方法，用于从Reader中读取数据并写入到TCPConn的socket上。

       5. 小结

       通过跟踪TCPListener的Accept方法，我们详细阐述了server侧接收新连接的过程。总结了关键点，并为下一章分析TCPConn的Read方法，深入理解数据读取过程奠定了基础。

技术干货！DPDK新手入门到网络功能深入理解

       DPDK新手入门

       一、安装

       1. 下载源码

       DPDK源文件由几个目录组成。

       2. 编译

       二、配置

       1. 预留大页

       2. 加载 UIO 驱动

       三、安卓+框架+源码运行 Demo

       DPDK在examples文件下预置了一系列示例代码，这里以Helloworld为例进行编译。

       编译完成后会在build目录下生成一个可执行文件，通过附加一些EAL参数可以运行起来。

       以下参数都是比较常用的

       四、核心组件

       DPDK整套架构是基于以下四个核心组件设计而成的

       1. 环形缓冲区管理(librte_ring)

       一个无锁的多生产者，多消费者的FIFO表处理接口，可用于不同核之间或是逻辑核上处理单元之间的通信。

       2. 内存池管理(librte_mempool)

       主要职责是在内存中分配用来存储对象的pool。 每个pool以名称来唯一标识，并且使用一个ring来存储空闲的对象节点。 它还提供了一些其他的服务，如针对每个处理器核心的缓存或者一个能通过添加padding来使对象均匀分散在所有内存通道的对齐辅助工具。

       3. 网络报文缓冲区管理(librte_mbuf)

       它提供了创建、释放报文缓存的能力，DPDK应用程序可能使用这些报文缓存来存储数据包。这个缓存通常在程序开始时通过DPDK的mempool库创建。这个库提供了创建和释放mbuf的API，能用来暂存数据包。

       4. 定时器管理(librte_timer)

       这个模块为DPDK的执行单元提供了异步执行函数的能力，也能够周期性的触发函数。它是通过环境抽象层EAL提供的能力来获取的精准时间。

       五、环境抽象层（EAL）

       EAL是用于为DPDK程序提供底层驱动能力抽象的，它使DPDK程序不需要关注下层具体的网卡或者操作系统，而只需要利用EAL提供的抽象接口即可，EAL会负责将其转换为对应的API。

       六、通用流rte_flow

       rte_flow提供了一种通用的方式来配置硬件以匹配特定的Ingress或Egress流量，根据用户的任何配置规则对其进行操作或查询相关计数器。

       这种通用的方式细化后就是一系列的流规则，每条流规则由多种匹配模式和动作列表组成。

       一个流规则可以具有几个不同的动作(如在将数据重定向到特定队列之前执行计数，封装，解封装等操作)，而不是依靠几个规则来实现这些动作，应用程序操作具体的硬件实现细节来顺序执行。

       1. 属性rte_flow_attr

       a. 组group

       流规则可以通过为其分配一个公共的组号来分组，通过jump的流量将执行这一组的操作。较低的值具有较高的优先级。组0具有最高优先级，且只有组0的规则会被默认匹配到。

       b. 优先级priority

       可以将优先级分配给流规则。像Group一样，较低的值表示较高的优先级，0为最大值。

       组和优先级是任意的，取决于应用程序，它们不需要是连续的，也不需要从0开始，但是最大数量因设备而异，并且可能受到现有流规则的影响。

       c. 流量方向ingress or egress

       流量规则可以应用于入站和/或出站流量(Ingress/Egress)。

       2. 模式条目rte_flow_item

       模式条目类似于一套正则匹配规则，用来匹配目标数据包，其结构如代码所示。

       首先模式条目rte_flow_item_type可以分成两类：

       同时每个条目可以最多设置三个相同类型的结构：

       a. ANY可以匹配任何协议，还可以一个条目匹配多层协议。

       b. ETH

       c. IPv4

       d. TCP

       3. 操作rte_flow_action

       操作用于对已经匹配到的数据包进行处理，同时多个操作也可以进行组合以实现一个流水线处理。

       首先操作类别可以分成三类：

       a. MARK对流量进行标记，会设置PKT_RX_FDIR和PKT_RX_FDIR_ID两个FLAG，具体的值可以通过hash.fdir.hi获得。

       b. QUEUE将流量上送到某个队列中

       c. DROP将数据包丢弃

       d. COUNT对数据包进行计数，如果同一个flow里有多个count操作，则每个都需要指定一个独立的id，shared标记的计数器可以用于统一端口的不同的flow一同进行计数。

       e. RAW_DECAP用来对匹配到的数据包进行拆包，一般用于隧道流量的剥离。在action定义的时候需要传入一个data用来指定匹配规则和需要移除的内容。

       f. RSS对流量进行负载均衡的操作，他将根据提供的数据包进行哈希操作，并将其移动到对应的队列中。

       其中的level属性用来指定使用第几层协议进行哈希：

       g. 拆包Decap

       h. One\Two Port Hairpin

       七、常用API

       1. 程序初始化

       2. 端口初始化

       3. 队列初始化

       DPDK-网络协议栈-vpp-ovs-DDoS-虚拟化技术

       DPDK技术路线视频教程地址立即学习

       一、DPDK网络

       1. 网络协议栈项目

       2.dpdk组件项目

       3.dpdk经典项目

       二、DPDK框架

       1. 可扩展的矢量数据包处理框架vpp(c/c++)

       2.DPDK的虚拟交换机框架OvS

       3.golang的网络开发框架nff-go(golang)

       4. 轻量级的switch框架snabb(lua)

       5. 高效磁盘io读写spdk(c)

       三、DPDK源码

       1. 内核驱动

       2. 内存

       3. 协议

       4. 虚拟化

       5. cpu

       6. 安全

       四、性能测试

       1. 性能指标

       2. 测试方法

       3. 测试工具DPDK相关学习资料分享：点击领取，备注DPDK

       DPDK新手入门原文链接：DPDK上手

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，并注意细节。

禾匠榜店小程序商城后台源码安装教程（最详版）

       前提：

       1、确保使用PHP7.2，数据库版本为5.6。

       2、选择与PHP7.2版本相匹配的phpMyAdmin工具。

       3、在宝塔安全设置中，开放和端口。

       4、使用宝塔市场的CentOS Linux 7.5版本，避免版本差异过大。

       一、安装配置环境

       1、安装PHP7.2，从宝塔软件商店获取。

       2、额外安装Redis扩展，确保未安装离子立方或SG扩展。

       3、删除所有与proc_open、pcntl相关的禁用函数。

       4、安装Swoole扩展，上传swoole_loader.so文件至指定路径，更新PHP配置文件，确保Swoole扩展已启用。

       二、安装程序

       1、在宝塔中创建网站，并设置数据库。

       注意：必须使用MySQL 5.6版本，其他版本需备份数据库后重新安装。

       2、开启强制HTTPS功能。

       3、将系统压缩包上传至网站文件目录并解压。

       三、后续配置

       1、登录后台，使用默认账户admin，密码admin。

       2、开启队列服务，设置命令行版本，打开终端执行相应命令。

       成功后，即可正常运行，使用完毕。

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

       源代码奉上，流程图。。。这个太简单了，你自己看看。。。。。。。

       //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( );

       }

开源的TCPing网络测试工具

       开源的TCPing网络测试工具是一个跨平台的TCP端口ping程序，灵感来源于Linux的ping实用程序。它能够向您指定的IP地址或主机名发送TCP探测，并打印结果。TCPing支持IPv4和IPv6，为成功和失败的探测使用不同的TCP序列编号。这使得查看结果和推断总数据包丢失量变得更加容易。项目使用GO语言开发，源码地址为GitHub - pouriyajamshidi/tcping: Ping TCP ports using tcping. Inspired by Linux's ping utility. Written in Go。TCPing具备以下特点：使用例子、可选参数说明。它与Ping的主要区别在于：Ping测试网络物理连通性，而TCPing通过TCP连接检测更上层的网络可达性。TCPing提供连接建立时间、丢包率等更多连接性能数据，有助于判断网络质量和问题排查。在某些网络环境下禁用Ping时，TCPing是一种很好的替代方法。总的来说，TCPing是一个方便实用的工具，掌握其用法能有效提高网络问题的诊断与排查效率。