Обеспечить возможность подключения к серверу нескольких клиентов

@Mansi · Регистрация: 10.03.2013

Студворк — интернет-сервис помощи студентам

Люди добрые прошу помощи. У меня есть простенький код сервера с сокетом.
Проблема в том, что к серверу может подключиться только один клиент и с ним работать.
А если запущу второй, сервер просто будет его игнорировать до тех пор, пока первый не закончит работу.

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
        static Connect()
        {
            Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //Создаем основной сокет
            IPAddress ipAddress = null; //IP-адресс
            IPEndPoint Addr = null; //конечная точка(IP и порт)
            Addr = new IPEndPoint(IPAddress.Any, 8124); //"localhost" = 127.0.0.1
            s.Bind(Addr); //"Адресуем" сокет
            s.Listen(10); //Обозначаем количество ожидающих в очереди на подключение
            Console.WriteLine("Ждем коннекта...");
            Socket socket = s.Accept(); //Ожидаем подключения
            Console.WriteLine("Есть коннект!");
            while (Console.KeyAvailable) //Пока не нажата клавиша
            {
                byte[] msg = new byte[socket.Available];
                socket.Receive(msg); //Принимаем МСГ
                Console.WriteLine(Encoding.UTF8.GetString(msg)); //Конвертируем и выводим
            }
            socket.Close(); //Закрываем сокет
            s.Close(); //Закрываем сокеты
        }

Это код сервера, запускаю его в Main вот так Connect conn = new Connect();

Как я понял, мне нужно Socket socket = s.Accept(); сделать циклом и сделать так, чтоб всё передавалось в новый поток. Тем самым, я могу запустить хоть 3 клиента и все их сообщения будут выводиться мне на консоль.

Буду очень рад, если кто-то поможет и исправит мой код. Т.к. сам сколько не бился, просто не получается.

