Форум программистов, компьютерный форум, киберфорум
C# для начинающих
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.79/29: Рейтинг темы: голосов - 29, средняя оценка - 4.79
0 / 0 / 0
Регистрация: 27.10.2015
Сообщений: 56

Доступ к ликвидированному объекту невозможен

06.05.2016, 15:43. Показов 5950. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Есть сервер на C# + клиент на C# + клиент на Java Android. Сервер асинхронный. Суть вот в чем: андройд должен отправлять данные на сервер (тут все отлично работает), а сервер должен перенаправлять эти данные клиенту на ПК с таким же именем (+ приписка "-pc"). Я сделал так - при подключении к серверу, клиент (и андройд и ПК) сразу отправляет ему сообщение со своим именем в такой форме - @@onConnection#name, сервер в свою очередь отправившему присваивает это имя. Вероятно есть и другие способы дать имя, но я их не знаю.
Так вот, когда ПК клиент отправляет сообщение со своим именем, он выкидывает исключение System.ObjectDisposedException и объясняет это тем, что "доступ к ликвидированному объекту невозможен".

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

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
class Server
    {
        public class StateObject
        {
            // Client  socket.
            public Socket workSocket = null;
            // Size of receive buffer.
            public const int BufferSize = 1024;
            // Receive buffer.
            public byte[] buffer = new byte[BufferSize];
            // Received data string.
            public StringBuilder sb = new StringBuilder();
            // Client name
            public string name = "";
        }
 
        public class AsynchronousSocketListener
        {
            // Thread signal.
            public static ManualResetEvent allDone = new ManualResetEvent(false);
            private static List<StateObject> sockets = new List<StateObject>();
 
            public AsynchronousSocketListener()
            {
            }
 
            public static void StartListening()
            {
                // Data buffer for incoming data.
                byte[] bytes = new Byte[1024];
 
                // Establish the local endpoint for the socket.
                // The DNS name of the computer
                // running the listener is "host.contoso.com".
                IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
                IPAddress ipAddress = ipHostInfo.AddressList[0];
                IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 31111);
 
                // Create a TCP/IP socket.
                Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
                // Bind the socket to the local endpoint and listen for incoming connections.
                try
                {
                    listener.Bind(localEndPoint);
                    listener.Listen(100);
 
                    while (true)
                    {
                        // Set the event to nonsignaled state.
                        allDone.Reset();
 
                        // Start an asynchronous socket to listen for connections.
                        Console.WriteLine("Waiting for a connection...");
                        listener.BeginAccept(
                            new AsyncCallback(AcceptCallback),
                            listener);
 
                        // Wait until a connection is made before continuing.
                        allDone.WaitOne();
                    }
 
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.ToString());
                }
 
                Console.WriteLine("\nPress ENTER to continue...");
                Console.Read();
 
            }
 
            public static void AcceptCallback(IAsyncResult ar)
            {
                // Signal the main thread to continue.
                allDone.Set();
 
                // Get the socket that handles the client request.
                Socket listener = (Socket)ar.AsyncState;
                Socket handler = listener.EndAccept(ar);
 
                // Create the state object.
                StateObject state = new StateObject();
                state.workSocket = handler;
                sockets.Add(state);
                handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                    new AsyncCallback(ReceiveCallback), state);
            }
 
            public static void ReceiveCallback(IAsyncResult ar)
            {
                try
                {
                    // Retrieve the state object and the client socket 
                    // from the asynchronous state object.
                    StateObject state = (StateObject)ar.AsyncState;
                    Socket client = state.workSocket;
                    // Read data from the remote device.
                    int bytesRead = client.EndReceive(ar);
                    if (bytesRead > 0)
                    {
                        // There might be more data, so store the data received so far.
                        state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
                        string text = state.sb.ToString();
                        if (text.Contains("@@onConnection"))
                        {
                            string[] parts = text.Split('#');
                            state.name = parts[1];
                        }
                        else
                        {
                            string[] parts = text.Split('#');
                            
                            foreach (var item in sockets)
                            {
                                if (item.name.Equals(state.name + "-pc"))
                                {
                                    Send(item.workSocket, parts[1]);
                                }
                            }
                            Console.WriteLine(parts[1]);
                        }
                        state.sb.Clear();
                        //  Get the rest of the data.
                        client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                            new AsyncCallback(ReceiveCallback), state);
                    }
                    else {
                        // All the data has arrived; put it in response.
                        if (state.sb.Length > 1)
                        {
                            Console.WriteLine(state.sb.ToString());
                        }
                        // Signal that all bytes have been received.
                        //receiveDone.Set();
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.ToString());
                }
            }
 
            public static void ReadCallback(IAsyncResult ar)
            {
                String content = String.Empty;
 
                // Retrieve the state object and the handler socket
                // from the asynchronous state object.
                StateObject state = (StateObject)ar.AsyncState;
                Socket handler = state.workSocket;
 
                // Read data from the client socket. 
                int bytesRead = handler.EndReceive(ar);
 
                if (bytesRead > 0)
                {
                    // There  might be more data, so store the data received so far.
                    state.sb.Append(Encoding.ASCII.GetString(
                        state.buffer, 0, bytesRead));
                    handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                        new AsyncCallback(ReadCallback), state);
 
                    // Check for end-of-file tag. If it is not there, read 
                    // more data.
                    content = state.sb.ToString();
                    
                    Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",
                            content.Length, content);
                }
            }
 
            private static void Send(Socket handler, String data)
            {
                // Convert the string data to byte data using ASCII encoding.
                byte[] byteData = Encoding.ASCII.GetBytes(data);
 
                // Begin sending the data to the remote device.
                handler.BeginSend(byteData, 0, byteData.Length, 0,
                    new AsyncCallback(SendCallback), handler);
            }
 
            private static void SendCallback(IAsyncResult ar)
            {
                try
                {
                    // Retrieve the socket from the state object.
                    Socket handler = (Socket)ar.AsyncState;
 
                    // Complete sending the data to the remote device.
                    int bytesSent = handler.EndSend(ar);
                    Console.WriteLine("Sent {0} bytes to client.", bytesSent);
 
                    handler.Shutdown(SocketShutdown.Both);
                    handler.Close();
 
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.ToString());
                }
            }
 
            public static void Main(String[] args)
            {
                StartListening();
            }
        }
    }


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

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
class Connection
    {
        TcpClient client = null;
 
        private class State
        {
            public State(byte[] buffer, Socket socket, string msg)
            {
                this.buffer = buffer;
                this.socket = socket;
                this.msg = msg;
            }
 
            public byte[] buffer;
            public Socket socket;
            public string msg;
        }
 
        public Connection(string name, string ip, int port)
        {
            client = new TcpClient();
 
            IPEndPoint point = new IPEndPoint(IPAddress.Parse(ip), port);
            client.Connect(point);
            using (NetworkStream ns = client.GetStream())
            {
                byte[] buffer = Encoding.ASCII.GetBytes("@@onConnection#" + name + "-pc");
                ns.Write(buffer, 0, buffer.Length);
            }
 
            StartReceiving(client);
        }
 
        public void StartReceiving(TcpClient client)
        {
            byte[] buffer = new byte[1024];
            string message = String.Empty;
            using (Socket socket = client.Client)
            {
                State state = new State(buffer, socket, message);
                socket.BeginReceive(state.buffer, 0, state.buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), state);
                message = Encoding.ASCII.GetString(buffer);
            }
        }
 
        private void ReceiveCallback(IAsyncResult ar)
        {
            try
            {
                State state = (State)ar.AsyncState;
                Socket socket = state.socket;
 
                int bytesRead = socket.EndReceive(ar);
                if (bytesRead > 0)
                {
                    string msg = Encoding.ASCII.GetString(state.buffer, 0, bytesRead);
                    MessageBox.Show(msg);
                }
            }
            catch(Exception e)
            {
                MessageBox.Show(e.ToString());
            }
        }
    }
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public partial class MainWindow : Window
    {
        private string name = "";
        private string ip = "";
        Connection conntection = null;
 
        public MainWindow()
        {
            InitializeComponent();
        }
 
        private void Button_Click(object sender, RoutedEventArgs e)
        {
            name = nameTextBox.Text;
            ip = ipTextBox.Text;
            conntection = new Connection(name, ip, 31111);
        }
    }


