0 / 0 / 1
Регистрация: 18.12.2011
Сообщений: 21

Чат на протоколе TCP

07.05.2013, 17:54. Показов 7949. Ответов 6
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Доброго времени суток
Пишу чат на протоколе TCP и столкнулся с такой проблемой: дублируется сообщение себе же... то есть я пишу, как клиент, сообщение - оно остается после написания и присылается себе же от сервера

СКРИНШОТ

как бы по простому обойти эту проблему?

Сервер

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
namespace Server_Chat
{
    class Program
    {
        static TcpListener tcpListener; //монитор подключений TCP клиентов
        static Thread listenThread; //создание потока
 
        static List<TcpClient> clients = new List<TcpClient>(); //список клиентских подключений
        static List<NetworkStream> netStream = new List<NetworkStream>(); //список потока данных
 
        static void Main(string[] args)
        {
            
            try
            {
                Console.WriteLine("Server Started!");
                tcpListener = new TcpListener(IPAddress.Any, 8888);  
                listenThread = new Thread(new ThreadStart(ListenThread)); 
                listenThread.Start(); //старт потока
            }
            catch
            {
                Disconnect();
            }
        }
 
        static void ListenThread()
        {
            tcpListener.Start();
 
            while (true)
            {
                clients.Add(tcpListener.AcceptTcpClient()); //подключение пользователя
                netStream.Add(clients[clients.Count - 1].GetStream()); //обьект для получения данных
 
                Thread clientThread = new Thread(new ParameterizedThreadStart(ClientRecieve));
                clientThread.Start(clients.Count - 1);
            }
        }
 
        static void ClientRecieve(object ID)
        {
            int thisID = (int)ID;
 
            byte[] recieve = new byte[64];
 
            while (true)
            {
                try
                {
                    netStream[thisID].Read(recieve, 0, 64);
                }
                catch
                {
                    Console.WriteLine("Client with ID: " + thisID + " has Disconnected!");
                    break;
                }
                Console.WriteLine(thisID + " message: " + Encoding.ASCII.GetString(recieve));
                SendMessageToClients(recieve);
                for (int i = 0; i < 64; i++)
                {
                    recieve[i] = 0;
                }
            }
        }
 
        static void SendMessageToClients(byte[] toSend)
        {
            for (int i = 0; i < netStream.Count; i++)
            {
                netStream[i].Write(toSend, 0, 64); //передача данных
                netStream[i].Flush(); //удаление данных с потока
            }
        }
 
        static void Disconnect()
        {
            tcpListener.Stop(); //остановка чтения
 
            for (int i = 0; i < clients.Count; i++)
            {
                clients[i].Close(); //отключение клиента
                netStream[i].Close(); //отключение потока
            }
            Environment.Exit(0); //завершение процесса
        }
    }
}



Клиент

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
namespace Chat_Client
{
    class Program
    {
        static string usr;
        static TcpClient client;
        static NetworkStream netStream;
 
        static void Main(string[] args)
        {
            Console.Write("User name: ");
            usr = Console.ReadLine();
            Console.Write("IP: ");
            string ip = Console.ReadLine();
            Console.Write("Port: ");
            int port = Convert.ToInt32(Console.ReadLine());
            Connect(ip, port);
        }
 
        static void Connect(string ip, int port)
        {
            IPEndPoint ipe = new IPEndPoint(IPAddress.Parse(ip), port); //IP с номером порта
            client = new TcpClient(); //подключение клиента
            try
            {
                client.Connect(ipe); 
                netStream = client.GetStream();
                Thread receiveThread = new Thread(new ParameterizedThreadStart(ReceiveData));//получение данных
                receiveThread.Start();//старт потока
                Console.WriteLine("Connected!");
 
            }
            catch
            {
                Connect(ip, port);
            }
            SendMessage();
        }
 
        static void SendMessage()
        {
            Console.Write("Message: ");
            while (true)
            {
                try
                {
                    string message = usr + ": " + Console.ReadLine();
                    byte[] toSend = new byte[64];
                    toSend = Encoding.ASCII.GetBytes(message);
                    netStream.Write(toSend, 0, toSend.Length);
                    netStream.Flush(); //удаление данных из потока
                    //Console.WriteLine(message);
                    for (int i = 0; i < message.Length; i++)
                    {
                        toSend[i] = 0;
                    }
                }
                catch
                {
                    Console.WriteLine("ERROR");
                }
            }
        }
 
        static void ReceiveData(object e)
        {
            byte[] receiveMessage = new byte[64];
 
            while (true)
            {
                try
                {
                    netStream.Read(receiveMessage, 0, 64);//чтение сообщения
                }
                catch
                {
                    Console.WriteLine("The connection to the server was interrupted!"); //соединение было прервано
                    Console.ReadLine();
                    Disconnect();
                }
 
                string message = Encoding.ASCII.GetString(receiveMessage);
                Console.WriteLine(message);//вывод сообщения
            }
        }
 
 
        static void Disconnect()
        {
            client.Close();//отключение клиента
            netStream.Close();//отключение потока
            Environment.Exit(0); //завершение процесса
        }
    }
}
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
07.05.2013, 17:54
Ответы с готовыми решениями:

консольный чат на протоколе ТСР
как с нуля выглядит код который описывается в этой ссылке. Заранее спасибо!

TCP-Чат
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using...

Чат на сокетах (TCP)
как реализовать? в принципе работал с сокетами, но не понимаю как конкретно чат делается? ведь всегда должен быть сервер по идее, я могу...

6
192 / 199 / 82
Регистрация: 11.04.2013
Сообщений: 1,086
07.05.2013, 18:19
C#
1
2
3
4
5
6
7
8
 static void SendMessageToClients(byte[] toSend)
        {
            for (int i = 0; i < netStream.Count; i++)
            {
                netStream[i].Write(toSend, 0, 64); //передача данных
                netStream[i].Flush(); //удаление данных с потока
            }
        }
Наверное тут стоит проверить и отсечь того кто отсылает
0
0 / 0 / 1
Регистрация: 18.12.2011
Сообщений: 21
07.05.2013, 18:31  [ТС]
Цитата Сообщение от EVG-1980 Посмотреть сообщение
Наверное тут стоит проверить и отсечь того кто отсылает
да.. но я не особо понимаю как это сделать

Добавлено через 8 минут
Такой вариант не особо работает:
C#
1
2
3
4
5
6
7
8
9
for (int i = 0; i < netStream.Count; i++)
            {
                if (thisID != i)
                {
                    netStream[i].Write(toSend, 0, 64); //передача данных
                    netStream[i].Flush(); //удаление данных с потока
                }
                else { }
            }
от первого пользователя все работает, то есть ему ж не присылает. А вот второй пользователь один раз отправляет нормально, а потом не отправляются данные вообще...
0
192 / 199 / 82
Регистрация: 11.04.2013
Сообщений: 1,086
07.05.2013, 18:36
C#
1
2
3
4
5
6
7
8
9
10
11
static void SendMessageToClients(byte[] toSend, int thisID)
        {
            for (int i = 0; i < netStream.Count; i++)
            {
                if(i!=thisID)
                {
                netStream[i].Write(toSend, 0, 64); //передача данных
                netStream[i].Flush(); //удаление данных с потока
               }
}
        }
0
0 / 0 / 1
Регистрация: 18.12.2011
Сообщений: 21
07.05.2013, 18:42  [ТС]
EVG-1980, я ж так и сделал [постом выше]

Добавлено через 2 минуты
Странно, но твой код работает, а мой нет...
бубен в помощь

спасибо)
0
192 / 199 / 82
Регистрация: 11.04.2013
Сообщений: 1,086
07.05.2013, 18:52
sanyaok, я не знаю где ты это нашел я пологаю это 80 годов, нормально это работать не будет

когда работаешь с потоками надо блокировать объекты к которым обращаются из нескольких потоков
clients
netStream

И это че такое это типа очистка массива
C#
1
2
3
4
 for (int i = 0; i < 64; i++)
                {
                    recieve[i] = 0;
                }
0
Эксперт .NET
 Аватар для Wolfdp
3790 / 1767 / 371
Регистрация: 15.06.2012
Сообщений: 6,543
Записей в блоге: 3
08.05.2013, 08:12
Цитата Сообщение от EVG-1980 Посмотреть сообщение
И это че такое это типа очистка массива
автор просто не знает, что метод Read возвращает количество прочитаных байт, вот и чистит сообщение от мусора. =)
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
08.05.2013, 08:12
Помогаю со студенческими работами здесь

TCP интернет-чат между пользователями
Помогите. Не получается. На компе у себя работает всё ок. а если с другом , то проблема - не подкл. типа не было отклика и т.д.

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

Чат TCP Консоль сервер + WinForm клиент
Чат TCP сервер консоль + WinForm клиент Есть код где Консоль сервер+ Консоль клиент создает Чат но когда это я перевел на Консоль...

TCP чат работает только локально
есть 2 части клиент/сервер, если сервер стоит на другой машине не могу приконектится к нему, работает только локально, в чем может быть...

Tcp чат. Не коннектится с другими или роняет сервер
помогите исправить, на одном компе запускается , при конекте с другим не цепляется либо серв падает.


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Опции темы

Новые блоги и статьи
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки
Neotwalker 08.03.2026
Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .
Модульная разработка через nuget packages
DevAlt 07.03.2026
Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .
Модульный подход на примере F#
DevAlt 06.03.2026
В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .
Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование
8Observer8 05.03.2026
Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D
8Observer8 04.03.2026
Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .
SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий
8Observer8 02.03.2026
Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .
Реалии
Hrethgir 01.03.2026
Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .
Ритм жизни
kumehtar 27.02.2026
Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru