%read()
 n ozt,oio,y,l,len s ozt=$ZT,$ZT="%readErr",oio=$IO
 u device r y# 2 :Timeout e  s Status= 0 ,$ZT=ozt u oio  q ""
 s len=+($A(y, 1 )* 256 )+$A(y, 2 ) s y=len# 31990  ; проверка на длину строки и заодно переполнение буфера
 r l#(y):Timeout e  s Status= 0 ,$ZT=ozt u oio  q ""
 s Status= 1  u oio q l
%readErr s Status=- 1 ,$ZT=ozt,Connected= 0  u oio  q ""
 q ""

%write(astr) s astr=$g(astr,"")
 i 'Connected s Status=- 1  q Status
 n ozt,oio,l s ozt=$ZT,$ZT="%writeErr",oio=$IO,l=($l(astr)# 31990 ) ; проверка на длину строки и заодно переполнение буфера
 u device w $C(l\ 256 ,l# 256 ),$e(astr, 0 ,l) w ! s $ZT=ozt u oio s Status= 1  q Status
%writeErr s $ZT=ozt,Connected= 0  u oio s Status=- 1  q Status
 q ""

TRead() ;
 n str 
TReadLoop s str=$$%read() q:(Status< 1 ) "" s Command=$lg(str, 1 ) 
 i Command= 1  s $li(str, 1 )= 2  d %write(str) g TReadLoop ; пинг спросили отошлем дальше и будес слушать все остальное
 i Command= 2  q $li(str, 2 , 5 )    ; пинг вернулся - отдали данные без  1 -го элемента - комманды
 i Command= 3  q $lg(str, 5 )      ; данные пришли
 q ""

TWrite(astr) s astr=$g(astr,"")
 d %write($lb( 3 ,"","","",astr)) i Status= 1  s Command= 3 
 q Status

// Клиент
d %connection.TWrite($lb("GSA:READ","^Pluk")
for   {
 set ret=%connection.TRead() quit:%connection.Status'=1 
 set comand=$lg(ret,1) quit:comand'="GSA:READOK"  
 w "Узел :",$lg(ret, 2 )
 w " = ",$lg(ret, 3 ),!
}

//Сервер
s str=%connection.TRead() 
if $lb(str, 1 )="GSA:READ"  {
 d GSAREAD($lb(str, 2 ))
}elseif  0 = 1  {
 // ...
}

GSAREAD(glb)
 new var,ret
 set $ZT="GSAREADerr"
 set var=$g(glb)
 set ret=$g(@var)
 for { set ret=$q(@ret) quit:ret="" 
  d %connection.TWrite($lb("GSA:READOK",ret,$g(@ret))
 }
 set $ZT=""
 q
GSAREADerr
 set $ZT=""
 q 

 o ..device:(..host:..port:"S"):..Timeout 

 
// открытие и ожидание
o io:("":port:"SA"):Timeout 
// запуск конкрурентных запросов
loop u io r x ;Read for accept 
 j childstart($j,log):(: 5 :io:io) ;  Concurrent server bit is on
 // еще нужен код по выключению сервера
 g loop 

// процедура запуска детишек
childstart(serverjob,slog)
 // внутри ChildLoop создается %connection и процедура может отдавать данные
 d ..ChildLoop(serverjob,slog)
 q

set con=##class(класс).%New()
if con.OpenConnection("127.0.0.1","3333") {
 d %connection.TWrite($lb("GSA:READ","^Pluk")
}
set con=""

do ##class(класс).ServerStart("3333")

d ##class(csp.samples.menu).Page()

/// Клиент-Сервер
Class User.Net Extends %Library.RegisteredObject
{

/// Команда
Property Command As %Library.String;

/// Истина если соединение произведено
Property Connected As %Boolean [ InitialExpression =  0  ];

/// Статус текущей операции
Property Status As %Library.Integer [ InitialExpression =  0  ];

/// Имя системы выполнения
Property Sys As %Library.String [ InitialExpression = {$S(($zv["VMS"):"M/AV",($zv["Windows"):"M/WNT", 1 :"M/UX")} ];

///Таймаут по умолчанию
Property Timeout As %Integer [ InitialExpression = { 10 } ];

Property Type As %Library.String;

/// Строка с описанием устройства используем  9000 -е  порты
Property device As %String [ InitialExpression = {"|TCP|9"_$R( 999 )} ];

/// адрес хоста (IP)
Property host As %Library.String;

/// Порт
Property port As %Library.String;

/// Нулевое устройство что бы сбрасывать ненужную отладку
Property nulldevice As %Library.String [ Calculated, InitialExpression = {"//./nul"} ];


/// в  5 -ке нужно проверять
Method %OnClose() As %Library.Status
{
 d:..Connected ..CloseConnection() q $$$OK
}

/// Инициализим хост и порт  - если указаны сразу соединяемся
Method %OnNew(arg As %Library.String = "") As %Library.Status
{
 n sc,host,port,time s host=$p(arg,":", 1 ),port=$p(arg,":", 2 ),time=$p(arg,":", 3 )
 s ..host=host,..port=port s:time'="" ..Timeout=time
 i (((..host)'="")&(..port'="")) s sc=..OpenConnection(..host,..port)
 q $$$OK
}

/// asc=1 все ок
/// asc=0 таймаут
/// asc=-1 обрыв связи
Method %read() As %Library.String [ Private ]
{
 i '..Connected s ..Status=- 1  q ""
 n ozt,oio,y,l,len s ozt=$ZT,$ZT="%readErr",oio=$IO
 u ..device r y# 2 :..Timeout e  s ..Status= 0 ,$ZT=ozt u oio  q ""
 s len=+($A(y, 1 )* 256 )+$A(y, 2 ) s y=len# 31990  ; проверка на длину строки и заодно переполнение буфера
 r l#(y):..Timeout e  s ..Status= 0 ,$ZT=ozt u oio  q ""
 s ..Status= 1  u oio q l
%readErr s ..Status=- 1 ,$ZT=ozt,..Connected= 0  u oio  q ""
}

Method %write(astr As %Library.String = "") As %Library.Status [ Private ]
{
 i '..Connected s ..Status=-1 q ..Status
 n ozt,oio,l s ozt=$ZT,$ZT="%writeErr",oio=$IO,l=($l(astr)#31990) ; проверка на длину строки и заодно переполнение буфера
 u ..device w $C(l\256,l#256),$e(astr,0,l) w ! s $ZT=ozt u oio s ..Status=1 q ..Status
%writeErr s $ZT=ozt,..Connected=0 u oio s ..Status=-1 q ..Status
}

ClassMethod ChildLoop(sjob As %Library.Integer = 0, aslog As %Library.String = "") As %Library.Status [ Private ]
{
 n %nul,%x,%oldzt,%connection,%type,%sc,%machname,%ipaddr,%userid,%exename,%userdate
 s %oldzt=$ZT,$ZT="childErr",sjob=$g(sjob,"1")
 /// Создаем %connection для JOB и заполняем его
 s %connection=..%New(),%nul=%connection.nulldevice
 s %connection.Connected=1,%connection.device=$IO o %nul u %nul
 i aslog="" s aslog=%nul
 s $ZE=""
 s ^CacheTempserverlog($i(^CacheTempserverlog))=$j_" Server JOB Started"
 /// Читаем первую команду 
 s %x=%connection.TRead() i %connection.Status<0  g childErr

 // Чего нибудь делаем


 s ^CacheTempserverlog($i(^CacheTempserverlog))=$j_" Server JOB Complete" 
childErr s ^CacheTempserverlog($i(^CacheTempserverlog))=$j_" HALT "_$ZE 
 s $ZT=%oldzt 
closechild d %connection.%Close() d $system.OBJ.CloseObjects() 
 q  
}

Method CloseConnection() As %Library.Status
{
 n ozt s ozt=$ZT,$ZT="CloseConnectionErr" i ..Connected c ..device 
 s ..Connected=0,$ZT=ozt 
 q 1
CloseConnectionErr s ..Connected=0,$ZT=ozt q -1
}

/// Вернет IO
Method OpenConnection(host As %Library.String = {"127.0.0.1"}, serverport As %Library.String = {9001}) As %Library.Integer
{
 i ..Connected s ..Status=1 q ..Status
 n ozt s ozt=$ZT,$ZT="OpenConnectionErr",..host=host,..port=serverport 
 o ..device:(..host:..port:"S"):..Timeout e  s ..Connected=0,$ZT=ozt,..Status=0 q ..Status
 s ..Connected=1,$ZT=ozt,..Status=1 q ..Status
OpenConnectionErr s ..Connected=0,$ZT=ozt,..Status=-1 q ..Status
}

ClassMethod ServerLoop(Log As %Library.String = 0) As %Library.Status [ Private ]
{
 n ttt,log,serverport,io,sc,x,len,y s x="",y="",sc=0,log=0
 s log="srv.log" o log:"WAS":5 e  s log=$IO
 i log'=$IO c log
 
 s io="|TCP|9"_$R( 999 )
 
 s serverport= 9001 
 
 #; ip не указывается - слушать на всех адресах  
 o io:("":serverport:"SA"): 10  e  u log w "[",$ZDT($H),"] ["_$j($j, 4 )_"] 0.0.0.0 :",serverport," Cannot open server [",$ZUTIL( 67 , 6 ,$Job),"]",! u  0  c log q $$$ERROR(- 1 ,"["_$ZDT($H)_"] Cannot open server 0.0.0.0 :"_serverport)
 
 o log:"WAS" i $t u log w "[",$ZDT($H),"] ["_$j($j, 4 )_":"_$j($j, 4 )_"] "_$j("0.0.0.0", 15 )_":"_$j(serverport, 5 )_" Server started [",$ZUTIL( 67 , 6 ,$Job),"]",! u  0  c log
 
 s $ZT="serverErr" k ^CacheTemp("ServerControlCenter",$j) s ^CacheTemp("ServerControlCenter",$j)= 1  
 
loop u io r x ;Read for accept 
 j childstart($j,log):(: 5 :io:io) ;  Concurrent server bit is on
 /// Постой машинист не стучите колеса
 s ttt=$g(^CacheTemp("ServerControlCenter",$j),- 1 )
 i ttt= 0  o log:"WAS" i $t u log w "[",$ZDT($H),"] ["_$j($j, 4 )_":"_$j($j, 4 )_"] "_$j("0.0.0.0", 15 )_":"_$j(serverport, 5 )_" Recive STOP signal",! u  0  c log g serverErr
 e  g loop
 
serverErr
 u  0  c io 
 o log:"WAS" i $t u log w "[",$ZDT($H),"] ["_$j($j, 4 )_":"_$j($j, 4 )_"] "_$j("0.0.0.0", 15 )_":"_$j(serverport, 5 )_" Server Shutdown $ZE=",$ZE,! u  0  c log
 q $$$OK
 #; дочерний процесс
childstart(serverjob,slog)
 d ..ChildLoop(serverjob,slog)
 q
}

/// asc= 1  все ок
/// asc= 0  таймаут
/// asc=- 1  обрыв связи
Method TRead() As %Library.String
{
 n str 
TReadLoop s str=..%read() q:(..Status< 1 ) "" s ..Command=$lg(str, 1 ) 
 i ..Command= 1  s $li(str, 1 )= 2  d ..%write(str) g TReadLoop ; пинг спросили отошлем дальше и будес слушать все остальное
 i ..Command= 2  q $li(str, 2 , 5 )    ; пинг вернулся - отдали данные без  1 -го элемента - комманды
 i ..Command= 3  q $lg(str, 5 )      ; данные пришли
 q ""
}

Method TWrite(astr As %Library.String = "") As %Library.Status
{
 d ..%write($lb( 3 ,"","","",astr)) i ..Status= 1  s ..Command= 3 
 q ..Status
}

Method nulldeviceGet() As %Library.String [ CodeMode = expression ]
{
$S((..Sys["M/AV"):"NL:",(..Sys["M/WNT"):"//./nul", 1 :"/dev/null/")
}

}