Помогите разобраться.
И если есть идеи, как все это дело грамотнее организовать, буду очень рад их услышать.

PS. Диплом сдавать уже через месяц
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
06.05.2016, 15:43
Ответы с готовыми решениями:

Ошибка "Доступ к ликвидированному объекту невозможен"
Ошибка &quot;Доступ к ликвидированному объекту невозможен. Имя объекта: &quot;Form&quot;.&quot; в чем проблема не пойму

Если форма вдруг закрылась то поток все равно долбится к ликвидированному объекту
readThreed = new Thread(new ThreadStart(RunClient)); readThreed.Start(); } public void RunClient() ...

Доступ к закрытому потоку невозможен
Вылетает ошибка: &quot;Доступ к закрытому потоку невозможен.&quot; MemoryStream _tempMem; _tempMem.Position = 0; string subject =...

2
Эксперт .NETАвтор FAQ
 Аватар для Storm23
10427 / 5157 / 1825
Регистрация: 11.01.2015
Сообщений: 6,226
Записей в блоге: 34
06.05.2016, 18:18
Цитата Сообщение от justjew Посмотреть сообщение
Так вот, когда ПК клиент отправляет сообщение со своим именем, он выкидывает исключение System.ObjectDisposedException и объясняет это тем, что "доступ к ликвидированному объекту невозможен".
В строке 25 класса Connection вы получаете поток сокета через using. Значит после выхода из using, поток закрывается и диспозится. Вместе с ним закрывается и сам сокет. Поэтому когда затем вы вызываете StartReceiving, и пытаетесь начать получение данных из сокета, он оказывается уже закрыт. Отсюда и ошибка.
Если вы не хотите закрывать соединение, уберите using при получении NetworkStream.

