Как завершить цикл по таймауту, TCPServer Socket C # - PullRequest
Новая
       18

Как завершить цикл по таймауту, TCPServer Socket C #

0 голосов
/ 26 июня 2018

Я создаю TCP-сервер / клиент.Что касается этого проекта, мне нужно только запустить эту функцию в течение 60 секунд, и после этого она будет завершена.Может ли кто-нибудь помочь мне исправить этот код?

public static void SendTCPServer(string content)
    {
        Stopwatch timer = new Stopwatch();
        timer.Start();

        byte[] data = new byte[1024];
        IPEndPoint ipep = new IPEndPoint(IPAddress.Any,
                               8080);

        Socket newsock = new
            Socket(AddressFamily.InterNetwork,
                        SocketType.Stream, ProtocolType.Tcp);

        newsock.Bind(ipep);
        newsock.Listen(10);
        while (timer.Elapsed.TotalSeconds < 60)
        {
            Console.WriteLine("Waiting for a client...");
        Socket client = newsock.Accept();
        IPEndPoint clientep =
                     (IPEndPoint)client.RemoteEndPoint;


            Console.WriteLine("Connected with {0} at port {1}",
                            clientep.Address, clientep.Port);


            string welcome = content;
            data = Encoding.ASCII.GetBytes(welcome);
            client.Send(data, data.Length,
                              SocketFlags.None);

            Console.WriteLine("Disconnected from {0}",
                              clientep.Address);
            client.Close();
            newsock.Close();
            return;
        }
        timer.Stop();
        //client.Close();
        newsock.Close();
        return;
    }

1 Ответ

0 голосов
/ 26 июня 2018

Вы можете использовать нить для этого. 

 public class Parameters
 {
    public Socket _socket;
    public string content;
 }

//calling part
  Thread listenerThread = new Thread(new ParameterizedThreadStart(SendTCPServer));
        Socket newsock = new
           Socket(AddressFamily.InterNetwork,
                       SocketType.Stream, ProtocolType.Tcp);
        listenerThread.Start(new Parameters { _socket = newsock, content = "Welcome" 
 });

        Thread.Sleep(60000);
            newsock.Dispose();
//calling part end
 public static void SendTCPServer(object obj)
    {
        try
        {
            Stopwatch timer = new Stopwatch();
            timer.Start();

            byte[] data = new byte[1024];
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any,
                                   8080);

            Parameters param = obj as Parameters;


            Socket newsock = param._socket;
            newsock.Bind(ipep);
            newsock.Listen(10);
            while (timer.Elapsed.TotalSeconds < 60)
            {
                Console.WriteLine("Waiting for a client...");
                Socket client = newsock.Accept();
                IPEndPoint clientep =
                             (IPEndPoint)client.RemoteEndPoint;


                Console.WriteLine("Connected with {0} at port {1}",
                                clientep.Address, clientep.Port);


                string welcome = param.content;
                data = Encoding.ASCII.GetBytes(welcome);
                client.Send(data, data.Length,
                                  SocketFlags.None);

                Console.WriteLine("Disconnected from {0}",
                                  clientep.Address);
                client.Close();
                newsock.Close();
                return;
            }
            timer.Stop();
            //client.Close();
            newsock.Close();
            return;
        }
        catch (Exception ex)
        {


        }

    }
...