Форум программистов, компьютерный форум, киберфорум
C# для начинающих
Форум программистов и сисадминов Киберфорум > Форум программистов > .NET > C# .NET > C# для начинающих
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.75/8: Рейтинг темы: голосов - 8, средняя оценка - 4.75
11 / 10 / 1
Регистрация: 05.02.2012
Сообщений: 106

Клиент-серверное приложение перстает работать при отправке/приеме 3-4 сообщений

05.02.2012, 22:21. Показов 1548. Ответов 2
Метки нет (Все метки)
Студворк — интернет-сервис помощи студентам
Здравствуйте! При создании сервера (пока он ещё на начальном этапе и я сделал только самое простое) у меня возникла проблема: сначала сервер получает сообщения от клиента и отправляет уведомление. Потом он начинает получать сообщения от клиента и отправлять уведомления о доставке. После двух или нескольких сообщений клиент перестает получать уведомления, а сервер перестает воспринимать окружающие подключения. Вот код сервера:

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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Diagnostics;
 
namespace SocketServer
{
    public partial class Form1 : Form
    {
        Socket server = null;
        //Socket client = null;
        bool RunChat = false;
 
        public Form1()
        {
            InitializeComponent();
        }
 
        private void startServerButton_Click(object sender, EventArgs e)
        {
 
            if (server != null && server.Connected)
                server.Disconnect(false);
 
            int port = 12345;
            if (portTextBox.Text != "")
                port = Convert.ToInt32(portTextBox.Text);
            else
                MessageBox.Show("используется порт по умолчанию: 12345");
            
 
            server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            EndPoint endPoint = new IPEndPoint(IPAddress.Any, port);
 
 
            try
            {
                server.Bind(endPoint);
                server.Listen(100);
            }
            catch (Exception exc)
            {
                MessageBox.Show("Невозможно запустить сервер " + exc.Message);
                return;
            }
 
            server.BeginAccept(new AsyncCallback(AsyncAcceptCallback_), server);
        }
 
        void AsyncAcceptCallback(IAsyncResult result)
        {
            Socket serverSocket = (Socket)result.AsyncState;
 
            SocketData data = new SocketData();
            data.ServerConnection = serverSocket.EndAccept(result);
 
            data.ServerConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
                    new AsyncCallback(ReadCallback), data);
        }
 
        void ReadCallback(IAsyncResult result)
        {
            SocketData data = (SocketData)result.AsyncState;
            int bytes = data.ServerConnection.EndReceive(result);
 
            if (bytes > 0)
            {
                string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
 
                try
                {
                    clientRichTextBox.AppendText(s + "\n");
                }
                catch (Exception exc) { }
 
                data.ServerConnection.Send(Encoding.UTF8.GetBytes("Получено: " + s.Length + " символов"));
                RunChat = true;
            }
 
        }
 
        void AsyncAcceptCallback_(IAsyncResult result)
        {
            Socket serverSocket = (Socket)result.AsyncState;
 
            SocketData data = new SocketData();
            data.ServerConnection = serverSocket.EndAccept(result);
 
            data.ServerConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
                    new AsyncCallback(ReadCallback_), data);
            server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);   
        }
 
        void ReadCallback_(IAsyncResult result)
        {
            SocketData data = (SocketData)result.AsyncState;
            int bytes = data.ServerConnection.EndReceive(result);
 
            if (bytes > 0)
            {
                string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
 
                try
                {
                    clientRichTextBox.AppendText(s + "\n");
                }
                catch (Exception exc) { }
 
                data.ServerConnection.Send(Encoding.UTF8.GetBytes("Сервер: соединен"));
                RunChat = true;
            }
 
        }
 
        public IPAddress GetAddress(string address)
        {
            IPAddress ipAddress = null;
            try
            {
                ipAddress = IPAddress.Parse(address);
            }
            catch (Exception)
            {
                IPHostEntry heserver;
 
                try
                {
                    heserver = Dns.GetHostEntry(address);
                    if (heserver.AddressList.Length == 0)
                    {
                        return null;
                    }
                    ipAddress = heserver.AddressList[0];
                }
                catch
                {
                    return null;
                }
            }
 
            return ipAddress;
        }
 
        private void timerServer_Tick(object sender, EventArgs e)
        {
            if (RunChat)
            {
                try
                {
                    server.Listen(100);
                }
                catch (Exception exc)
                {
                    MessageBox.Show("Ошибка прослушивания: " + exc.Message);
                    RunChat = false;
                    return;
                }
 
                server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);
 
                RunChat = false;
            }
        }
    }
 
    class SocketData
    {
        public const int BufferSize = 1024;
 
        public Socket ServerConnection { get; set; }
 
        byte[] buffer = new byte[BufferSize];
 
        public byte[] Buffer 
        {
            get { return buffer; }
            set { buffer = value; }
        }
    }
}
Вот код клиента:

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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Diagnostics;
 