Аналогично - строка 38, там тоже usnig не нужен. Вам нужно диспозить потоки и сокеты тогда, когда передача данных через сокет уже полностью завершена.
1
0 / 0 / 0
Регистрация: 27.10.2015
Сообщений: 56
07.05.2016, 19:35  [ТС]
Цитата Сообщение от Storm23 Посмотреть сообщение
Вместе с ним закрывается и сам сокет.
Большое спасибо. не знал, что сокет тоже закрывается. Просто отправить данные серверу нужно только один раз, а остальное время только получать. Вот я и подумал, открою, отправлю, закрою
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
07.05.2016, 19:35
Помогаю со студенческими работами здесь

Доступ к закрытому потоку невозможен
Здравствуйте. есть функция , которая возвращает Stream. Когда я в переменную Stream заношу результат этой функции - далее не могу с ней...

Доступ к закрытому файлу невозможен
Пишу программу для приёма и отправки файлов по сети. Такой код на отправку файла private static void SendFile(FileStream fh) ...

Доступ к ликвидированному объекту невозможен
Есть два метода, один из которых запускается в новом потоке. private void _Process() { try { ...

Доступ к ликвидированному объекту невозможен
Всем доброго времени суток. Вообщем скажу сразу речь будет о ддосе но я делаю это исключительно в целях тестирования своих игровых...

Доступ к ликвидированному объекту невозможен
Всем доброго времени суток! Никак не могу избавиться от ошибки: System.ObjectDisposedException: Доступ к ликвидированному объекту...


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

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
Отправка уведомления на почту при изменении наименования справочника
Maks 24.03.2026
Программная отправка письма электронной почты на примере изменения наименования типового справочника "Склады" в конфигурации БП3. Перед реализацией необходимо выполнить настройку системной учетной. . .
модель ЗдравоСохранения 5. Меньше увольнений- больше дохода!
anaschu 24.03.2026
Теперь система здравосохранения уменьшает количество увольнений. 9TO2GP2bpX4 a42b81fb172ffc12ca589c7898261ccb/ https:/ / rutube. ru/ video/ a42b81fb172ffc12ca589c7898261ccb/ Слева синяя линия -. . .
Midnight Chicago Blues
kumehtar 24.03.2026
Такой Midnight Chicago Blues, знаешь?. . Когда вечерние улицы становятся ночными, а ты не можешь уснуть. Ты идёшь в любимый старый бар, и бармен наливает тебе виски. Ты смотришь на пролетающие. . .
SDL3 для Desktop (MinGW): Вывод текста со шрифтом TTF с помощью библиотеки SDL3_ttf на Си и C++
8Observer8 24.03.2026
Содержание блога Финальные проекты на Си и на C++: finish-text-sdl3-c. zip finish-text-sdl3-cpp. zip
Жизнь в неопределённости
kumehtar 23.03.2026
Жизнь — это постоянное существование в неопределённости. Например, даже если у тебя есть список дел, невозможно дойти до точки, где всё окончательно завершено и больше ничего не осталось. В принципе,. . .
Модель здравоСохранения: работники работают быстрее после её введения.
anaschu 23.03.2026
geJalZw1fLo Корпорация до введения программа здравоохранения имела много невыполненных работниками заданий, после введения программы количество заданий выросло. Но на выплатах по больничным это. . .
Контроль уникальности заводского номера
Maks 23.03.2026
Алгоритм контроля уникальности заводского (или серийного) номера на примере нетипового документа выдачи шин для спецтехники с табличной частью, разработанного в конфигурации КА2. Данные берутся из. . .
Хочу заставить корпорации вкладываться в здоровье сотрудников: делаю мат модель здравосохранения
anaschu 22.03.2026
e7EYtONaj8Y Z4Tv2zpXVVo https:/ / github. com/ shumilovas/ med2. git
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru