标签 tcp 下的文章

2024-08-16

以下是一个简化的Go TCP服务器示例，用于处理Redis协议。这个示例不完整，只展示了如何建立TCP连接并简单处理命令。

package main

import (
    "bufio"
    "fmt"
    "net"
)

// 简单的处理Redis命令的函数
func handleRedisCommand(conn net.Conn, cmd string) {
    if cmd == "PING" {
        conn.Write([]byte("+PONG\r\n"))
    } else {
        conn.Write([]byte("-ERR unknown command\r\n"))
    }
}

func main() {
    listener, err := net.Listen("tcp", ":6379")
    if err != nil {
        panic(err)
    }
    defer listener.Close()

    fmt.Println("Redis server is running on port 6379...")
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Error accepting connection:", err)
            continue
        }

        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()

    reader := bufio.NewReader(conn)
    for {
        line, err := reader.ReadString('\n')
        if err != nil {
            fmt.Println("Error reading command:", err)
            return
        }

        cmd := parseRedisCommand(line)
        handleRedisCommand(conn, cmd)
    }
}

// 解析Redis命令的函数，这里需要完善解析逻辑
func parseRedisCommand(line string) string {
    // 示例解析，仅支持简单的PING命令
    return line[1 : len(line)-3]
}

这段代码创建了一个监听在6379端口的TCP服务器，并简单处理了连接和"PING"命令。这个示例不包括完整的Redis协议解析，只展示了如何开始接收TCP连接和简单处理命令。实际应用中，你需要实现完整的Redis命令解析和响应生成。

- 阅读更多 -

Modbus平台：协议中间件(支持Modbus TCP、RTU、ASCII)

System

2024-08-16

所有,中间件

Modbus是一种工业通信协议，常用于工业自动化设备之间的数据通信。Modbus TCP、RTU和ASCII是Modbus的三种传输方式，其中TCP是基于以太网的传输方式，RTU和ASCII是基于串行链路的传输方式。

在开发基于Modbus协议的应用时，通常需要一个Modbus协议栈或者中间件来处理不同设备之间的通信。以下是一个简单的Python示例，使用pymodbus库来实现Modbus TCP服务器。

首先，需要安装pymodbus库：

pip install pymodbus

然后，可以使用以下代码创建一个简单的Modbus TCP服务器：

from pymodbus.server.sync import StartTcpServer
from pymodbus.datastore import ModbusSequentialDataBlock, ModbusSlaveContext, ModbusServerContext
from pymodbus.transaction import ModbusRtuFramer, ModbusBinaryFramer

# 设置从机上的寄存器和线圈数量
data_block = ModbusSequentialDataBlock(0, [17]*10 + [3]*10 + [65535]*10)

# 设置数据块从机上下文
context = ModbusSlaveContext(
    di=data_block,
    co=data_block,
    hr=data_block,
    ir=data_block
)

# 创建服务器上下文
server = ModbusServerContext(context)

# 设置服务器和端口
address = ("localhost", 502)

# 创建TCP服务器
start_server = StartTcpServer(server, address=address)

# 启动服务器
start_server.start()

这段代码创建了一个Modbus TCP服务器，它有10个寄存器，10个线圈，10个保持寄存器。它将所有的输入、输出、保持寄存器和线圈值初始化为示例数据。

注意：在实际应用中，你需要根据自己的网络环境和设备配置相应地调整IP地址和端口号，并且配置数据块的大小和类型。

- 阅读更多 -

Java基于Modbus4j实现Modbus Tcp

System

2024-08-14

所有,java

以下是一个使用modbus4j实现Modbus TCP客户端的简单示例代码。请注意，在运行此代码之前，您需要有一个Modbus TCP服务器运行在网络上的某个地址。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import org.apache.log4j.BasicConfigurator;

import com.intelligt.modbus.jlibmodbus.Master;
import com.intelligt.modbus.jlibmodbus.exception.ModbusInitException;
import com.intelligt.modbus.jlibmodbus.exception.ModbusTransportException;

public class ModbusTcpClientExample {
    public static void main(String[] args) {
        BasicConfigurator.configure();

        try {
            ExecutorService executor = Executors.newSingleThreadExecutor();
            Master master = Master.createTcpMaster("127.0.0.1", 502, true, "127.0.0.1", 3);
            executor.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        master.init();
                        short[] registers = master.readHoldingRegisters(0, 10, 0);
                        for (short register : registers) {
                            System.out.println(register);
                        }
                    } catch (ModbusTransportException e) {
                        e.printStackTrace();
                    } finally {
                        try {
                            master.destroy();
                        } catch (ModbusInitException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });

            executor.shutdown();
            executor.awaitTermination(10, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            e.printStackTrace();
        }
    }
}

在这个示例中，我们首先配置了日志记录。然后，我们创建了一个Modbus TCP客户端，指定了服务器的IP地址和端口号。在单独的线程中，我们初始化了Master实例，并读取了从地址0开始的10个保持寄存器的数值。读取到的寄存器值将被打印输出。最后，我们在完成操作后销毁了Master实例，并关闭了执行器服务。

请注意，上述代码中的IP地址和端口号以及从机地址都应该根据您的实际Modbus TCP服务器进行相应的修改。

System

2024-08-14

所有,linux

在TCP中，快重传（SACK）和滑动窗口（TCP流量控制）是两种用于改善网络传输效率的机制。

快重传是一种SACK（选择性确认）的机制，它允许接收方通过单个重复ACK向发送方通知丢失的数据段，而不是等待超时。这样可以使得发送方尽快重传丢失的数据，而不是等待整个重传算法的时间周期。

以下是快重传的示例代码（假设已有TCP包处理逻辑）：

// 假设tcp_recv是TCP接收数据的函数
void tcp_recv(struct tcp_packet *packet) {
    // ... 接收数据处理逻辑 ...

    // 检测数据丢失
    if (数据丢失) {
        // 通知快重传
        tcp_send_dup_ack(packet->seq_num);
        // 标记快重传
        tcp_set_sack_flag();
        // 重传丢失的数据
        tcp_retransmit_lost_data(packet->seq_num);
    }
}

滑动窗口是TCP用于流量控制的机制，它通过调整发送方的发送速率来避免网络拥塞。

以下是设置TCP滑动窗口大小的示例代码：

// 设置TCP滑动窗口大小
void tcp_set_window_size(int new_window_size) {
    // 确保窗口大小不超过TCP协议允许的最大值
    if (new_window_size > TCP_MAX_WINDOW_SIZE) {
        new_window_size = TCP_MAX_WINDOW_SIZE;
    }
    // 设置窗口大小
    tcp_window_size = new_window_size;
}

// 更新滑动窗口
void tcp_update_window(struct tcp_packet *packet) {
    // 根据接收情况调整窗口大小
    tcp_set_window_size(当前窗口大小 + packet->win_size_increment);
}

快重传和滑动窗口是TCP协议的重要组成部分，用于提高网络传输的效率和稳定性。在实际编程中，这些机制通常由操作系统的TCP/IP栈实现，开发者通常不需要手动处理它们。但了解它们的工作原理和效果可以帮助开发者更好地理解网络编程。

- 阅读更多 -

Linux：对TCP阻塞控制/面向字节流/异常的理解

System

2024-08-14

所有,php

在Linux中，TCP的块模式和非阻塞模式是两种常见的I/O模型。

阻塞I/O（blocking I/O）：默认情况下，所有的套接字都是阻塞的。当进程调用一个阻塞的I/O函数时，该进程会被挂起，直到有数据可供处理。
非阻塞I/O（nonblocking I/O）：通过设置套接字选项为非阻塞，进程可以直接调用recvfrom()等函数，如果没有数据可读，这些函数会立即返回一个EWOULDBLOCK错误，而不会挂起进程。
TCP字节流（TCP stream）：TCP作为一种字节流协议，提供了一种可靠的、面向连接的数据传输服务。
TCP异常（TCP exceptions）：TCP异常指的是TCP协议中的一些特殊情况，如连接断开、网络超时等。

对于TCP异常的处理，可以使用select()或poll()系统调用，它们可以等待多个文件描述符上的某种事件，如果任何一个文件描述符上的事件发生，select()或poll()就会返回。这样，你可以检查哪个socket或文件描述符可以进行无阻塞的I/O操作。

以下是一个使用select()处理TCP异常的简单示例：

#include <sys/select.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdio.h>

int main() {
    fd_set rfds;
    struct timeval tv;
    int retval;

    // 清除文件描述符集合
    FD_ZERO(&rfds);

    // 添加你想要检查的文件描述符到集合中
    FD_SET(0, &rfds); // 标准输入
    FD_SET(sockfd, &rfds); // 你的socket文件描述符

    // 超时设置
    tv.tv_sec = 1; // 秒
    tv.tv_usec = 0; // 微秒

    // 调用select()
    retval = select(sockfd + 1, &rfds, NULL, NULL, &tv);

    if (retval == -1) {
        // 错误处理
        perror("select()");
        exit(1);
    } else if (retval) {
        // 如果retval非零，则至少有一个描述符的事件发生了
        if (FD_ISSET(sockfd, &rfds)) {
            // 你的socket文件描述符上的事件
            // 可能是可读、可写或异常
            // 对于异常，你可能需要调用getsockopt()来检查
            // SOCKET_ERROR来获取错误代码
        }
    } else {
        // 超时处理
        printf("select() timed out.\n");
    }

    return 0;
}

在这个例子中，select()会等待数据在标准输入或者指定的socket上可读、可写或者发生异常。如果在指定时间内没有任何事件发生，select()会超时返回。如果发生异常，你可能需要通过getsockopt()函数和SO\_ERROR选项来检查具体的错误代码。

- 阅读更多 -

Linux 下 nc 发送接收 udp、tcp数据

System

2024-08-14

所有,php

在Linux环境下，可以使用nc（netcat）命令来发送和接收UDP和TCP数据。

UDP数据的发送和接收

发送UDP数据：

echo "Hello, World!" | nc -u -w 1 127.0.0.1 12345

在另一个终端接收UDP数据：

nc -ul 12345

TCP数据的发送和接收

发送TCP数据：

echo "Hello, World!" | nc 127.0.0.1 12345

在另一个终端接收TCP数据：

nc -l 12345

这里，-u 选项用于UDP，没有 -u 是TCP。-w 选项用于设置超时时间，127.0.0.1 是本地回环地址，12345 是端口号。

请确保目标机器上的端口号没有被其他服务占用，并且你有权限在这些端口上进行通信。

System

2024-08-13

所有,linux

在Linux系统中，你可以使用find命令来查找和删除7天前的文件。以下是两种常见的方法：

使用find命令查找并删除7天前的文件：

find /path/to/directory -type f -mtime +6 -exec rm -f {} \;

解释：

/path/to/directory 是你想要搜索文件的目录路径。
-type f 表示搜索文件。
-mtime +6 表示修改时间超过6天的文件。
-exec rm -f {} \; 对符合条件的文件执行删除操作。

使用find命令结合xargs来删除文件：

find /path/to/directory -type f -mtime +6 | xargs rm -f

解释：

这种方法使用xargs来避免在有大量文件要删除的情况下可能出现的命令行参数限制问题。

请根据你的具体需求选择合适的方法，并确保你有足够的权限来删除目标目录下的文件。在执行删除操作之前，请务必检查find命令的输出，以确保不会误删重要文件。

- 阅读更多 -

Go语言实战：Go的网络编程与TCP_UDP

System

2024-08-13

所有,golang

以下是针对Go语言网络编程的TCP和UDP的简单示例代码。

TCP服务器端：

package main

import (
    "fmt"
    "net"
)

func main() {
    listener, err := net.Listen("tcp", "localhost:50000")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer listener.Close()

    fmt.Println("Listening on localhost:50000...")
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println(err)
            continue
        }
        go handleTCPConnection(conn)
    }
}

func handleTCPConnection(conn net.Conn) {
    defer conn.Close()
    fmt.Fprintf(conn, "Hello, client! Type 'exit' to quit.\n")
    for {
        buf := make([]byte, 1024)
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println(err)
            return
        }
        if string(buf[:n-1]) == "exit" {
            fmt.Println("Client exited.")
            return
        }
        fmt.Fprintf(conn, "Received: %s\n", string(buf[:n-1]))
    }
}

TCP客户端：

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)

func main() {
    conn, err := net.Dial("tcp", "localhost:50000")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer conn.Close()

    go func() {
        reader := bufio.NewReader(os.Stdin)
        for {
            data, err := reader.ReadString('\n')
            if err != nil {
                fmt.Println(err)
                return
            }
            trimmedData := strings.TrimSpace(data)
            if trimmedData == "exit" {
                conn.Close()
                return
            }
            conn.Write([]byte(trimmedData))
        }
    }()

    for {
        buf := make([]byte, 1024)
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println(err)
            return
        }
        fmt.Printf("Server: %s\n", string(buf[:n]))
    }
}

UDP服务器端：

package main

import (
    "fmt"
    "net"
)

func main() {
    addr, err := net.ResolveUDPAddr("udp", "localhost:50001")
    if err != nil {
        fmt.Println(err)
        return
    }

    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println(err)
        return
    }
    defer conn.Close()

    fmt.Println("Listening on localhost:50001...")
    for {
        handleUDPConnection(conn)
    }
}

func handleUDPConnection(conn *net.UDPConn) {
    buffer := make([]byte, 1024)
    n, addr, err := conn.ReadFromUDP(buffer)
    if err != nil {
        fmt.Println(err)
        return
    }
    message := string(buffer[:n])
    fmt.Printf("Received message: %s from %s\n", message, addr)

    _, err = conn.WriteToUDP([]byte("Hello, client!"),

- 阅读更多 -

【网络原理】使用Java基于TCP搭建简单客户端与服务器通信

System

2024-08-12

所有,java

以下是一个简单的Java TCP Socket客户端和服务器端的例子。服务器端接收客户端发送的消息并将其打印出来。

服务器端 (Server.java):

import java.io.*;
import java.net.*;

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(1234); // 监听1234端口
            Socket socket = serverSocket.accept(); // 等待客户端连接
            System.out.println("Client connected!");

            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String str = in.readLine();
            System.out.println("Client says: " + str);

            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            out.println("Server received the message.");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (serverSocket != null) {
                serverSocket.close();
            }
        }
    }
}

客户端 (Client.java):

import java.io.*;
import java.net.*;

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = null;
        try {
            socket = new Socket("localhost", 1234); // 连接到本地主机的1234端口
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            out.println("Hello from Client"); // 发送消息
            System.out.println("Client says: Hello from Client");

            String response = in.readLine(); // 接收响应
            System.out.println("Server says: " + response);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (socket != null) {
                socket.close();
            }
        }
    }
}

在运行这些代码之前，请确保没有其他服务占用1234端口。运行服务器端 (Server.java) 将会创建一个监听1234端口的服务器，然后运行客户端 (Client.java) 将会连接到服务器并发送消息。服务器接收到消息后，将响应客户端并关闭连接。

- 阅读更多 -

【Linux】TCP套接字编程

System

2024-08-09

所有,linux

在Linux中，TCP套接字编程通常涉及以下步骤：

创建套接字（socket）。
绑定套接字到一个特定的地址和端口（bind）。
监听连接请求（listen）。
接受连接（accept）。
发送/接收数据（send/recv）。
关闭套接字（close）。

以下是一个简单的TCP服务器和客户端示例代码：

TCP 服务器端示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>

int main() {
    int server_fd, new_socket;
    struct sockaddr_in address;
    int opt = 1;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};
    const char *greeting = "Hello from server";

    // 创建套接字
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    // 绑定套接字到地址和端口
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(8080);

    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    // 监听连接请求
    if (listen(server_fd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    // 接受连接
    if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
        perror("accept");
        exit(EXIT_FAILURE);
    }

    // 发送数据
    send(new_socket, greeting, strlen(greeting), 0);

    // 接收数据
    if (recv(new_socket, buffer, 1024, 0) == 0) {
        printf("Client disconnected\n");
    } else {
        printf("Received message: %s\n", buffer);
    }

    // 关闭套接字
    close(new_socket);
    close(server_fd);
    return 0;
}

TCP 客户端示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>

int main(int argc, char *argv[]) {
    int sock;
    struct sockaddr_in serv_addr;
    char buffer[1024] = {0};

    if (argc < 2) {
        printf("Please provide the server ip address as first argument\n");
        return 1;
    }

    // 创建套接字
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        perror("Socket creation error");
        return 1;
    }

    memset(&serv_addr, '0', sizeof(serv_addr));

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(8080);

    if (inet_pton(AF_INET, argv[1], &serv_addr.sin_addr) <= 0) {
        per

- 阅读更多 -