namespace SocketClient
{
    public partial class Form1 : Form
    {
        Socket client = null;
        int id = 0;
        public Form1()
        {
            InitializeComponent();
        }
 
        private void connectButton_Click(object sender, EventArgs e)
        {
            if (client != null && client.Connected)
                client.Disconnect(false);
 
            IPAddress addr = GetAddress(serverAddressTextBox.Text);
            if (addr == null)
            {
                MessageBox.Show("Я в шоке, не смог разобрать адрес");
                return;
            }
 
            int port = 12345;
            if (portTextBox.Text != "")
                port = Convert.ToInt32(portTextBox.Text);
            else
                MessageBox.Show("используется порт по умолчанию: 12345");
 
            client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            EndPoint point = new IPEndPoint(addr, port);
            try
            {
                client.Connect(point);
            }
            catch (Exception exc)
            {
                MessageBox.Show("Ошибка соединения: " + exc.Message);
            }
            if (client.Connected)
            {
                MessageBox.Show("Подключен!");
            }
 
            this.id = Convert.ToInt32(textBoxID.Text);
 
            client.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + " Password: " + textBoxPassword.Text + " - Подключен!"));
 
            byte[] buffer = new byte[1024];
            int bytes = 0;
 
            try
            {
                bytes = client.Receive(buffer);
            }
            catch (Exception exc)
            {
                MessageBox.Show("Ошибка подключения: " + exc.Message);
            }
            
            if (bytes > 0)
            {
                string s = Encoding.UTF8.GetString(buffer, 0, bytes);
                clientRichTextBox.AppendText(s + "\n");
            }
        }
 
        void AsyncAcceptCallback(IAsyncResult result)
        {
            Socket serverSocket = (Socket)result.AsyncState;
 
            SocketData data = new SocketData();
            data.ClientConnection = serverSocket.EndAccept(result);
 
            data.ClientConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
                    new AsyncCallback(ReadCallback), data);
        }
 
        void ReadCallback(IAsyncResult result)
        {
            SocketData data = (SocketData)result.AsyncState;
            int bytes = data.ClientConnection.EndReceive(result);
 
            if (bytes > 0)
            {
                string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
 
                try
                {
                    clientRichTextBox.AppendText(s + "\n");
                }
                catch (Exception exc)
                { }
                data.ClientConnection.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + "Получено!"));
            }
 
        }
 
        public IPAddress GetAddress(string address)
        {
            IPAddress ipAddress = null;
            try
            {
                ipAddress = IPAddress.Parse(address);
            }
            catch (Exception)
            {
                IPHostEntry heserver;
 
                try
                {
                    heserver = Dns.GetHostEntry(address);
                    if (heserver.AddressList.Length == 0)
                    {
                        return null;
                    }
                    ipAddress = heserver.AddressList[0];
                }
                catch
                {
                    return null;
                }
            }
 
            return ipAddress;
        }
 
        private void sendButton_Click(object sender, EventArgs e)
        {
            if (client != null && client.Connected)
                client.Disconnect(false);
 
            IPAddress addr = GetAddress(serverAddressTextBox.Text);
            if (addr == null)
            {
                MessageBox.Show("Я в шоке, не смог разобрать адрес");
                return;
            }
 
            int port = 12345;
            if (portTextBox.Text != "")
                port = Convert.ToInt32(portTextBox.Text);
 
            client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            EndPoint point = new IPEndPoint(addr, port);
            try
            {
                client.Connect(point);
            }
            catch (Exception exc)
            {
                MessageBox.Show("Ошибка соединения: " + exc.Message);
            }
 
            try
            {
                client.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + " Сообщение: " + commandTextBox.Text));
            }
            catch (Exception exc)
            {
                MessageBox.Show("Ошибка отправки: " + exc.Message);
            }
 
            byte[] buffer = new byte[1024];
 
            int bytes = 0;
            try
            {
                bytes = client.Receive(buffer);
            }
            catch (Exception exc)
            {
                MessageBox.Show("Ошибка получения уведомления об отправке: " + exc.Message);
            }
 
            if (bytes > 0)
            {
                string s = Encoding.UTF8.GetString(buffer, 0, bytes);
                try
                {
                    clientRichTextBox.AppendText(s + "\n");
                }
                catch (Exception exc)
                {}
            }
        }
    }
 
    class SocketData
    {
        public const int BufferSize = 1024;
 
        public Socket ClientConnection { get; set; }
 
        byte[] buffer = new byte[BufferSize];
 
        public byte[] Buffer
        {
            get { return buffer; }
            set { buffer = value; }
        }
    }
}
иногда все работает, но иногда ...
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
 05.02.2012, 22:21
Ответы с готовыми решениями:

Клиент-серверное приложение отправка сообщений
Помогите разобраться создаю клиент-серверное приложение отправка сообщений. //Сервер package ClientServer; import...

Клиент-серверное приложение, сохранение сообщений переписки
Здраствуйте!):help: У меня есть два приложения: одно-клиентская часть, второе-серверная часть. Передача сообщений между ними по IP налажена...

Клиент-серверное приложение для для предложенной схемы мультиплексирования сообщений
Напишите, откомпилируйте и прогоните программы сервера и клиентов для предложенной схемы мультиплексирования сообщений.

2
11 / 10 / 1
Регистрация: 05.02.2012
Сообщений: 106
10.02.2012, 22:56  [ТС]
Мне подсказали, в чем корень зла: Надо использовать Thread + сам подразобрался и понял)
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.Threading;
 
        void StartServer()
        {
            while (this.IsActive)
            {
                if(this.IsEnable)
                    if (this.RunChat)
                    {
                        try
                        {
                            server.Listen(100);
                        }
                        catch (Exception exc)
                        {
                            MessageBox.Show("Ошибка прослушивания: " + exc.Message);
                            RunChat = false;
                            return;
                        }
 
                        server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);
                        RunChat = false;
                    }
                Thread.Sleep(50);
            }
        }
 
        private void startServerButton_Click(object sender, EventArgs e)
        {
            if (!this.IsActive)
            {
                if (server != null && server.Connected)
                    server.Disconnect(false);
 
                int port = 12345;
                if (portTextBox.Text != "")
                    port = Convert.ToInt32(portTextBox.Text);
                else
                    MessageBox.Show("используется порт по умолчанию: 12345");
 
 
                server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                EndPoint endPoint = new IPEndPoint(IPAddress.Any, port);
 
                try
                {
                    server.Bind(endPoint);
                    //server.Listen(100);
                }
                catch (Exception exc)
                {
                    MessageBox.Show("Невозможно запустить сервер " + exc.Message);
                    return;
                }
 
                this.RunChat = true;//для приема нового сообщения
                this.IsActive = true;//для работы потока
                this.IsEnable = true;//для временного прерывания\возобновления потока, при этом данные на сокете, ожидающие принятия программой не пропадают
 
                myThread = new Thread(new ThreadStart(StartServer));
                myThread.Start();
            }
        }
//...
Вот основные изменения, решающие проблему, может кому пригодится ...
0
10 / 10 / 4
Регистрация: 14.08.2010
Сообщений: 103
11.02.2012, 16:02
Я тоже использую подобную же вещь, но я думал, что подписывание на события типа ReadCallback(IAsyncResult result) и т.п. - как бы и есть ихнее оформление в отдельном потоке каждый, а оно оказывается не так и у вас были проблемы. У меня не было проблем, но видимо данных не так много у меня. Спасибо и тоже пересмотрю свой код и сообщу о результатах.(правда на след. неделе в середине где-то).
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
 11.02.2012, 16:02
Помогаю со студенческими работами здесь

Клиент-серверное приложение. Ошибка при вызове события.
Не выполняется (evToSomewhere != null). Если эту проверку убрать, то /An unhandled exception of type 'System.NullReferenceException'...

Клиент-Серверное приложение. Как сделать, чтобы сервер сам отправлял сообщения на клиент
Добрый день всем. Проблема заключается в следующем: Есть клиент-серверное приложение, хочу реализовать своего рода защиту, чтобы при...

Клиент-серверное приложение. Сервер - ПК, клиент - телефон (Android)
Здравствуйте, решил для обучения написать программу для выключения ПК с телефона, используя компонент TIdTCPServer. Подскажите, как...

Клиент-серверное приложение: как определить, что сервер/клиент не отвечает в течении определенного времени
Пишу клиент-серверное приложение. Использую TCPListener и TCPClient. Вопрос: как определить что сервер(клиент) не отвечает в течении...

Клиент-серверное приложение. Как занести в цикл, чтобы каждый раз при вводе пары чисел, выводилась сумма?
Добрый день. Есть клиент-серверное приложение, которое суммирует пару чисел, но только один раз. Как сделать, чтобы на каждый запрос...


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

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Работа со звуком через SDL3_mixer
8Observer8 08.02.2026
Содержание блога Пошагово создадим проект для загрузки звукового файла и воспроизведения звука с помощью библиотеки SDL3_mixer. Звук будет воспроизводиться по клику мышки по холсту на Desktop и по. . .
SDL3 для Web (WebAssembly): Основы отладки веб-приложений на SDL3 по USB и Wi-Fi, запущенных в браузере мобильных устройств
8Observer8 07.02.2026
Содержание блога Браузер Chrome имеет средства для отладки мобильных веб-приложений по USB. В этой пошаговой инструкции ограничимся работой с консолью. Вывод в консоль - это часть процесса. . .
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве
8Observer8 02.02.2026
Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .
Философия технологии
iceja 01.02.2026
На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .
SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf
8Observer8 01.02.2026
Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .
SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли
8Observer8 30.01.2026
Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm
8Observer8 30.01.2026
Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .
SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 29.01.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Поддержать - Реклама - Условия использования - Обратная связь
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru