NetworkCommsDotNet ，如何在此代码中反转 TCP 客户端和服务器功能？

Question

编辑有了 NetworkCommsDotNet 提供的所有强大功能，看起来这个库不再受到积极支持。我正在改变方向以接受 Eser 的回应作为答案。我测试了提供的代码并且它有效。感谢您的帮助。

下面是我的简单 TCP 客户端-服务器代码，基于 NetworkCommsDotNet 库。客户端周期性地向服务器发送一个"object"的变化位置，服务器显示它们。这工作正常，但是，我想要实现的恰恰相反：我希望客户端只连接到服务器，一旦服务器检测到连接，它就会开始定期将一些 X 和 Y 坐标发送回客户端。我无法使用 NetworkCommsDotNet 完成此操作，感谢任何帮助。

客户：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using NetworkCommsDotNet;
using NetworkCommsDotNet.Connections.TCP;

namespace ObjectPositionClient
{
  class Program
  {
    static void Main(string[] args)
    {

        try { 
            var conn = TCPConnection.GetConnection(new ConnectionInfo("127.0.0.1", 50747));

            System.Timers.Timer tmer;
            tmer = new System.Timers.Timer(3000);
            tmer.Elapsed += (sender, e) => TimerElapsed(sender, e, conn);
            tmer.Enabled = true;

            Console.WriteLine("Press any key to exit client.");
            Console.ReadKey(true);
            NetworkComms.Shutdown();
        }
        catch (Exception e)
        {
            Console.WriteLine(e.InnerException + "\n" + e.Message);
        }

    }

    static public void TimerElapsed(object sender, System.Timers.ElapsedEventArgs e, TCPConnection conn)
    {
        Random rnd = new Random();
        int X = rnd.Next(1, 101);
        int Y = rnd.Next(1, 51);

        conn.SendObject("Message", "X=" + X + "; Y=" + Y);
    }
  }
}

服务器：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using NetworkCommsDotNet;
using NetworkCommsDotNet.Connections;


namespace ObjectPositionServer
{
  class Program
  {
    static void Main(string[] args)
    {

        try
        {
            var con = Connection.StartListening(ConnectionType.TCP, new System.Net.IPEndPoint(System.Net.IPAddress.Any, 50747));

            NetworkComms.AppendGlobalIncomingPacketHandler<string>("Message", PrintIncomingMessage);

            Console.WriteLine("Server ready. Press any key to shutdown.");
            Console.ReadKey(true);
            NetworkComms.Shutdown();

        }
        catch (Exception e)
        {
            Console.WriteLine(e.InnerException + "\n" + e.Message);
        }

    }


    private static void PrintIncomingMessage(PacketHeader header, Connection 
     connection, string message)
    {
        Console.WriteLine(message + "\n");

    }
  }
}

Answer 1

这是一个基于 TCP 的基本 client/server 示例。每当客户端连接到服务器时，服务器都会向客户端发送 10 个字符串，然后关闭连接。我认为这与您的情况相似。

using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;

public class TCPTest
{
    public static void StartAll()
    {

        Task.Run(() => StartServer());
        Task.Run(() => StartClient());
    }

    static void StartServer()
    {
        TcpListener listener = new TcpListener(IPAddress.Any, 12345);
        listener.Start();
        Console.WriteLine("Server Started");
        while (true)
        {
            var client = listener.AcceptTcpClient();
            Console.WriteLine("A new client is connected");
            ThreadPool.QueueUserWorkItem(ServerTask,client);

        }
    }

    static void ServerTask(object o)
    {
        using (var tcpClient = (TcpClient)o)
        {
            var stream = tcpClient.GetStream();
            var writer = new StreamWriter(stream);
            for (int i = 0; i < 10; i++)
            {
                writer.WriteLine($"packet #{i + 1}");
                writer.Flush();
                Thread.Sleep(1000);
            }

            Console.WriteLine("Server session ended..");
        }
    }


    static void StartClient()
    {
        TcpClient client = new TcpClient();
        client.Connect("localhost", 12345);
        var stream = client.GetStream();
        var reader = new StreamReader(stream);
        string line = "";
        while((line = reader.ReadLine()) != null)
        {
            Console.WriteLine("Client received: "+ line);
        }
        Console.WriteLine("Client detected end of the session");
    }
}

使用TCPTest.StartAll();开始测试。

您甚至可以telnet 到此服务器。 telnet localhost 12345

编辑

既然你已经评论过，你想在客户端和服务器之间传输对象，我修改了代码来展示它是如何完成的（使用 Json.Net）。这次，服务器向客户端发送 10 User 个对象。

我会 post 它作为新代码，以防有人想看到细微差别。

using Newtonsoft.Json;
using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;

public class TCPTest
{
    //Sample class to transfer between server and client
    public class User
    {
        public string Name { get; set; }
        public int  Id { get; set; }
        public DateTime BirthDate { set; get; }
    }


    public static void StartAll()
    {

        Task.Run(() => StartServer());
        Task.Run(() => StartClient());
    }

    static void StartServer()
    {
        TcpListener listener = new TcpListener(IPAddress.Any, 12345);
        listener.Start();
        Console.WriteLine("Server Started");
        while (true)
        {
            var client = listener.AcceptTcpClient();
            Console.WriteLine("A new client is connected");
            ThreadPool.QueueUserWorkItem(ServerTask, client);

        }
    }

    static void ServerTask(object o)
    {
        using (var tcpClient = (TcpClient)o)
        {
            var stream = tcpClient.GetStream();
            var writer = new StreamWriter(stream);
            for (int i = 0; i < 10; i++)
            {
                var user = new User() { Name = $"Joe{i}", Id = i , BirthDate = DateTime.Now.AddDays(-10000)}; 
                var json = JsonConvert.SerializeObject(user);
                writer.WriteLine(json); 
                writer.Flush();
                Thread.Sleep(1000);
            }

            Console.WriteLine("Server session ended..");
        }
    }


    static void StartClient()
    {
        TcpClient client = new TcpClient();
        client.Connect("localhost", 12345);

        var stream = client.GetStream();
        var reader = new StreamReader(stream);
        string json = "";
        while ((json = reader.ReadLine()) != null)
        {
            var user = JsonConvert.DeserializeObject<User>(json);
            Console.WriteLine($"Client received: Name={user.Name} Id={user.Id} BirthDate={user.BirthDate}");
        }
        Console.WriteLine("Client detected end of the session");
    }
}

NetworkCommsDotNet ，如何在此代码中反转 TCP 客户端和服务器功能？

NetworkCommsDotNet , how can I reverse TCP client and server functions in this code?

c#

tcp

client-server