解决C#与Python Telegram Bot通信中的套接字端口占用问题

import socket
import time
# 假设这里有你的Telegram bot相关导入，例如 from aiogram import Bot, Dispatcher, types, F, Router, html
# from aiogram.filters import CommandStart
# from aiogram.types import Message, CallbackQuery
# from aiogram.utils.markdown import hbold

# 仅为示例，实际Telegram Bot逻辑可能更复杂
# router = Router() # 如果你使用aiogram 3.x

stop_output = False # 用于控制服务器循环的全局变量

# @router.callback_query(lambda c: c.data == "start_button") # 假设此函数在Telegram Bot的事件循环中被调用
async def start_socket_server_and_listen():
    global stop_output
    stop_output = False
    # await call.answer() # 如果在callback_query中，需要应答

    # 使用新的端口号，例如 50001
    server_port = 50001
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    try:
        server_socket.bind(("localhost", server_port))
        server_socket.listen(1)
        print(f"Python服务器已启动，监听端口: {server_port}")

        while not stop_output:
            # 增加一个超时，防止accept()无限阻塞，以便检查stop_output
            server_socket.settimeout(1.0) 
            try:
                client_socket, address = server_socket.accept()
                print(f"接收到来自 {address} 的连接")

                data = client_socket.recv(1024).decode("utf-8")
                print(f"接收到的数据: {data}")

                # 这里可以添加将数据发送到Telegram Bot的逻辑
                # 例如：await bot.send_message(chat_id, data)

                client_socket.close()
            except socket.timeout:
                # 超时时检查stop_output，继续循环
                pass
            except Exception as e:
                print(f"套接字操作错误: {e}")
                break # 发生其他错误时退出循环

    except OSError as e:
        print(f"绑定套接字失败: {e}")
    finally:
        server_socket.close()
        print("Python服务器已关闭。")

# 实际应用中，此函数会在Telegram Bot的事件循环中被调度
# 例如，在bot启动时或某个命令触发时
# import asyncio
# if __name__ == "__main__":
#     asyncio.run(start_socket_server_and_listen())

using System;
using System.Net.Sockets;
using System.Text;
using Newtonsoft.Json; // 假设您已安装Newtonsoft.Json

public class SocketClient
{
    public static void Main(string[] args)
    {
        // 使用与Python服务器相同的端口号
        int serverPort = 50001; 
        string serverIp = "localhost";

        try
        {
            using (TcpClient client = new TcpClient(serverIp, serverPort))
            {
                Console.WriteLine($"成功连接到Python服务器: {serverIp}:{serverPort}");

                using (NetworkStream stream = client.GetStream())
                {
                    // 假设ArbitragVnytribirgevoi是一个包含要发送数据的对象
                    // 实际应用中，您需要定义这个对象的结构
                    var ArbitragVnytribirgevoi = new {
                        Source = "C# App",
                        Timestamp = DateTime.Now,
                        Data = "Hello from C#!"
                    };

                    string message = JsonConvert.SerializeObject(ArbitragVnytribirgevoi);
                    byte[] buffer = Encoding.UTF8.GetBytes(message);

                    stream.Write(buffer, 0, buffer.Length);
                    Console.WriteLine($"已发送数据: {message}");
                }
            }
        }
        catch (SocketException ex)
        {
            Console.WriteLine($"连接或发送数据失败: {ex.Message}");
            Console.WriteLine($"错误代码: {ex.ErrorCode}");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"发生未知错误: {ex.Message}");
        }

        Console.WriteLine("按任意键退出...");
        Console.ReadKey();
    }
}