HiAsm
HiAsm
Вверх ↑
ФорумыПомощь по пакетуКлиент серверное приложение ← Ctrl1Ctrl →
Этот топик читают: Гость
Ответов: 37
Рейтинг: 5
#1: 2013-06-27 14:12:02 ЛС | профиль | цитата
Всем доброе время суток. опять застопарился.
Есть клиент серверное приложение. Реализовано посредством TCP сервера и TCP клиента, обмен данными идёт dtStream. Клиентов более 500 компьютеров. И вот проблема в том что когда они разом подключаются, и одновременно несколько клиентов пересылают какие либо данные, приходит не понятные данные и порт виснет, и не перенимает больше сообщений. Если серверная часть и клиентские (50 шт тестовых) запущены на одном компе то всё норм, а если серверная установлена на другом компьютере (пробывал как на серваках так и на обычных компьютерах, при разных операционнках) то при подключении 50 тестовых клиентов и пересылки данных серверу порт сервера виснет (ошибок от TCP сервера не вызываются).
есть у кого соображения?
карма: 0

0
Ответов: 37
Рейтинг: 5
#2: 2013-07-29 12:29:50 ЛС | профиль | цитата
давно я сюда не заглядывал, делами был завален. но смотрю идей у людей 0 (
карма: 0

0
Ответов: 8955
Рейтинг: 824
#3: 2013-07-29 12:59:08 ЛС | профиль | цитата
Fidel, так люди своими идеями и делами заняты, где им до других идей
карма: 19

0
Ответов: 45
Рейтинг: 0
#4: 2013-07-29 17:13:34 ЛС | профиль | цитата
Делай сегодня такую идею, что другие даже не думали что это возможно, а завтра эта идея жить будет так, как другие не смогут
карма: 0
всё что мешает нам жить это человеческий фактор который не имеющий границы ..
0
Ответов: 845
Рейтинг: 19
#5: 2013-07-29 17:22:37 ЛС | профиль | цитата
попробуй использовать
code_31510.txt
я 5 тысяч за 1 раз запустил успешно

Add(MainForm,2953706,308,224)
{
 Width=399
 Height=382
 link(onCreate,7843392:doEvent1,[])
}
Add(TCP_ServerEx,16036862,434,238)
{
 ServerPort=8080
 link(onRead,15047266:doAdd,[])
}
BEGIN_SDK
  Add(EditMultiEx,3226023,21,21)
  {
   WorkCount=#6:##open|
   EventCount=#6:onRead|
  }
  Add(TCP_Connection,7164231,154,105)
  {
   link(onRead,3226023:onRead,[(246,111)(246,27)])
  }
  Add(DoData,2479933,273,147)
  {
  }
  Add(Timer,12228736,210,147)
  {
   Interval=100
   link(onTimer,2479933:doData,[])
  }
END_SDK
Add(Hub,7843392,378,238)
{
 link(onEvent1,16036862:##open,[])
}
Add(Button,12470532,301,322)
{
 Left=10
 Top=15
 Data=String(123)
 link(onClick,3324816:doTimer,[])
}
Add(Memo,15047266,532,238)
{
 Left=80
 Top=20
 Width=270
 Height=275
 ScrollBars=3
}
Add(MultiElementEx,10983976,525,322)
{
 link(Data,13703264:Count,[(531,310)(454,310)(454,366)(419,366)])
}
BEGIN_SDK
  Add(EditMultiEx,7562578,21,21)
  {
   WorkCount=#5:##add|
   DataCount=#4:Data|
   Point(##add)
   link(##add,3394148:doEvent1,[(87,27)(87,83)])
  }
  Add(TCP_Client,16235569,266,77)
  {
   Port=8080
   IP="127.0.0.1"
   link(Data,13695799:Result,[(279,65)(233,65)(233,135)(188,135)])
  }
  Add(Hub,3394148,91,77)
  {
   link(onEvent1,16235569:doOpen,[])
   link(onEvent2,13695799:doStrCat,[(143,90)(143,97)])
  }
  Add(StrCat,13695799,182,91)
  {
   Str1="я клиент номер - "
   link(onStrCat,16235569:doSend,[])
   link(Str2,7562578:Data,[(195,56)(27,56)])
  }
END_SDK
Add(Timer,3324816,350,322)
{
 Interval=10
 Enable=1
 AutoStop=5000
 OverCall=1
 link(onTimer,13703264:doNext,[])
}
Add(CounterEx,13703264,413,322)
{
 Max=100000
 link(onNext,10983976:##add,[])
}


Add(MainForm,2953706,301,189)
{
 Width=399
 Height=382
 link(onCreate,7843392:doEvent1,[])
}
Add(Hub,7843392,371,203)
{
 link(onEvent1,13056130:doOpen,[])
}
Add(Button,12470532,301,322)
{
 Left=10
 Top=15
 Data=String(123)
 link(onClick,3324816:doTimer,[])
}
Add(Memo,15047266,532,203)
{
 Left=80
 Top=20
 Width=270
 Height=275
 ScrollBars=3
}
Add(MultiElementEx,10983976,525,322)
{
 link(Data,13703264:Count,[(531,310)(454,310)(454,366)(419,366)])
}
BEGIN_SDK
  Add(EditMultiEx,7562578,21,21)
  {
   WorkCount=#5:##add|
   DataCount=#4:Data|
   Point(##add)
   link(##add,3394148:doEvent1,[(87,27)(87,83)])
  }
  Add(TCP_Client,16235569,266,77)
  {
   Port=8080
   IP="127.0.0.1"
   link(Data,13695799:Result,[(279,65)(233,65)(233,135)(188,135)])
  }
  Add(Hub,3394148,91,77)
  {
   link(onEvent1,16235569:doOpen,[])
   link(onEvent2,13695799:doStrCat,[(143,90)(143,97)])
  }
  Add(StrCat,13695799,182,91)
  {
   Str1="я клиент номер - "
   link(onStrCat,16235569:doSend,[])
   link(Str2,7562578:Data,[(195,56)(27,56)])
  }
END_SDK
Add(Timer,3324816,350,322)
{
 Interval=10
 Enable=1
 AutoStop=1000
 OverCall=1
 link(onTimer,13703264:doNext,[])
}
Add(CounterEx,13703264,413,322)
{
 Max=100000
 link(onNext,10983976:##add,[])
}
Add(TCP_Server,13056130,434,203)
{
 Port=8080
 link(onRead,15047266:doAdd,[])
}
Add(DoData,2479933,434,273)
{
 link(onEventData,10447120:doText,[])
 link(Data,13056130:Count,[])
}
Add(Timer,12228736,371,273)
{
 Interval=100
 link(onTimer,2479933:doData,[])
}
Add(Label,10447120,490,273)
{
 Left=80
 Top=300
}
карма: 0

0
файлы: 1code_31510.txt [146B] [204]
Ответов: 37
Рейтинг: 5
#6: 2013-08-09 07:19:56 ЛС | профиль | цитата
GAv, Ваш пример, отлично работает, но не совсем то что требовалось. В вашем примере пользователи подключаются и отсылают данные последовательно, а надо одновременно, и что бы клиент и серверная часть находились на разных компьютерах, для задержки передачи данных. И при таких условиях, порт виснет(
попробую приложить пример чуть попозже.
------------ Дoбавленo в 07.19:
Всем привет. Короче всё оказалось совсем всё интересно. Поэтому решил всё написать небольшую историю, потомкам на будущее и разработчикам на заметку, так как считаю что ошибка в компонентах (по возможности перенесите тему в категорию "Ошибки компонентов").
Напомню о постановке задаче и о самой проблеме:
Нужно было создать клиент серверное приложение, клиентов более 1000 шт. Решено было использовать TCP_Server и TCP_Client с DataType = dtStream, и Convertor для конвертации данных из dtStream в dtString. Клиенты должны отсылать кое какие данные на сервер, когда сервер становится не доступен, клиенты пытаются вновь подключиться. И вот возникла ошибка, когда все клиенты разом подключаются к серверу и отсылают данные после временной недоступности сервера, сервер воспринимает небольшое количество данных а потом виснет, хотя продолжает подключать к себе новых клиентов.
Для того что бы понять суть проблемы решил написать тестовые программы. Клиентская программа эмитировала 3000 подключений и отсылала данные на сервер.

Серверная часть: 
Add(MainForm,2953706,343,161)
{
 Width=385
 Height=330
 Caption="Server"
 Position=1
 Point(onClose)
 link(onCreate,825948:doOpen,[])
 link(onClose,825948:doClose,[])
}
Add(Label,1776579,637,245)
{
 Left=20
 Top=245
 Width=200
}
Add(Label,7230009,511,266)
{
 Left=20
 Top=220
 Width=200
}
Add(StrCat,7196014,469,266)
{
 Str2=" Количество подключенных"
 link(onStrCat,7230009:doText,[])
 link(Str1,825948:Count,[(475,236)(412,236)])
}
Add(StrCat,15327132,595,245)
{
 Str2=" Количество присланных"
 link(onStrCat,1776579:doText,[])
 link(Str1,11960055:Count,[])
}
Add(Convertor,3413582,539,175)
{
 Mode=11
 DirectFill=1
 link(onResult,11960055:doAdd,[])
}
Add(Memo,11960055,588,175)
{
 Left=15
 Top=15
 Width=335
 Height=190
 ScrollBars=3
 link(onChange,15327132:doStrCat,[(634,181)(634,226)(583,226)(583,251)])
}
Add(TCP_Server,825948,406,175)
{
 Port=1547
 DataType=3
 Point(doSendByIp)
 link(onRead,3413582:doConvert,[])
 link(onConnect,13372437:doEvent1,[])
 link(onDisconnect,13372437:doEvent2,[])
}
Add(Hub,13372437,448,182)
{
 InCount=2
 OutCount=1
 link(onEvent1,7196014:doStrCat,[(469,188)])
}

Клиентская часть: 
Add(MainForm,2953706,266,385)
{
 Width=264
 Height=145
 Caption="Client"
 Position=1
}
Add(Button,8952864,280,497)
{
 Left=75
 Top=40
 Width=135
 Caption="Создать клиентов"
 link(onClick,13120155:doCompare,[])
}
Add(Edit,6520318,476,455)
{
 Left=10
 Top=40
 Hint="Количество клиентов"
 Text="3000"
}
Add(For,16201031,469,504)
{
 link(onEvent,4157259:##add,[])
 link(End,6520318:Text,[])
}
Add(MultiElementEx,4157259,595,504)
{
 Mode=1
 link(IP,11266026:Var3,[(601,446)])
}
BEGIN_SDK
  Add(EditMultiEx,3022714,21,21)
  {
   WorkCount=#5:##add|7:##clear|
   VarCount=#7:##count|
   DataCount=#2:IP|
   Width=867
   Height=298
   Point(##add)
   Point(##clear)
   Point(##count)
   link(##add,1465170:doValue,[(59,27)(59,83)])
  }
  Add(TCP_Client,11433968,287,126)
  {
   Port=1547
   DataType=3
   link(onConnect,1953504:doStrCat,[])
   link(IP,3022714:IP,[(293,74)(27,74)])
  }
  Add(Timer,8884694,182,126)
  {
   Interval=1
   link(onTimer,7644262:doCompare,[])
  }
  Add(If_else,7644262,231,126)
  {
   Op2=Integer(0)
   link(onTrue,11433968:doOpen,[])
   link(Op1,11433968:Active,[(237,114)(265,114)(265,170)(293,170)])
  }
  Add(Memory,1465170,343,77)
  {
  }
  Add(StrCat,1953504,343,133)
  {
   Str2=" - Тестовый текст Очень длинный и сложный, что бы проверить всё на верняка. Тестовый текст Очень длинный и сложный, что бы проверить всё на верняка."
   link(onStrCat,3413582:doConvert,[])
   link(Str1,1465170:Value,[])
  }
  Add(Convertor,3413582,392,133)
  {
   Mode=12
   link(onResult,11433968:doSend,[(441,139)(441,189)(275,189)(275,146)])
  }
END_SDK
Add(Button,9240195,463,548)
{
 Left=75
 Top=65
 Width=135
 Caption="Удалить клиентов"
 link(onClick,4157259:##clear,[(545,554)(545,517)])
}
Add(Edit,13472982,329,385)
{
 Left=10
 Top=15
 Width=200
 Hint="IP адрес сервера"
 Text=""
}
Add(StrMask,13120155,329,497)
{
 Mask="*.*.*.*"
 link(onFalse,9845159:doMessage,[(377,503)(377,468)])
 link(onTrue,16201031:doFor,[])
 link(Str,11266026:Var2,[])
}
Add(Message,9845159,392,462)
{
 Message="Укажите IP адрес сервера"
}
Add(GetDataEx,11266026,329,441)
{
 link(Data,13472982:Text,[])
}

Для имитирования реальных условий, серверную часть программы нужно запускать после запуска 3000 клиентов, которые ждут доступности сервера, и при первой возможности, одновременно подключаться и отправят данные.
Если запустить серверную и клиентскую часть на одном компьютере то всё нормально отрабатывает, все 3000 пользователей подключаются и присылают данные.
Решено было клиентскую часть перенести на соседний компьютер, который находится в одной сети с основным компьютером.
И вот тут та сработала ошибка, которая срабатывала в реальных условиях. Приходили первые данные от первых подключенных пользователях и после конвертации элементом Converter часть из них отображалось, после Convertor походу путался в очереди и выдавал непонятный символ и зависал, хотя остальные пользователи продолжали успешно подключаться и присылать данные.
Началось стадия выяснения проблемы.
Опытным путём было выявлено: что при DataType = dtString в TCP_Server и TCP_Client и соответственно без Convertor, всё отлично работает. Пример:

Серверная часть DataType = dtString: 
Add(MainForm,2953706,343,161)
{
 Width=385
 Height=330
 Caption="Server"
 Position=1
 Point(onClose)
 link(onCreate,825948:doOpen,[])
 link(onClose,825948:doClose,[])
}
Add(Label,1776579,637,245)
{
 Left=20
 Top=245
 Width=200
}
Add(Label,7230009,511,266)
{
 Left=20
 Top=220
 Width=200
}
Add(StrCat,7196014,469,266)
{
 Str2=" Количество подключенных"
 link(onStrCat,7230009:doText,[])
 link(Str1,825948:Count,[(475,236)(412,236)])
}
Add(StrCat,15327132,595,245)
{
 Str2=" Количество присланных"
 link(onStrCat,1776579:doText,[])
 link(Str1,11960055:Count,[])
}
Add(Memo,11960055,588,175)
{
 Left=15
 Top=15
 Width=335
 Height=190
 ScrollBars=3
 link(onChange,15327132:doStrCat,[(634,181)(634,226)(583,226)(583,251)])
}
Add(TCP_Server,825948,406,175)
{
 Port=1547
 Point(doSendByIp)
 link(onRead,11960055:doAdd,[])
 link(onConnect,13372437:doEvent1,[])
 link(onDisconnect,13372437:doEvent2,[])
}
Add(Hub,13372437,448,182)
{
 InCount=2
 OutCount=1
 link(onEvent1,7196014:doStrCat,[(469,188)])
}

Клиентская часть DataType = dtString: 
Add(MainForm,2953706,266,385)
{
 Width=264
 Height=145
 Caption="Client"
 Position=1
}
Add(Button,8952864,280,497)
{
 Left=75
 Top=40
 Width=135
 Caption="Создать клиентов"
 link(onClick,13120155:doCompare,[])
}
Add(Edit,6520318,476,455)
{
 Left=10
 Top=40
 Hint="Количество клиентов"
 Text="3000"
}
Add(For,16201031,469,504)
{
 link(onEvent,4157259:##add,[])
 link(End,6520318:Text,[])
}
Add(MultiElementEx,4157259,595,504)
{
 Mode=1
 link(IP,11266026:Var3,[(601,446)])
}
BEGIN_SDK
  Add(EditMultiEx,3022714,21,21)
  {
   WorkCount=#5:##add|7:##clear|
   VarCount=#7:##count|
   DataCount=#2:IP|
   Width=867
   Height=298
   Point(##add)
   Point(##clear)
   Point(##count)
   link(##add,1465170:doValue,[(59,27)(59,83)])
  }
  Add(TCP_Client,11433968,287,126)
  {
   Port=1547
   link(onConnect,1953504:doStrCat,[])
   link(IP,3022714:IP,[(293,74)(27,74)])
  }
  Add(Timer,8884694,182,126)
  {
   Interval=1
   link(onTimer,7644262:doCompare,[])
  }
  Add(If_else,7644262,231,126)
  {
   Op2=Integer(0)
   link(onTrue,11433968:doOpen,[])
   link(Op1,11433968:Active,[(237,114)(265,114)(265,170)(293,170)])
  }
  Add(Memory,1465170,343,77)
  {
  }
  Add(StrCat,1953504,343,133)
  {
   Str2=" - Тестовый текст Очень длинный и сложный, что бы проверить всё на верняка. Тестовый текст Очень длинный и сложный, что бы проверить всё на верняка."
   link(onStrCat,11433968:doSend,[(384,139)(384,187)(275,187)(275,146)])
   link(Str1,1465170:Value,[])
  }
END_SDK
Add(Button,9240195,463,548)
{
 Left=75
 Top=65
 Width=135
 Caption="Удалить клиентов"
 link(onClick,4157259:##clear,[(545,554)(545,517)])
}
Add(Edit,13472982,329,385)
{
 Left=10
 Top=15
 Width=200
 Hint="IP адрес сервера"
 Text=""
}
Add(StrMask,13120155,329,497)
{
 Mask="*.*.*.*"
 link(onFalse,9845159:doMessage,[(377,503)(377,468)])
 link(onTrue,16201031:doFor,[])
 link(Str,11266026:Var2,[])
}
Add(Message,9845159,392,462)
{
 Message="Укажите IP адрес сервера"
}
Add(GetDataEx,11266026,329,441)
{
 link(Data,13472982:Text,[])
}

Далее было решено вернуть DataType = dtStream, так как того требовала основная задача. Далее заменил элемент в серверной части TCP_Server на TCP_ServerEx.

Серверная часть TCP_ServerEx: 
Add(MainForm,2953706,343,161)
{
 Width=385
 Height=330
 Caption="Server"
 Position=1
 Point(onClose)
 link(onCreate,7089171:##open,[])
 link(onClose,7089171:##Close,[])
}
Add(Label,1776579,637,245)
{
 Left=20
 Top=245
 Width=200
}
Add(Label,7230009,511,266)
{
 Left=20
 Top=220
 Width=200
}
Add(StrCat,7196014,469,266)
{
 Str2=" Количество подключенных"
 link(onStrCat,7230009:doText,[])
 link(Str1,7089171:##Count,[(475,236)(412,236)])
}
Add(StrCat,15327132,595,245)
{
 Str2=" Количество присланных"
 link(onStrCat,1776579:doText,[])
 link(Str1,11960055:Count,[])
}
Add(Memo,11960055,588,175)
{
 Left=15
 Top=15
 Width=335
 Height=190
 ScrollBars=3
 link(onChange,15327132:doStrCat,[(634,181)(634,226)(583,226)(583,251)])
}
Add(TCP_ServerEx,7089171,406,175)
{
 ServerPort=1547
 link(onRead,3413582:doConvert,[])
 link(onEvent1,7196014:doStrCat,[(454,188)(454,272)])
}
BEGIN_SDK
  Add(EditMultiEx,2650183,21,21)
  {
   WorkCount=#6:##open|7:##Close|
   EventCount=#6:onRead|8:onEvent1|
   VarCount=#7:##Count|
   Point(##Count)
  }
  Add(TCP_Connection,12087566,189,105)
  {
   DataType=3
   link(onRead,2650183:onRead,[(271,111)(271,27)])
   link(onConnect,460347:doEvent1,[])
   link(onDisconnect,460347:doEvent2,[])
  }
  Add(Hub,460347,259,112)
  {
   InCount=2
   OutCount=1
   link(onEvent1,2650183:onEvent1,[(297,118)(297,34)])
  }
END_SDK
Add(Convertor,3413582,539,175)
{
 Mode=11
 DirectFill=1
 link(onResult,11960055:doAdd,[])
}

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

И о чудо! Всё работает!
Выявлено, что при условиях:
1) TCP_Server с DataType = dtStream;
2) TCP_Server + Convertor;
3) Работа через сеть.
Возникает странная ошибка (как мне показалось зависание элемента Convertor). Хотя при использовании TCP_ServerEx вместо TCP_Server при таких же условиях ошибка не выдаётся и всё нормально функционирует.

Ну так как причина выявлена можно переходить к применению знаний к основной программе, но тут возникла загвозка. Как в элементе TCP_ServerEx отправлять данные для всех пользователей и для определённых по IP адресу (где взять точки doSend и doSendByIp у TCP_ServerEx аналогичные TCP_Server)? Является ли точка doSend в компоненте TCP_Connection аналогом как у TCP_Server?

Надеюсь разработчики обратят внимание на эти проблемы.
Комментируйте, обсуждайте, жду предложений и подсказок.
карма: 0

0
Ответов: 45
Рейтинг: 0
#7: 2013-08-10 18:51:21 ЛС | профиль | цитата
довольно таки интересно
карма: 0
всё что мешает нам жить это человеческий фактор который не имеющий границы ..
0
Ответов: 3851
Рейтинг: 159
#8: 2013-08-14 21:13:01 ЛС | профиль | цитата

Fidel, способы работы с TCP_ServerEx можно поискать по форуму (например мои посты )
BTW: memo имеет некоторые ограничения по объёму текста..
Fidel писал(а):
Возникает странная ошибка (как мне показалось зависание элемента Convertor)
поставь вместо него Debug - узнаешь, даже memo не нужен IMHO..

P.S.: dtString (в TCP_Server) точно не подойдёт?
карма: 0
начавший
0
8
ФорумыПомощь по пакетуКлиент серверное приложение ← Ctrl1Ctrl →
Сообщение
...
Прикрепленные файлы
(файлы не залиты)
HiAsm Studio 2003 - 2025
Пользовательское соглашение | support@hiasm.com
Яндекс.Метрика