Работа с классами и коллекциями
Здесь я расскажу об одной своей довольно интересной проге, на которой хорошо исключительно хорошо видно - как именно надо работать с классами (обьектами) и как это надо делать в многопоточном режиме. Это один из классов огромной системы и здесь я выложу реальный текст этого класса, который вы можете расширять дальше в любом направлении.
Этот небольшой класс является ядром любого прокси сервера, за исключением того, что общается со внешним миром он просто по TCP/IP, а не через HTTP. Однако, если вы пороетесь у меня на сайте, то найдете еще некий фрагмент, который позволит превратить нижеследующую прогу в полноценный прокси-сервер...
Чтобы на заморачиватся здесь на вопросах маршализации в поток формы из потоков прокси, представьте что вся диагностика по Normal_Message - это просто Console.WriteLine. Тогда протокол работы этого прокси будет выглядеть вот так.
Итак, наконец, вот собственно моя прога во всей красе, в которой отлично видно четыре основные техники работы с потоками (а может у кого-то их и больше)...
00001: Imports System.Net 00002: Imports System.Net.Sockets 00003: Imports System.IO 00004: 00005: Public Class NET_Listener 00006: ' 00007: Dim Config As System.Collections.Specialized.NameValueCollection 00008: Dim ValidIP As New System.Text.RegularExpressions.Regex("[1-2]\d{1,2}\.[1-2]?\d{1,2}\.[1-2]?\d{1,2}\.[1-2]?\d{1,2}") 00009: ' 00010: Dim SQL_Thread As Threading.Thread 00011: Dim SQL_IP As System.Net.IPAddress 00012: Dim SQL_Port As Int16 00013: Dim SQL_Listener As System.Net.Sockets.TcpListener 00014: Dim SQL_OpenNewPort As Int32 00015: ' 00016: Dim SVA_Queue As New SVA_QUE() 'очередь на передачу сообщений от SQL к SVA 00017: Dim SVA_Threads As New ArrayList() 'коллекция дочерних потоков 00018: Dim SVA_ListenerClass As New ArrayList() 'Коллекция указателей на классы прослушки 00019: Dim Perfomance As Int16 'Интервал опроса очереди на передачу 00020: ' 00021: Public Sub New() 00022: MyBase.new() 00023: End Sub 00024: ' 00025: Protected Overrides Sub Finalize() 'нас грохают 00026: MyBase.Finalize() 00027: End Sub 00028: ' 00029: Public ReadOnly Property GetQueue() As String 00030: Get 00031: Dim One As SVA_Data 00032: Dim Str1 As String = "" 00033: For Each One In SVA_Queue 00034: Str1 &= One.Value & ", " 00035: Next 00036: GetQueue = Str1 00037: End Get 00038: End Property 00039: ' 00040: Public ReadOnly Property GetThread() As String 00041: Get 00042: Dim Thread As System.Threading.Thread 00043: Dim Str2 As String = "" 00044: For Each Thread In SVA_Threads 00045: Str2 &= Thread.Name & ", " 00046: Next 00047: GetThread = Str2 00048: End Get 00049: End Property 00050: ' 00051: Public Function SQL_Start() As String 00052: If SQL_Thread Is Nothing Then 'нам лишних потоков не надо 00053: Config = System.Configuration.ConfigurationSettings.AppSettings 00054: If Config.Count = 0 Then 00055: Call Error_Message( _ 00056: "Ошибка. Нет файла конфигурации " & vbCrLf & _ 00057: System.AppDomain.CurrentDomain.SetupInformation.ConfigurationFile & vbCrLf & _ 00058: "в каталоге " & vbCrLf & _ 00059: System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase) 00060: Else 00061: If Len(Config("SQL_IP")) = 0 Or Len(Config("SQL_PORT")) = 0 Or Len(Config("Perfomance")) = 0 Or Len(Config("SQL_OpenNewPort")) = 0 Then 00062: Call Error_Message( _ 00063: "Ошибка. В файле конфигурации " & vbCrLf & _ 00064: System.AppDomain.CurrentDomain.SetupInformation.ConfigurationFile & vbCrLf & _ 00065: "в каталоге " & vbCrLf & _ 00066: System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase & vbCrLf & _ 00067: "Нет ключей - ""SQL_IP"" или ""SQL_PORT"" или ""Perfomance"" или ""SQL_OpenNewPort"" ") 00068: Else 00069: If ValidIP.IsMatch(Config("SQL_IP")) And Val(Config("SQL_PORT")) < 65535 Then 00070: Try 00071: SQL_IP = IPAddress.Parse(Config("SQL_IP")) 00072: SQL_Port = Val(Config("SQL_PORT")) 00073: SQL_OpenNewPort = Val(Config("SQL_OpenNewPort")) 00074: Perfomance = Val(Config("Perfomance")) 00075: ' 00076: SQL_Thread = New Threading.Thread(AddressOf SQL_Process) 00077: SQL_Thread.Start() 00078: ' 00079: SQL_Start = Config("SQL_IP") & ":" & Config("SQL_PORT") 00080: ' 00081: Catch x As System.Exception 00082: Call Error_Message( _ 00083: "Не стартовал главный поток прослушки сообщений от SQL-сервера." & vbCrLf & _ 00084: "Одна из вероятных причин - ошибки в файле конфигурации " & vbCrLf & _ 00085: System.AppDomain.CurrentDomain.SetupInformation.ConfigurationFile & vbCrLf & _ 00086: "в каталоге " & vbCrLf & _ 00087: System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase & vbCrLf & _ 00088: "Адреса и порты прослушки, заданные в конфигурации: " & _ 00089: Config("SQL_IP") & ":" & Config("SQL_PORT") & vbCrLf & _ 00090: "Другая возможная ошибка:" & vbCrLf & _ 00091: x.Message) 00092: End Try 00093: 00094: Else 00095: Call Error_Message( _ 00096: "Ошибка. В файле конфигурации " & vbCrLf & _ 00097: System.AppDomain.CurrentDomain.SetupInformation.ConfigurationFile & vbCrLf & _ 00098: "в каталоге " & vbCrLf & _ 00099: System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase & vbCrLf & _ 00100: "Неверно задан один из ключей - ""SQL_IP"" , ""SQL_PORT"" ") 00101: End If 00102: End If 00103: End If 00104: End If 00105: End Function 00106: ' 00107: Public Sub Abort_SVA_Thread(ByVal ThreadName As String) 00108: Dim Thread As System.Threading.Thread, SVA_Class As SVA_Listener 00109: Dim Str2 As String = "", i As Integer 00110: For Each Thread In SVA_Threads 00111: If ThreadName = Thread.Name Then 00112: SVA_Class = SVA_ListenerClass.Item(i) 00113: SVA_ListenerClass.RemoveAt(i) 00114: SVA_Class.Abort() 00115: SVA_Class = Nothing 00116: SVA_Threads.RemoveAt(i) 00117: Thread.Abort() 00118: Thread = Nothing 00119: Call Normal_Message("Закрыт поток " & ThreadName) 00120: Exit Sub 00121: End If 00122: i += 1 00123: Next 00124: End Sub 00125: ' 00126: Public Sub SQL_Abort() 00127: SQL_Thread.Abort() 'главный поток 00128: SQL_Thread = Nothing 00129: End Sub 00130: ' 00131: Private Sub SQL_Process() 00132: Call Normal_Message("Старт потока прослушки SQL-сервера : " & Config("SQL_IP") & ":" & Config("SQL_PORT").ToString) 00133: Try 00134: NewSQL_Connect: SQL_Listener = New System.Net.Sockets.TcpListener(SQL_IP, SQL_Port) 00135: ' 00136: SQL_Listener.Start() 00137: ' 00138: Dim TCPClient As System.Net.Sockets.TcpClient = SQL_Listener.AcceptTcpClient() 00139: 'Здесь поток ЖДЕТ первого пакета из сети чтобы все проинициализировалось 00140: ' 00141: Dim NetStream As System.Net.Sockets.NetworkStream = TCPClient.GetStream 00142: ' 00143: Dim SQL_Reader As System.IO.BinaryReader = New System.IO.BinaryReader(NetStream) 00144: ' 00145: Dim Result As Int32 00146: ' 00147: Do While True 'Вычитываем все что дает сервер в этом коннекте 00148: ' 00149: Try 00150: Result = SQL_Reader.ReadInt32 00151: 'пока данных нет - поток в этом месте подвисает 00152: 'или падает по закрытию коннекта (завершении процедуры) 00153: ' 00154: Catch x As System.IO.EndOfStreamException 00155: ' 00156: TCPClient.Close() 'полное закрытие коннекта с SQL 00157: TCPClient = Nothing 00158: SQL_Listener.Stop() 00159: SQL_Listener = Nothing 00160: NetStream.Close() 00161: NetStream = Nothing 00162: SQL_Reader.Close() 00163: SQL_Reader = Nothing 00164: ' 00165: Call Normal_Message("Закрыт коннект с SQL-сервером") 00166: GoTo NewSQL_Connect 00167: End Try 00168: ' 00169: Call Normal_Message("От SQL-сервера получено - " & Result.ToString) 00170: ' 00171: Select Case Result 00172: Case SQL_OpenNewPort 'дальше по нашему протоколу SQL-сервер сразу дает новый номер порта, который надо слушат у SVA и номер юзера 00173: Dim NewPort As Int32 00174: Dim NewUser As Int32 00175: Dim NewByte1, NewByte2, NewByte3, NewByte4 As Int32 00176: Dim SVA_IP As System.Net.IPAddress, SVA_IP_string As String 00177: Try 00178: NewPort = SQL_Reader.ReadInt32 00179: NewUser = SQL_Reader.ReadInt32 00180: 'теперь побайтно принимаем айпишник 00181: NewByte1 = SQL_Reader.ReadInt32 00182: NewByte2 = SQL_Reader.ReadInt32 00183: NewByte3 = SQL_Reader.ReadInt32 00184: NewByte4 = SQL_Reader.ReadInt32 00185: ' 00186: SVA_IP_string = NewByte1.ToString & "." & NewByte2.ToString & "." & NewByte3.ToString & "." & NewByte4.ToString 00187: If ValidIP.IsMatch(SVA_IP_string) Then 00188: SVA_IP = IPAddress.Parse(SVA_IP_string) 00189: ' 00190: Dim NewListener As New SVA_Listener(SVA_IP, NewPort, NewUser, SVA_Queue, Perfomance) 00191: SVA_ListenerClass.Add(NewListener) 00192: Dim NewThread As Threading.Thread = New Threading.Thread(AddressOf NewListener.Start) 00193: NewThread.Name = "SVA_Listener. User:" & NewUser.ToString & " - " & SVA_IP.ToString & ":" & NewPort.ToString 00194: NewThread.Start() 00195: SVA_Threads.Add(NewThread) 00196: 00197: Else 00198: Throw New System.Exception("От SQL-сервера принят неверный адрес прослушки SVA") 00199: End If 00200: Catch x As System.Exception 00201: Call Error_Message( _ 00202: "Ошибка создания нового потока прослушки данных от клиентов." & vbCrLf & _ 00203: x.Message & vbCrLf & _ 00204: "Запрашивалось создание потока для прослушки от юзера " & NewUser.ToString & " На " & SVA_IP.ToString & ":" & NewPort.ToString) 00205: End Try 00206: ' 00207: Case Else 'иначе просто в очередь на передачу данных 00208: Dim NewData As SVA_Data = New SVA_Data(Result) 00209: SVA_Queue.Add(NewData) 00210: ' 00211: End Select 00212: ' 00213: Loop 00214: ' 00215: Catch x As System.Exception 00216: Dim One As SVA_Data 00217: Dim Str1 As String = "", Str2 As String = "" 00218: For Each One In SVA_Queue 00219: Str1 &= One.Value & "," 00220: Next 00221: Dim Thread As System.Threading.Thread 00222: For Each Thread In SVA_Threads 00223: Str2 &= Thread.Name & "," 00224: Next 00225: If TypeName(x) = "ThreadAbortException" Then 00226: Call Normal_Message( _ 00227: "Закрыт главный поток прослушки данных от SQL-сервера" & vbCrLf & _ 00228: "Содержимое очереди на передачу: " & Str1 & vbCrLf & _ 00229: "Потоки передачи: " & Str2) 00230: Else 00231: Call Error_Message( _ 00232: "Ошибка TCP/IP в главном потоке прослушки сообщений от SQL-сервера" & vbCrLf & _ 00233: x.Message & vbCrLf & _ 00234: "Содержимое очереди на передачу: " & Str1 & vbCrLf & _ 00235: "Потоки передачи: " & Str2) 00236: End If 00237: End Try 00238: End Sub 00239: End Class 00240: 00241: 'Этот класс - отдельный поток. После создания 00242: 'он периодически просматривает очередь 00243: 'на передачу в свой порт 00244: Public Class SVA_Listener 00245: ' 00246: Dim MyIP As System.Net.IPAddress 'IP - Куда передаем (где слушаем юзера) 00247: Dim MyPort As Int16 'Port - Куда передаем (где слушаем юзера) 00248: Dim MyUser As Int32 'Номер юзера на этом порту 00249: Dim MyInterval As Int16 'Интервал опроса очереди на передачу 00250: Dim MyQueue As SVA_QUE 'Очередь на передачу 00251: ' 'Средства передачи по TCP/IP 00252: Dim MyListener As System.Net.Sockets.TcpListener 00253: Dim MyStream As System.Net.Sockets.NetworkStream 00254: Dim MyTcpClient As System.Net.Sockets.TcpClient 00255: Dim MyWriter As System.IO.BinaryWriter 00256: ' 00257: Public Sub New(ByVal IP As System.Net.IPAddress, ByVal Port As Int16, ByVal User As Int32, ByVal Queue As SVA_QUE, ByVal Interval_Oprosa As Int16) 00258: MyUser = User 00259: MyInterval = Interval_Oprosa 00260: MyQueue = Queue 00261: MyPort = Port 00262: MyIP = IP 00263: MyListener = New System.Net.Sockets.TcpListener(IP, Port) 00264: Call Normal_Message( _ 00265: "Создан обьект передачи для юзера - " & MyUser & _ 00266: " На порту - " & MyIP.ToString & ":" & MyPort.ToString) 00267: End Sub 00268: ' 00269: Public Sub Abort() 00270: Call Normal_Message( _ 00271: "Закрыт обьект передачи для юзера - " & MyUser & _ 00272: " На порту - " & MyIP.ToString & ":" & MyPort.ToString) 00273: If Not (MyWriter Is Nothing) Then MyWriter.Close() 00274: If Not (MyStream Is Nothing) Then MyStream.Close() 00275: If Not (MyListener Is Nothing) Then MyListener.Stop() 00276: If Not (MyTcpClient Is Nothing) Then MyTcpClient.Close() 00277: MyWriter = Nothing 00278: MyStream = Nothing 00279: MyListener = Nothing 00280: MyTcpClient = Nothing 00281: 'System.Threading.Thread.CurrentThread.Abort() 00282: End Sub 00283: ' 00284: Public Sub Start() 00285: 'Начало бесконечного цикла передачи сообщений по установленному каналу 00286: Try 00287: MyListener.Start() 00288: MyTcpClient = MyListener.AcceptTcpClient 00289: 'здесь подвисает ??? 00290: MyStream = MyTcpClient.GetStream 00291: MyWriter = New System.IO.BinaryWriter(MyStream) 00292: ' 00293: Call Normal_Message( _ 00294: "Инициализирован обьект передачи для юзера - " & MyUser & _ 00295: " На порту - " & MyIP.ToString & ":" & MyPort.ToString) 00296: ' 00297: Catch x As System.Exception 00298: Call Error_Message( _ 00299: "Ошибка создания порта прослушки " & MyIP.ToString & ":" & MyPort.ToString & vbCrLf & _ 00300: "для юзера " & MyUser.ToString & vbCrLf & _ 00301: x.Message) 00302: 'И весь этот поток и класс глючный - его надо убить 00303: 'пока непонятно как 00304: Exit Sub 00305: End Try 00306: ' 00307: Do While True 00308: System.Threading.Thread.Sleep(MyInterval) 00309: Try 00310: If MyQueue.Present(MyUser) Then 00311: ' 00312: Call Normal_Message( _ 00313: "Найдены данные для передачи юзеру - " & MyUser & _ 00314: " На порту - " & MyIP.ToString & ":" & MyPort.ToString) 00315: ' 00316: MyWriter.Write(MyUser) 00317: MyQueue.Delete(MyUser) 00318: ' 00319: Call Normal_Message( _ 00320: "Закончена передача для юзера - " & MyUser & _ 00321: " На порту - " & MyIP.ToString & ":" & MyPort.ToString) 00322: ' 00323: End If 00324: 00325: Catch x As System.Exception 00326: Call Error_Message( _ 00327: "Ошибка передачи данных юзеру " & MyUser.ToString & "в порт " & MyIP.ToString & ":" & MyPort.ToString & vbCrLf & _ 00328: vbCrLf & _ 00329: x.Message) 00330: End Try 00331: Loop 00332: End Sub 00333: End Class 00334: 00335: 'В этот класc прячем данные для передачи 00336: Public Class SVA_Data 00337: Dim Data As Int32 00338: 00339: Public Sub New(ByVal Value As Int32) 00340: Data = Value 00341: End Sub 00342: 00343: Public ReadOnly Property Value() As Int32 00344: Get 00345: Value = Data 00346: End Get 00347: End Property 00348: End Class 00349: 00350: 'Этот класс - очередь на передачу из элементов SVA_Data 00351: Public Class SVA_QUE 00352: Inherits System.Collections.CollectionBase 'переопределяем 00353: 00354: Public Sub Add(ByVal Data As SVA_Data) 00355: Me.List.Add(Data) 00356: Call Normal_Message("В очередь передачи добавлены данные : " & Data.Value.ToString) 00357: End Sub 00358: 00359: Public Function Present(ByVal Value As Int32) As Boolean 00360: Dim One As SVA_Data 00361: For Each One In Me 00362: If One.Value = Value Then 00363: Present = True 00364: Exit Function 00365: End If 00366: Next 00367: Present = False 00368: End Function 00369: 00370: Public Sub Delete(ByVal value As Int32) 00371: Dim One As SVA_Data 00372: Dim i As Int32 00373: For i = 0 To Me.Count 00374: One = Me.List(i) 00375: 'удаляем первый - они все равно одинаковые 00376: If One.Value = value Then 00377: Me.RemoveAt(i) 00378: Call Normal_Message("Из очереди передачи удалены данные : " & One.Value.ToString) 00379: Exit Sub 00380: End If 00381: Next 00382: End Sub 00383: 00384: End Class
Итак, как вы видите, функционально эта прога состоит из класса NET_Listener (строки 1-240) экземпляр которого, создает при запуске Прокси внешее приложение.
Этот класс имеет несколько, методов, первым (естественно после конструктора NEW (строка 22), который вызывается автоматически для создания экземпляра этого класса), так вот первым пользовательское приложение вызывает метод SQL_Start в строке 51. Этот метод считывает конфигурацию этого класса:
прверяет ее на правильность (строка 69) по регулярному выражению (заданному в строке 8) и наконец в строке 76-77 стартует новый поток SQL_Process (строка 131), который в дальнейшем будет управлять всеми действиями этого прокси-сервера. После старта управление возвращается вызывающей проге, а созданный экземпляр NET_Listener'а дальше будет жить своей жизнью (в бесконечном цикле со строки 134 по строку 213), независимой от вызывающей проги и того, что мы уже вернули управление, тк жизнь экземпляра этого класса будет продолжатся во вновь созданном нами потоке, тк мы запустили в новый поток метод этого же класса.
Это, так сказать первый прием работы с классами и потоками. Иной способ создания потоков (не другой поток в существующем классе, а на каждый поток - отдельный класс) - рассмотрен в самом конце этой странички. Заметьте, что поскольку экземпляр сохранен, и у вызывающего класса ЕСТЬ ВЕРНАЯ ССЫЛКА на экземпляр этого класса, независимо от потока в этом классе, МОЖНО ВЫЗВАТЬ МЕТОДЫ класса NET_LISTENER, скажем так: PROXY.GetQueue или так PROXY.GetThread и достать этими методами маленькие хитрости, который этот класс прячет у себя...
Теперь рассмотрим внутренню жизнь этого класса, заключающуюся в бесконечном цикле в строках 134-213. Взглянув на текст проги, вы понимаете, что здесь все начинается в строке 150, где прога получает данные из сети. Здесь, как вы видите, как у Ильи Муромца, есть три основные дорожки.
Первая дорожка, SQL-сервер закрыл коннект, срабатывает фильтрованная ловушка в строке 154, коннект полностью закрывается и переход в строке 166 приводит к полному переоткрытию коннекта с SQL. Физически это означает что на SQL-сервере закончился SQL-BATCH, скажем такой:
exec SY_MG_MessageWrite 11, 11, N'COMPUTER', N'432432', 0, N'', N'', 3, 20, 1, 10, 0, 0, 1, 1, 0, 0, 0, 0
00010: ALTER procedure SY_MG_MessageWrite ...... ...... <b>фрагмент - все детали опущены</b> ...... 00073: -- 00074: -- Теперь выполняем ОПОВЕЩЕНИЕ 00075: -- 00076: 00077: Declare @Ret int,@Handler int 00078: exec @Ret= SY_MG_SEND 'Load',@Handler OUTPUT,default,default,default 00079: IF (@Ret>0 or @Handler=0) return 7 00080: 00081: Declare @ProxyIP varchar(15), @ProxyPort smallint 00082: Select top 1 @ProxyIP=[IP], @ProxyPort=[Port] from SY_MG_ProxyParm 00083: exec @Ret= SY_MG_SEND 'Start',@Handler,@ProxyIP,@ProxyPort,default 00084: IF @Ret>0 return 8 00085: 00086: exec @Ret= SY_MG_SEND 'Connect',@Handler,default,default,default 00087: IF @Ret>0 return 9 00088: 00089: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@ID 00090: IF @Ret>0 return 10 00091: 00092: exec @Ret= SY_MG_SEND 'Abort',@Handler 00093: IF @Ret>0 return 11 00094: 00095: return(0)
00007: ALTER procedure SY_MG_SEND 00008: -- 00009: -- @Action - определяет ШЕСТЬ РАЗЛИЧНЫХ ОПЕРАЦИЙ выполняемых процедурой: 00010: -- 'Load' - загрузка драйвера (возвращается @Handler - указатель на драйвер) 00011: -- во всех остальных случаях @Handler обязательно задается для работы процедуры 00012: -- 'Hello' - выдача на сервере диагностического сообщения для проверки наличия драйвера 00013: -- 'Start' - инициализация загруженного экземпляра драйвера для работы в сети 00014: -- 'Connect'- коннект к клиенту (надо задавать еще @IP и @Port) 00015: -- 'Write' - передача данных (надо указать передаваемое число в @Data) 00016: -- 'Abort' - разрыв соединения и уничтожение экземпляра драйвера 00017: -- если все сработало правильно - код возврата процедуры 0 00018: -- 00019: @Action Varchar(7), 00020: @Handler int OUTPUT, 00021: @IP varchar(15) ='', 00022: @Port varchar(5) ='', 00023: @Data int =0 00024: as 00025: DECLARE @hr int 00026: DECLARE @src varchar(255), @desc varchar(255), @Return int 00027: If @Action='Load' BEGIN 00028: EXEC @hr = sp_OACreate 'SQLSENDER.SQL_Sender', @Handler OUT 00029: IF (@hr = 0) Return (0) else GOTO ERROR1 00030: END 00031: ELSE If @Action='Hello' BEGIN 00032: EXEC @hr = sp_OAMethod @Handler, 'Hello', @Return OUT,'Привет из SQL-сервера' 00033: IF (@hr = 0) Return (0) else GOTO ERROR1 00034: END 00035: ELSE If @Action='Start' BEGIN 00036: EXEC @hr = sp_OAMethod @Handler, 'Start',@Return OUT,@IP,@Port 00037: IF (@hr = 0) Return (0) else GOTO ERROR1 00038: END 00039: ELSE If @Action='Connect' BEGIN 00040: EXEC @hr = sp_OAMethod @Handler, 'Connect',@Return OUT 00041: IF (@hr = 0) Return (0) else GOTO ERROR1 00042: END 00043: ELSE If @Action='Write' BEGIN 00044: EXEC @hr = sp_OAMethod @Handler, 'Write',@Return OUT,@Data 00045: IF (@hr = 0) Return (0) else GOTO ERROR1 00046: END 00047: ELSE If @Action='Abort' BEGIN 00048: EXEC @hr = sp_OAMethod @Handler, 'Abort',@Return OUT 00049: IF (@hr = 0) Return (0) else GOTO ERROR1 00050: EXEC @hr = sp_OADestroy @Handler 00051: IF (@hr = 0) Return (0) else GOTO ERROR1 00052: END 00053: ERROR1: 00054: EXEC sp_OAGetErrorInfo @Handler, @src OUT, @desc OUT 00055: SELECT @Action,hr=convert(varbinary(4),@hr), Source=@src, Description=@desc 00056: RETURN @hr
Вторая дорожка начинается в строке 207, если принятое число не равно значению переменной SQL_OpenNewPort. Эдесь применяется основной метод работы с классами. Если вы понимаете, как это работает, и реально будете применять это в сових прогах - половина работы с классами у вас в кармане.
Так вот - сначала делается маленький класс строки 336-348. Этот класс имеет параметризованный конструктор в строке 339 и когда вы создаете в строке 208 экземпляр этого класса в стек намертво утапливается значение, которое мы задали при создании экземпляра этого класса.
А вот следующий класс - строки 351-384 ГОРАЗДО более интересный. Замечательная строка 352, объявляет, что этот класс наследует System.Collections.CollectionBase, а чтобы отойти от этого слова к простым русским словам - уточняет, дополняет, переопределяет общие методы работы с коллекциями, прописанные в System.Collections.CollectionBase. Причем позволяет добавить (строка 209) в коллекцию (очередь на передачу), не какой угодно мусор, а только вышерассмотренный класс SVA_Data, который прячет в себе данные на передачу. Еще эта коллекция умеет проверить наличие данных для передачи и удалить элемент SVA_Data, хранящий уже не нужные данные для передачи. Обратите внимание, как работает эта хитрая коллекция - поймете - вам десять плюсов...
Теперь рассмотрим третью дорожку, самую сложную в плане понимания мультипоточного и обьектого программирования. Она начинается в строке 177, в том случае, если принятое число равно переменной SQL_OpenNewPort. В этом случае отрабатывает некоторый протокол, формируемый некоторой процедурой, в процессе которого передаются данные, какой именно порт и для кого следует открыть на внешнем (или иногда на внутреннем) интерфейсе прокси-сервера. Эта профедура имеет вот такой вид - только смысловой фрагмент, детали опущены:
exec SY_MG_Connect 11, 761162163, '192.168.0.51', 6011
00016: ALTER procedure SY_MG_Connect 00017: @CurrentUser int, 00018: @EID int, 00019: @IP as varchar(15), 00020: @Port as smallint 00021: as 00022: declare @Row1 int,@SCOPE int 00023: 00024: --сначала фиксируем вход 00025: INSERT INTO [SY_MG_ConnectTab]([CurrentUser], [SVA_ID], [IP],[PORT], [StartTime]) 00026: VALUES( @CurrentUser, @EID, @IP, @PORT, getdate()) 00027: select @Row1=@@Rowcount 00028: select @SCOPE=SCOPE_IDENTITY() 00029: If @Row1<>1 return 1 00030: 00031: --теперь загружаем драйвер и передаем ПРОКСИ-СЕРВЕРУ команду на открытие нового порта 00032: Declare @Ret int,@Handler int 00033: exec @Ret= SY_MG_SEND 'Load',@Handler OUTPUT,default,default,default 00034: UPDATE [SY_MG_ConnectTab] SET [StateLoad]=@Ret where [ID]=@SCOPE 00035: IF (@Ret>0 or @Handler=0) return 2 00036: 00037: Declare @ProxyIP varchar(15), @ProxyPort smallint, @ProxyKey int 00038: Select top 1 @ProxyIP=[IP], @ProxyPort=[Port], @ProxyKey=[key] from SY_MG_ProxyParm 00039: exec @Ret= SY_MG_SEND 'Start',@Handler,@ProxyIP,@ProxyPort,default 00040: UPDATE [SY_MG_ConnectTab] SET [StateStart]=@Ret where [ID]=@SCOPE 00041: IF @Ret>0 return 3 00042: 00043: exec @Ret= SY_MG_SEND 'Connect',@Handler,default,default,default 00044: UPDATE [SY_MG_ConnectTab] SET [StateConnect]=@Ret where [ID]=@SCOPE 00045: IF @Ret>0 return 4 00046: 00047: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@ProxyKey -- КЛЮЧ открыть новый порт 00048: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret where [ID]=@SCOPE 00049: IF @Ret>0 return 5 00050: 00051: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@Port -- Номер порта 00052: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret where [ID]=@SCOPE 00053: IF @Ret>0 return 5 00054: 00055: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@CurrentUser -- Кому 00056: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret where [ID]=@SCOPE 00057: IF @Ret>0 return 5 00058: 00059: Declare @Byte1 int, @Byte2 int, @Byte3 int, @Byte4 int 00060: exec @Ret=SY_MG_ParseIP @IP, @Byte1 OUTPUT, @Byte2 OUTPUT, @Byte3 OUTPUT, @Byte4 OUTPUT 00061: 00062: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@Byte1 -- Первый байт айпишника 00063: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret where [ID]=@SCOPE 00064: IF @Ret>0 return 5 00065: 00066: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@Byte2 -- Второй байт айпишника 00067: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret where [ID]=@SCOPE 00068: IF @Ret>0 return 5 00069: 00070: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@Byte3 -- Третий байт айпишника 00071: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret 00072: IF @Ret>0 return 5 00073: 00074: exec @Ret= SY_MG_SEND 'Write',@Handler,default,default,@Byte4 -- Четвертый байт айпишника 00075: UPDATE [SY_MG_ConnectTab] SET [StateWrite]=@Ret 00076: IF @Ret>0 return 5 00077: 00078: exec @Ret= SY_MG_SEND 'Abort',@Handler 00079: UPDATE [SY_MG_ConnectTab] SET [StateAbort]=@Ret 00080: IF @Ret>0 return 5 00081: 00082: 00083: Return @SCOPE
Как видите процедура передает серию чисел, принимаемых в строках 178-184. Если все прошло нормально (иначе просто THROW) - в строке 190 создается экземпляр класса SVA_Listener, определенного в строках 241-333. Как видите в строке 257, этот класс параметризованный и проглатывает в себя при создании экземпляра все, что ему надо для работы. Строки 191, 193 и 195 здесь смыслового значения для организации этого класса не имеют, они выполняют учетные функции и позволяют увидеть потом на форме созданные задачи:
А вот строка 192 во всей этой проге - самая что ни на есть ключевая. Она создает НОВЫЙ ПОТОК ИЗ ДИНАМИЧЕСКИ СОЗДАННОГО НАМИ ЭКЗЕМПЛЯРА КЛАССА NewListener. Это принципиально иной прием, чем мы пользовались в строке 76, когда создавали новый поток из самого себя, в классе, в котором уже был один поток. Здесь получается что созданный нами каждый экземпляр фактически работает в однопоточном режиме, для чего все данные для его работы в начале его жизни в строке 257 упрятывались вовнуть него. Как видите ситуация с классом NET_Listener приниципиально иная - тот класс действительно исполняется многими потоками одновременно - один поток кружит по строкам 134-213. Другой поток запрашивает, скажем свойства GetQueue. Но как же я обошелся без SYNCLOCK. А вот так. Все данные развязаны между потоками через нашу хитрую коллекцию (строки 351-384), работающую с классом 336-348.
Здесь есть еще один момент. Как вы видите созданные нами экземпляры классов-потоков передачи устроены несложно. Они просто в строках 307-331 проверяют в бесконечном цикле очередь (нашу коллекцию) в строке 310 и при появлении данных на передачу по своему коннекту начинают передачу. Очередь проверяется с задержкой потока по таймеру в строке 308. На самом деле - это слишком простенько, но моего заказчика-плательщика это пока устроило. На самом деле более корректно было бы (поскольку адрес каждого экземпляра этого класса в строке 191 учтен), можно было бы останавливать поток на синхронизации после передачи данных, а потом после строки 209 сформировать делегат, который разбудит нужный поток и разбуженный поток начнет передачу. Но это более сложный и продвинутый вариант этой проги требующий виртуозной работы не только с классами и потоками, но с делегатами...
В сущности это лишь два основных приема мультипоточной работы. Третья техника - когда из существующего потока сначала создается новый поток, а текущий поток вешается по скажем FORM.SHOWDIALOG, рассмотрена здесь. Причем сделано это в модуле - фактически в заведомо созданном экземпляре класса.
Наконец, в этом же топике рассмотрена и четвертая техника работы с потоками, имеющая специальное название - маршализация в поток формы.
)
|
|