0

Я имею консольный чат на сокетах, вот его код:

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

namespace SocketTcpServer
{
    class Program
    {
        static int port = 8005; // порт для приема входящих запросов


        static void Main(string[] args)
        {
            // получаем адреса для запуска сокета
            IPEndPoint ipPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), port);


            Socket listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                // связываем сокет с локальной точкой, по которой будем принимать данные
                listenSocket.Bind(ipPoint);

                // начинаем прослушивание
                listenSocket.Listen(10);

                Console.WriteLine("Сервер запущен. Ожидание подключений...");

                while (true)
                {

                    Socket handler = listenSocket.Accept();
                    // получаем сообщение
                    Task.Factory.StartNew(() =>
                    {
                        StringBuilder builder = new StringBuilder();
                        int bytes = 0; // количество полученных байтов
                        byte[] data = new byte[256]; // буфер для получаемых данных

                        do
                        {
                            bytes = handler.Receive(data);
                            builder.Append(Encoding.Unicode.GetString(data, 0, bytes));
                        }
                        while (handler.Available > 0);

                        Console.WriteLine(DateTime.Now.ToShortTimeString() + ": " + builder.ToString());

                        // отправляем ответ
                        string message = "ваше сообщение доставлено";
                        data = Encoding.Unicode.GetBytes(message);
                        handler.Send(data);
                        
                        // закрываем сокет
                        handler.Shutdown(SocketShutdown.Both);
                        handler.Close();
                    });
                }

            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }

        }
    }
}

Это был Сервер.

Сейчас покажу код клиента:

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

namespace SocketTcpClient
{
    class Program
    {
        // адрес и порт сервера, к которому будем подключаться
        static int port = 8005; // порт сервера
        static string address = "127.0.0.1"; // адрес сервера
        static string message = null;
        static void Main(string[] args)
        {
            
        
            while (message != "EndProgram")
            {
                try
                {
                    IPEndPoint ipPoint = new IPEndPoint(IPAddress.Parse(address), port);

                    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                    // подключаемся к удаленному хосту
                    socket.Connect(ipPoint);
                    Console.Write("Введите сообщение:");
                    message = Console.ReadLine();
                    byte[] data = Encoding.Unicode.GetBytes(message);
                    socket.Send(data);

                    // получаем ответ
                    data = new byte[256]; // буфер для ответа
                    StringBuilder builder = new StringBuilder();
                    int bytes = 0; // количество полученных байт

                    do
                    {
                        bytes = socket.Receive(data, data.Length, 0);
                        builder.Append(Encoding.Unicode.GetString(data, 0, bytes));
                    }
                    while (socket.Available > 0);
                    Console.WriteLine("ответ сервера: " + builder.ToString());

                    // закрываем сокет
                    // socket.Shutdown(SocketShutdown.Both);
                    // socket.Close();
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
            Console.WriteLine("Для завершения нажмите любую кнопку.");
            Console.Read();
        }
    }
}

Как я могу сделать так, чтобы мой клиент слушал сервер постоянно и получал от него сообщения? Наподобие дискорда или чата в стиме, где люди отправляют сообщения и сервер их пересылает пользователям?

19
  • Есть консольный чат на вебсокетах - сойдет?
    – aepot
    14 мар 2021 в 18:55
  • А так, вам клиент надо распилить на 2 потока, один должен принимать данные из сокета и выбрасывать их в консоль, второй должен читать консоль и писать прочитанное в сокет, 2 потока, в каждом бесконечный цикл.
    – aepot
    14 мар 2021 в 19:00
  • @aepot , Простите, я не могу понять, что означает "читать консоль и писать прочитанное в сокет"?
    – CsHarpUser
    14 мар 2021 в 19:08
  • ReadLine и socket.Send
    – aepot
    14 мар 2021 в 19:19
  • Ну socket.Write же нету? Я походу что-то не так понял
    – CsHarpUser
    14 мар 2021 в 19:20

0

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Посмотрите другие вопросы с метками или задайте свой вопрос.