Сокеты: передача на несколько адресов

@Rembrant87 · Регистрация: 30.01.2010

Студворк — интернет-сервис помощи студентам

здравствуйте. мне нужно выполнить передачу нескольких объектов (чисел и массивов) с клиента на 3 сервера. изначально делал это так:

Java
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
try {
    Socket[] s=new Socket[6];
    s[0] = new Socket(ipAdd, 3128);
    ObjectOutputStream out1 = new ObjectOutputStream(s[0].getOutputStream());
    s[1] = new Socket(ipAdd, 3129);
    ObjectInputStream in1 = new ObjectInputStream(s[1].getInputStream());
    out1.writeShort(m);
    out1.flush();
    out1.writeInt(n);
    out1.flush();
    out1.writeObject(b1);
    out1.flush();
    out1.writeObject(c);
    out1.flush();
 
    s[2] = new Socket(ipAdd, 3130);
    ObjectOutputStream out2 = new ObjectOutputStream(s[2].getOutputStream());
    s[3] = new Socket(ipAdd, 3131);
    ObjectInputStream in2 = new ObjectInputStream(s[3].getInputStream());
    out2.writeShort(m);
    out2.flush();
    out2.writeInt(n);
    out2.flush();
    out2.writeObject(b2);
    out2.flush();
    out2.writeObject(c);
    out2.flush();   
 
    s[4] = new Socket(ipAdd, 3132);
    ObjectOutputStream out3 = new ObjectOutputStream(s[4].getOutputStream());
    s[5] = new Socket(ipAdd, 3133);
    ObjectInputStream in3 = new ObjectInputStream(s[5].getInputStream());
    out3.writeShort(m);
    out3.flush();
    out3.writeInt(n);
    out3.flush();
    out3.writeObject(b3);
    out3.flush();
    out3.writeObject(c);
    out3.flush();
}
catch(Exception e)
{System.out.println("init error: "+e);}

всё работает, но при таком способе данные отправляются последовательно сначала на сервер 1, потом на 2 и 3, что при большом объёме данных выглядит не очень красиво и вообще.
чтобы данные отправлялись на серверы одновременно, пытаюсь запихнуть всё в потоки следующим образом:

Java
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
sender1 sd1=new sender1(z);
sender2 sd2=new sender2(z);
sender3 sd3=new sender3(z);
sd1.start();
sd2.start();
sd3.start();
 
//////////////
 
public class sender1 extends Thread
{
    data z;
    public sender1(data q) 
    {z=q;}
    public void run()
    {
        Socket[] s01=new Socket[2];
        try 
        {
            s01[0] = new Socket(ipAdd, 3128);
            ObjectOutputStream out1 = new ObjectOutputStream(s01[0].getOutputStream());
            out1.writeShort(m);
            out1.flush();
            s01[1] = new Socket(ipAdd, 3129);
            ObjectInputStream in1 = new ObjectInputStream(s01[1].getInputStream());
            out1.writeInt(n);
            out1.flush();
            out1.writeObject(b1);
            out1.flush();
            out1.writeObject(c);
            out1.flush();
        }
        catch(Exception e)
        {System.out.println("init error: "+e);}
    }
}
 
public class sender2 extends Thread
{
    data z;
    public sender2(data q) 
    {z=q;}
    public void run()
    {
        Socket[] s02=new Socket[2];
        try 
        {
            s02[0] = new Socket(ipAdd, 3130);
            ObjectOutputStream out2 = new ObjectOutputStream(s02[0].getOutputStream());
            s02[1] = new Socket(ipAdd, 3131);
            ObjectInputStream in2 = new ObjectInputStream(s02[1].getInputStream());
            out2.writeShort(m); 
            out2.flush();
            out2.writeInt(n);
            out2.flush();
            out2.writeObject(b2);
            out2.flush();
            out2.writeObject(c);
            out2.flush();   
        }
        catch(Exception e)
        {System.out.println("init error: "+e);}
    }
}
 
public class sender3 extends Thread
{
    data z;
    public sender3(data q) 
    {z=q;}
    public void run()
    {
        Socket[] s03=new Socket[2];
        try 
        {
            s03[0] = new Socket(ipAdd, 3132);   
            ObjectOutputStream out3 = new ObjectOutputStream(s03[0].getOutputStream());
            s03[1] = new Socket(ipAdd, 3133);
            ObjectInputStream in3 = new ObjectInputStream(s03[1].getInputStream());
            out3.writeShort(m);
            out3.flush();
            out3.writeInt(n);
            out3.flush();
            out3.writeObject(b3);
            out3.flush();
            out3.writeObject(c);
            out3.flush();
        }
        catch(Exception e)
        {System.out.println("init error: "+e);}
    }
}

вроде бы смысл тот же, но на деле получается такое: один сервер (случайный) принимает данные корректно, на остальных двух:
java.lang.NullPointerException:

at java.io.ObjectInputStream.readObject()
at server.SampleServer.run()
если оставить отправку только на один сервер, он принимает всё нормально. пожалуйста, подскажите где у меня ошибка.
или, может, существуют другие способы передачи данных на несколько адресов сразу?

@BogdanPotapenko · 16.02.2010, 19:25

Первое, что приходит в голову: твоя информация z в конструктор в итоге передаётся не по значению, а по ссылке и поэтому, все три потока фактически одновременно работают с одним и тем же объектом.
А это значит, что первый поток его блокирует на время своего выполнения и этот объект становится не доступным для двух других.
То есть тебе нужно эти три потока синхронизировать.

Возможно, должно помочь что-то в таком роде:

Java
1
2
3
4
5
6
7
8
synchronized (z) {
  sender1 sd1=new sender1(z);
  sender2 sd2=new sender2(z);
  sender3 sd3=new sender3(z);
  sd1.start();
  sd2.start();
  sd3.start();
}

ps: все три класса (sender1, 2, 3) абсолютно одинаковые, их можно объединить в один. Просто при создании нового объекта передавать ему параметры сервера к которому подключаться.

Удачи

@Rembrant87 · 17.02.2010, 20:37 **[ТС]**

одинаковые классы я планирую объединить, но думал, пусть пока хоть так получится, бо данные они передают не свосем одинаковые.

так как вы пишете не помогло

пробовал ещё по-другому - помещаю m,n,b,c в z (это монитор), в него же добавляю функции:

Java
1
2
public synchronized double[][] copy_c()
    {return c;}

и далее по аналогии. потом в каждом сендере делаю копирование:

Java
1
2
3
double[][]c1=z.copy_c();
out1.writeObject(c1);
out1.flush();

вместо

Java
1
2
out1.writeObject(z.c);
out1.flush();

и так везде. но после этого передача корректно стала осуществляться то на 1, то на 2 сервера (раньше было на 1). а так всё равно не работает

@Rembrant87 · 06.03.2010, 22:38 **[ТС]**

методом перебора разных вариантов получилось так:

Java
1
2
3
4
5
6
7
8
9
 ObjectInputStream in1 = new ObjectInputStream(s01[1].getInputStream());
            out1.writeInt(n);
            out1.flush();
            synchronized(z) {
               out1.writeObject(b1);
               out1.flush();
            }
            out1.writeObject(c);
            out1.flush();

при чём неважно, какой массив передаю первым, главное, что он в синхронайзе. далее можно передавать пофиг что и пофиг сколько - работает. не совсем понимаю, почему так, но работает

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .	Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .
Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .