标签 tcp 下的文章

Modbus通讯协议——Java通过Jlibmodbus实现Modbus Master(主机)TCP/RTU的Read；Slave（从机）TCP/RTU的Write

2024-08-26

在Java中，使用Jlibmodbus实现Modbus主机的TCP/RTU读取从机的功能，可以通过以下步骤进行：

确保已经安装了Jlibmodbus库。
使用Jlibmodbus的API创建Modbus主机连接。
选择要进行读取操作的从机地址、寄存器地址、读取长度。
执行读取操作并处理结果。

以下是一个简单的示例代码，展示了如何使用Jlibmodbus在TCP模式下读取Modbus从机数据：




import com.intelligt.modbus.jlibmodbus.*;
 
public class ModbusTCPMaster {
    public static void main(String[] args) {
        try {
            ModbusMaster master = ModbusMasterFactory.createTCPMaster("127.0.0.1", 502, 3000, true);
            master.init();
 
            int slaveId = 1; // Modbus从机地址
            int startAddress = 0; // 起始寄存器地址
            int quantity = 10; // 读取数量
 
            // 读取线圈状态
            boolean[] coils = master.readCoils(slaveId, startAddress, quantity);
            // 读取寄存器
            int[] registers = master.readInputRegisters(slaveId, startAddress, quantity);
 
            // 处理读取的数据
            for (boolean coil : coils) {
                System.out.print(coil ? "1" : "0");
            }
            System.out.println();
            for (int reg : registers) {
                System.out.print(reg + " ");
            }
 
            master.destroy();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个Modbus主机，用于连接到地址为"127.0.0.1"，端口为502的TCP服务器。然后，我们读取了从机地址为1的起始地址为0的寄存器状态和数据，读取的数量为10个。读取的线圈状态和寄存器数据被处理并打印输出。

请注意，上述代码只是一个简单的示例，实际应用中可能需要更复杂的异常处理和资源管理。此外，Jlibmodbus库可能需要额外的配置才能在不同的环境中工作，如不同的网络设置或安全性要求。

System

2024-08-25

所有,elasticsearch

TCP keep-alive机制是一种在不影响连接的情况下，检测对端是否仍然可达或者是否仍然保持在线状态的方法。Elasticsearch也有类似的机制，称为ping/keep-alive。

TCP的keep-alive通常是由操作系统的网络栈自动管理的，不需要用户进行配置。但是，可以通过设置socket选项来调整这个行为。

Elasticsearch的keep-alive机制是通过HTTP的header中的Connection: keep-alive来实现的。这意味着在一个HTTP连接上，连续的请求可以被复用，从而减少了建立新连接的开销。

在Elasticsearch中，默认情况下，Elasticsearch的节点会响应Ping请求，并且会在节点不可达时从集群中移除该节点。

以下是一个简单的Python示例，使用requests库发送带有keep-alive的HTTP请求：




import requests
from requests.adapters import HTTPAdapter
from requests.packages.urllib3.poolmanager import PoolManager
from requests.packages.urllib3.connection import HTTPConnection
 
class KeepAliveAdapter(HTTPAdapter):
    """An HTTPAdapter that adds support for Keep-Alive."""
 
    def init_poolmanager(self, connections, max_connections, block=False):
        self.poolmanager = PoolManager(num_pools=connections,
                                       maxsize=max_connections,
                                       block=block,
                                       strict=True,
                                       connection_class=HTTPConnection)
 
 
# 使用自定义的Adapter来发送带keep-alive的请求
session = requests.Session()
session.mount('http://', KeepAliveAdapter())
session.mount('https://', KeepAliveAdapter())
 
response = session.get('http://localhost:9200')
print(response.text)

在这个例子中，我们创建了一个自定义的HTTPAdapter，它使用HTTPConnection来管理keep-alive连接。然后我们用session.keep_alive = False来确保连接在任务完成后不会被关闭。这样，在session发送的连续请求会共享同一个TCP连接。

- 阅读更多 -

分布式 - 服务器Nginx：一小时入门系列之TCP反向代理和负载均衡

System

2024-08-25

所有,分布式

在Nginx中配置TCP反向代理和负载均衡，你需要使用stream模块。以下是一个简单的配置示例：




stream {
    upstream backend {
        server backend1.example.com:12345;
        server backend2.example.com:12345;
    }
 
    server {
        listen 12345;
        proxy_pass backend;
        proxy_connect_timeout 1s;
    }
}

在这个配置中，Nginx监听本地的12345端口，并将接收到的TCP连接代理到名为backend的上游组，该组中包含了两个后端服务器。proxy_connect_timeout指定了连接到后端服务器的超时时间。

确保你的Nginx版本支持stream模块，并在nginx.conf中包含了这个配置。记得重新加载或重启Nginx以应用新的配置。




nginx -s reload

或者




systemctl reload nginx

确保你的防火墙设置允许从你的服务器到后端服务器的流量通过相应的端口。

- 阅读更多 -

php使用swoole实现TCP服务

System

2024-08-24

所有,php

在PHP中使用Swoole扩展可以轻松地创建TCP服务器。以下是一个简单的TCP服务器示例代码：




<?php
// 创建TCP服务器对象，监听127.0.0.1的9501端口
$tcp_server = new Swoole\Server('127.0.0.1', 9501);
 
// 注册连接回调函数
$tcp_server->on('Connect', function ($server, $fd) {
    echo "客户端连接，ID：{$fd}\n";
});
 
// 注册接收数据回调函数
$tcp_server->on('Receive', function ($server, $fd, $reactor_id, $data) {
    $server->send($fd, "服务器收到数据：{$data}");
});
 
// 注册关闭连接回调函数
$tcp_server->on('Close', function ($server, $fd) {
    echo "客户端关闭，ID：{$fd}\n";
});
 
// 启动服务器
$tcp_server->start();

在这个例子中，我们创建了一个监听在本机IP地址127.0.0.1和端口9501上的TCP服务器。当客户端连接、发送数据或关闭连接时，会分别触发Connect、Receive和Close事件，并执行相应的回调函数。

确保你的PHP环境已经安装了Swoole扩展。可以通过运行php --ri swoole来检查Swoole扩展是否已经安装和加载。如果没有安装，你可以通过PECL安装Swoole扩展，使用命令pecl install swoole。

System

2024-08-23

所有,linux

报错解释：

这个错误表明Clash在尝试绑定到本地地址127.0.0.1的7890端口时失败了。通常是因为端口已被其他进程占用。

解决方法：

查找并停止占用端口的进程：
- 运行lsof -i :7890 或 netstat -tulnp | grep 7890 查找占用端口的进程。
- 如果找到，使用kill命令终止该进程。
更改Clash配置文件中的端口号：
- 编辑Clash的配置文件，将bind字段后的端口号更改为其他未被占用的端口号。
检查防火墙或安全软件设置：
- 确保没有防火墙规则阻止Clash绑定端口。
重新启动Clash。

确保在进行任何操作前备份好配置文件，以防需要恢复原始设置。

System

2024-08-23

所有,linux

TCP协议为了管理通信连接，定义了一系列的状态转换图，这些状态转换图描绘了TCP连接从开始到结束的生命周期中所经历的各种状态。以下是TCP连接状态转换图的核心部分：




                                   +----------+
                                   |  CLOSED  |
                                   +----------+
                                      |     ^
                                      v     |
                                   +----------+
                                   |  LISTEN  |
                                   +----------+
                                      |     ^
                                      v     |
                                   +----------+
                                   |  SYN_RCVD|
                                   +----------+
                                      |     ^
                                      v     |
                 +------------------+-----------+
                 |                  |           |
                 v                  v           v
           +----------+          +----------+    +----------+
           |  SYN_SENT|          | SYN_SENT|    |  CLOSED  |
           +----------+          +----------+    +----------+
                |                    |               |     ^
                v                    v               v     |
         +---------------+          +---------------+      |
         |     ESTAB     |          |     ESTAB     |      |
         |               |          |               |      |
         |               |          |               |      |
         +---------------+          +---------------+      |
                |                    |               |      |
                v                    v               v      |
         +---------------+          +---------------+      |
         |    FIN_WAIT1  |          |    FIN_WAIT2  |      |
         +---------------+          +---------------+      |
                |                    |               |      |

System

2024-08-23

所有,linux

在TCP协议中，有两种常见的优化技术：延迟应答（Delayed Acknowledgment）和捎带应答（Squashed Acknowledgment）。

延迟应答：

延迟应答是指TCP在接收到数据后，并不立即发送ACK确认包，而是等待一小段时间，以期望在这段时间内有更多的数据包到达，这样就可以把多个ACK合并为一个，减少网络中的小包数量，从而提高网络效率。

实现延迟应答的代码示例：




// 设置延迟时间，比如100毫秒
tcp_set_delack_time(100);

捎带应答：

捎带应答是指当发送方发送了数据，接收方也许会发送一个ACK确认包，但是在同一个round trip time（RTT）内，发送方又发送了更多的数据，此时接收方就可以把之前的ACK确认包与新数据一起发送回去，减少了网络延迟。

实现捎带应答的代码示例：




// 开启捎带应答功能
tcp_enable_squash_ack();

这两种技术可以有效地提高网络的吞吐量，减少网络延迟。在实际的编程中，这些功能通常由操作系统的TCP/IP栈自动管理，不需要用户手动进行设置。但是，了解这些概念有助于理解TCP协议的工作原理。

- 阅读更多 -

【MySQL | TCP】宝塔面板结合内网穿透实现公网远程访问

System

2024-08-23

所有,mysql

在宝塔面板中设置MySQL远程访问，并结合内网穿透实现公网远程访问，步骤如下：

在宝塔面板中安装MySQL。
登录MySQL，为远程访问设置权限。




CREATE USER 'yourusername'@'%' IDENTIFIED BY 'yourpassword';
GRANT ALL PRIVILEGES ON *.* TO 'yourusername'@'%' WITH GRANT OPTION;
FLUSH PRIVILEGES;

修改MySQL配置文件，注释掉bind-address这一行或者将其值改为0.0.0.0。
重启MySQL服务。
使用内网穿透工具，如frp或ngrok，将本地MySQL端口映射到公网。

frp示例配置：




[common]
server_addr = your_server_ip
server_port = 7000
 
[ssh]
type = tcp
local_ip = 127.0.0.1
local_port = 22
remote_port = 6000

在宝塔面板防火墙规则中放行内网穿透对应的端口。
使用SSH客户端或其他数据库管理工具远程连接到服务器的公网IP和内网穿透的端口，进行数据库管理。

注意：确保你的服务器安全组或防火墙规则已经放行了对应的内网穿透端口和MySQL默认端口3306。

以上步骤可以实现在公网远程访问你的MySQL数据库，但要注意远程访问数据库时要使用强密码，并确保使用了安全的连接协议（如SSL/TLS）。

System

2024-08-23

所有,golang

报错信息不完整，但从提供的部分可以看出，这是一个来自proxy.go的错误日志，与代理服务有关。错误代码通常以[E]开头，表示错误级别。在这个日志中，服务尝试通过SSH协议连接到本地服务（可能是一个代理的后端服务），但是连接失败了，可能是因为服务没有在预期的端口上运行，或者网络配置有误。

解决方法：

检查本地服务是否正在运行，并且监听在预期的SSH端口上。
检查服务的配置文件，确保服务的地址和端口设置正确。
检查防火墙规则，确保没有阻止本地服务和代理服务之间的通信。
如果服务是通过Docker或其他容器平台运行的，确保容器正确映射了端口。
查看代理服务的日志以获取更多错误信息，可能会提供更具体的失败原因。
如果问题依然存在，可以尝试重启本地服务和代理服务，有时这可以解决临时的网络问题。

由于报错信息不完整，这里只能给出一般性的指导。需要完整的错误信息或者更多的上下文来提供更具体的解决方案。

System

2024-08-19

所有,golang

在标准的IPv4网络中，TCP和UDP数据包的最大有效负载大小（payload size）通常被称为最大传输单元（Maximum Transmission Unit, MTU）。对于以太网，MTU默认值为1500字节。这意味着TCP数据包（包括TCP头部）最大可以为1500字节，而UDP数据包（包括UDP头部）最大可以为1472字节（1500字节的MTU减去20字节的UDP头部和8字节的IP头部）。

但是，在实际网络传输中，可能会遇到路径MTU发现（Path MTU Discovery）的情况，这时候数据包会被分片（fragmentation）。为了避免这种情况，通常建议设置TCP的MSS（Maximum Segment Size）来限制每个分片的大小，从而减少分片和提高网络效率。

在Go语言中，可以通过设置网络接口来改变TCP的MSS值，但是对于UDP数据包大小，你需要确保你的应用逻辑可以处理UDP数据包的分片。

以下是Go语言中设置TCP MSS的示例代码：




conn, err := net.Dial("tcp", "example.com:80")
if err != nil {
    log.Fatal(err)
}
defer conn.Close()
 
tcpConn := conn.(*net.TCPConn)
 
// 获取默认的TCP头部选项
err = tcpConn.SetWriteBuffer(1024 * 1024) // 设置为1MB的TCP缓冲区
if err != nil {
    log.Fatal(err)
}
 
// 设置MSS为1460字节（1500字节MTU减去20字节TCP头部和20字节IP头部）
err = tcpConn.SetMSS(1460)
if err != nil {
    log.Fatal(err)
}
 
// 此处可以正常发送数据

对于UDP数据包，Go语言没有提供直接设置UDP数据包大小的方法，因为UDP数据包大小受限于MTU。但是，你可以在发送UDP数据前，检查数据大小并确保它不会超过你期望的MTU大小。例如，如果你期望的MTU是1500字节，你可以这样做：




udpConn, err := net.ListenUDP("udp", &net.UDPAddr{
    IP:   net.ParseIP("127.0.0.1"),
    Port: 12345,
})
if err != nil {
    log.Fatal(err)
}
defer udpConn.Close()
 
maxUDPPayloadSize := 1500 - (20 + 8) // 1500 MTU减去20字节UDP头部和8字节IP头部
 
buffer := make([]byte, maxUDPPayloadSize)
// 填充buffer数据
 
n, addr, err := udpConn.WriteMsgUDP(buffer, nil, nil)
if err != nil {
    log.Fatal(err)
}
 
fmt.Printf("Wrote %d bytes to %v\n", n, addr)

在上面的代码中，我们计算了最大UDP有效负载大小，并在发送前确保数据包大小不超过这个值。如果你需要发送大于1500字节的数据，你需要分片你的数据并在接收端重新组合它们，这通常是通过UDP协议栈自动完成的，除非你的网络环境不允许路

- 阅读更多 -