Добавлено через 11 часов 12 минут
Никто не знает как сделать несколько потоков в цикле? =(((

Добавлено через 6 часов 3 минуты
Переписал код до такого состояния...

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
        static Connect()
        {
            Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // Создаем основной сокет
            IPHostEntry ipHostInfo = Dns.GetHostEntry("127.0.0.1"); // Пишем IP адрес
            IPAddress ipAddress = ipHostInfo.AddressList[0];
            IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 8124); // Указываем порт
            s.Bind(localEndPoint); // "Адресуем" сокет
            s.Listen(10); // Обозначаем количество ожидающих в очереди на подключение
            Console.WriteLine("Ждем коннекта... {0}", localEndPoint);
            Socket socket = s.Accept(); // Ожидаем подключения
            Console.WriteLine("Есть коннект!");
            while (true) // Бесконечность...
            {
                byte[] msg = new byte[socket.Available];
                socket.Receive(msg); // Принимаем Мессагу(пакет)
                Console.WriteLine(Encoding.UTF8.GetString(msg)); // Конвертируем и выводим
            }
            socket.Close(); // Закрываем сокет
            s.Close(); // Закрываем сокеты
        }

Получается, если первый человек подключится от него я нормально получаю сообщения. Если связь прервётся, программа начинает с большой скоростью логировать что-то и получается чёрный экран. А если потом ещё раз подключится, соединение будет нормальным/стабильным. Только вот в логах - пусто.

@Exerion · 28.05.2015, 15:37

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
static Connect()
{
    Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // Создаем основной сокет
    IPHostEntry ipHostInfo = Dns.GetHostEntry("127.0.0.1"); // Пишем IP адрес
    IPAddress ipAddress = ipHostInfo.AddressList[0];
    IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 8124); // Указываем порт
    s.Bind(localEndPoint); // "Адресуем" сокет
    s.Listen(10); // Обозначаем количество ожидающих в очереди на подключение
    while (true)
    {
        Console.WriteLine("Ждем коннекта... {0}", localEndPoint);
        Socket socket = s.Accept(); // Ожидаем подключения
        Thread t = new Thread(new ParameterizedThreadStart(Communicating));
        t.IsBackground = true;
        t.Start(socket);
    }
    s.Close(); // Закрываем сокеты
}
 
static void Communicating(object s)
{
    Socket socket = s as Socket;
    Console.WriteLine("Есть коннект!");
    while (true) // Бесконечность...
    {
        byte[] msg = new byte[socket.Available];
        socket.Receive(msg); // Принимаем Мессагу(пакет)
        Console.WriteLine(Encoding.UTF8.GetString(msg)); // Конвертируем и выводим
    }
    socket.Close(); // Закрываем сокет
}

Учитывайте, что ваши бесконечные циклы не имеют никакой возможности завершиться и все дополнительные потоки будут выполняться бесконечно, равно как и коннект.

@Mansi · 28.05.2015, 19:28 **[ТС]**

Хммм. А как-же socket.Close(), s.Close()?
Судя по информации, они должны закрывать сокет.

И у меня пишет только "Ждем коннекта...".
Получается, соединение работает. Но, я не получаю никаких сообщений на консоль.

Может есть пример сервера, куда можно подключить 2 или более клиентов, и мог читать от них сообщения.
Желательно с сокетом и многопоточностью. Т.к. надо работать с каждым клиентом. И по возможности,
можно было выполнять определённые функции, которые мне нужны.

Скажем, подключается 1 пользователь и он работает по своему потоку, и пишет сообщения в консоль(сервера),
а потом подключается ещё один и тоже пишет. И все сообщения выводятся на консоль. А по возможности, хотел бы добавить функцию чтоб если клиент написал слово "Привет", сервер бы смог отправить ответ "Здравствуй".

Как в таком случае переписать код и это реализовать?

@Mansi · 30.05.2015, 12:37 **[ТС]**

Пожалуй, напишу точнее, что мне нужно сделать.

У меня есть сервер на сокете, к ему может подключить клиент, и скидывать сообщения.
Но, есть проблема, к серверу может подключиться только один клиент и всё. Если клиент прекращает работу,
сервер крашится с ошибкой. Т.е. сокет не закрывается корректно.

Так вот, мне нужно переписать код так, чтоб к серверу могло подключиться много клиентов.
По мимо этого, была многопоточность и корректно закрывался/открывался новый сокет при подключении/отключении клиентов.

Кликните здесь для просмотра всего текста

Вот код, от сюда беру только клиент.

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Timers;
 
class Program
{
    static void Main(string[] args)
    {
        Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //Создаем основной сокет
        IPAddress ipAddress = null; //IP-адресс
        IPEndPoint Addr = null; //конечная точка(IP и порт)
 
        Console.WriteLine("1 - Server\n2 - Client");
        switch (Console.ReadKey(true).KeyChar)
        {
            case '1':
                Console.Title = "Server"; //Сервер
                //ipAddress = Dns.GetHostEntry("localhost").AddressList[0]; //Преобразовуем адрес или IP узла в массив IP и берем первый
                Addr = new IPEndPoint(IPAddress.Any, 8124); //"localhost" = 127.0.0.1
                s.Bind(Addr); //"Адресуем" сокет
                s.Listen(10); //Обозначаем количество ожидающих в очереди на подключение
                Console.WriteLine("Ждем коннекта...");
                for (int i = 0; i < 10; i++)
                {
                    Socket cl_s = s.Accept(); //Ожидаем подключения
                    Console.WriteLine("YES");
                    Thread ClientThread = new Thread(delegate() { ProcessClient(cl_s); });
                    ClientThread.Start();
                }
            break;
            case '2':
                Console.Title = "Client"; //Клиент
                ipAddress = Dns.GetHostEntry("127.0.0.1").AddressList[0];
                Addr = new IPEndPoint(ipAddress, 8124); //"localhost" = 127.0.0.1
                s.Connect(Addr); //Коннектимся к срверу
                while (true) //Вечная истина :)
                {
                    byte[] msg = Encoding.UTF8.GetBytes(Console.ReadLine()); //Конвертируем
                    s.Send(msg); //Отправляем
                }
            break;
        }
        s.Close(); //Закрываем сокет
        Console.ReadKey();
    }
    static void ProcessClient(Socket cl_s)
    {
        Console.WriteLine("Есть коннект!");
        while (!Console.KeyAvailable) //Пока не нажата клавиша
        {
            byte[] msg = new byte[cl_s.Available];
            cl_s.Receive(msg); //Принимаем МСГ
            Console.WriteLine(Encoding.UTF8.GetString(msg)); //Конвертируем и выводим
        }
        cl_s.Close(); //Закрываем сокет
    }
}

А тут, мой сервер...

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Timers;
 
namespace SocketServer
{
    class Program
    {
        static void Main(string[] args)
        {
            // Free memory...
            GC.Collect();
            Console.WriteLine("Всего памяти: {0}", GC.GetTotalMemory(false));
 
            // SocketServer
            Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // Создаем основной сокет
            IPHostEntry ipHostInfo = Dns.GetHostEntry("127.0.0.1"); // Пишем IP адрес
            IPAddress ipAddress = ipHostInfo.AddressList[0];
            IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 8124); // Указываем порт
            s.Bind(localEndPoint); // "Адресуем" сокет
            s.Listen(10); // Обозначаем количество ожидающих в очереди на подключение
            Console.WriteLine("Ждем коннекта... {0}", localEndPoint);
            Socket socket = s.Accept(); // Ожидаем подключения
            Console.WriteLine("Есть коннект!");
            while (true) // Бесконечность...
            {
                byte[] msg = new byte[socket.Available];
                socket.Receive(msg); // Принимаем Мессагу(пакет)
                Console.WriteLine(Encoding.UTF8.GetString(msg)); // Конвертируем и выводим
            }
            socket.Close(); // Закрываем сокет
            s.Close(); // Закрываем сокеты
        }
    }
}

И вот что получаю

Новые блоги и статьи Все статьи Все блоги /
Валидация и контроль данных табличной части документа перед записью Maks 22.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в КА2. Задача: контроль и валидация данных табличной части документа перед записью с учетом регламента компании. . .	Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .	Отчёт о спецтехнике находящейся в ремонте Maks 20.04.2026 Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .	Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)" Hrethgir 19.04.2026 Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .
Запрет удаления строк ТЧ документа при определённом условии Maks 19.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .	Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .

@Mansi 0 / 0 / 0 Регистрация: 10.03.2013 Сообщений: 31
	28.05.2015, 19:28 [ТС]
	Хммм. А как-же socket.Close(), s.Close()? Судя по информации, они должны закрывать сокет. И у меня пишет только "Ждем коннекта...". Получается, соединение работает. Но, я не получаю никаких сообщений на консоль. Может есть пример сервера, куда можно подключить 2 или более клиентов, и мог читать от них сообщения. Желательно с сокетом и многопоточностью. Т.к. надо работать с каждым клиентом. И по возможности, можно было выполнять определённые функции, которые мне нужны. Скажем, подключается 1 пользователь и он работает по своему потоку, и пишет сообщения в консоль(сервера), а потом подключается ещё один и тоже пишет. И все сообщения выводятся на консоль. А по возможности, хотел бы добавить функцию чтоб если клиент написал слово "Привет", сервер бы смог отправить ответ "Здравствуй". Как в таком случае переписать код и это реализовать? 0

Опции темы