Передача данных между клиентами

@NkL · Регистрация: 11.10.2020

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

Есть два клиента-приложения (в моём случае, на одном компьютере) и сервер. Как реализовать передачу объекта от одного клиента другому? Связующим звеном является сервер. Я пока написал этот код. Сервер получает объект класса, но при попытке передать его вылетает ошибка SocketException: Socket is closed. Вот код клиента и сервера. settings это класс с основными настройками клиента.

Клиент

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
        socketItem.addActionListener(e1 -> {
            updateSettings();
            try (Socket socket = new Socket()) {
                socket.connect(new InetSocketAddress("localhost",25565));
                ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                objectOutputStream.writeObject(settings);
                objectOutputStream.flush();
                objectOutputStream.close();
            } catch (IOException e2) {
                e2.printStackTrace();
            }
        });
 
        updateItem.addActionListener(e -> {
            updateForm();
        });

Сервер

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
package com.company;
 
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
 
public class Server implements Runnable {
    private Settings settings;
    private final Socket socket;
 
    Server(Socket socket) {
        this.socket = socket;
    }
 
    @Override
    public void run() {
        receive();
        send();
    }
 
    public void receive() {
        try (ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
            settings = (Settings) objectInputStream.readObject();
            System.out.println("Receiving message");
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
 
    public void send() {
        try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream())) {
            if (socket.isConnected())
                socket.close();
            socket.connect(new InetSocketAddress("localhost",25565));
            System.out.println("Sending message");
            objectOutputStream.writeObject(settings);
            objectOutputStream.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
    public static void main(String[] args) throws IOException {
        try (ServerSocket serverSocket = new ServerSocket(25565)) {
            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("Client connected");
                new Thread(new Server(socket)).start();
            }
        }
    }
}

@xoraxax · 28.05.2021, 15:10

https://cs.lmu.edu/~ray/notes/javanetexamples/

@NkL · 28.05.2021, 19:46 **[ТС]**

Сообщение от xoraxax

https://cs.lmu.edu/~ray/notes/javanetexamples/

Написал такой вариант. Вроде всё работает, но есть один вопрос. Почему при повторной попытке передать серверу данные бросается ошибка о том, что сокет уже закрыт? В конструкторе сервера поставил бесконечный цикл, и бросается эта ошибка.

Серверная часть

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
package com.company;
 
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
 
public class Server {
    private Settings settings;
    private final Socket socketSend;
    private final Socket socketReceive;
 
    Server(Socket socketSend, Socket socketReceive) {
        this.socketSend = socketSend;
        this.socketReceive = socketReceive;
        transmission();
    }
 
    public void transmission() {
        while (true) {
            receive();
            send();
        }
    }
 
    public void receive() {
        try (ObjectInputStream objectInputStream = new ObjectInputStream(socketSend.getInputStream())) {
            settings = (Settings) objectInputStream.readObject();
            System.out.println("Receiving message");
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
 
    public void send() {
        try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socketReceive.getOutputStream())) {
            System.out.println("Sending message");
            objectOutputStream.writeObject(settings);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    public static void main(String[] args) throws IOException {
        try (ServerSocket serverSocket = new ServerSocket(25565)) {
            while (true) {
                Socket socketSend = serverSocket.accept();
                Socket socketReceive = serverSocket.accept();
                System.out.println("Clients connected");
                new Server(socketSend,socketReceive);
            }
        }
    }
}

Клиент

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
        connectItem.addActionListener(e1 -> {
            try {
                socket.connect(new InetSocketAddress("localhost",25565));
            } catch (IOException e2) {
                e2.printStackTrace();
            }
        });
 
        sendItem.addActionListener(e1 -> {
            updateSettings();
            try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream())) {
                objectOutputStream.writeObject(settings);
            } catch (IOException e2) {
                e2.printStackTrace();
            }
        });
 
        receiveItem.addActionListener(e -> {
            try (ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
                settings = (Settings) objectInputStream.readObject();
            } catch (IOException | ClassNotFoundException e2) {
                e2.printStackTrace();
            }
            updateForm();
        });

@xoraxax · 28.05.2021, 21:34

Ну в примерах, как я помню, не было никаких ошибок

@NkL · 30.05.2021, 08:49 **[ТС]**

Сообщение от xoraxax

Ну в примерах, как я помню, не было никаких ошибок

Решил свою проблему. Суть проблемы была в том, что после передачи данных серверу клиент закрывал свой сокет автоматически. Поэтому каждый раз, когда надо передать новые данные на сервер, нужно делать так:

Java
1
socket = new Socket();

На новый пакет данных открывается новый сокет, передаёт их, и закрывается.

@korvin_ · 30.05.2021, 09:23

Сообщение от NkL

Поэтому каждый раз, когда надо передать новые данные на сервер, нужно делать так:

Нет, нужно открывать сокет один раз и закрывать один раз.

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
    private Socket socket;
    private ObjectOutputStream output;
    private ObjectInputStream input;
 
    …
 
    private void disconnect() {
        if (output != null) {
            try {
                output.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            output = null;
        }
        if (input != null) {
            try {
                input.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            input = null;
        }
        if (socket != null) {
            try {
                socket.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            socket = null;
        }
    }
 
    …
 
        connectItem.addActionListener(event -> {
            disconnect();
 
            socket = new Socket();
            try {
                socket.connect(new InetSocketAddress("localhost",25565));
                output = new ObjectInputStream(socket.getOutputStream());
                input = new ObjectInputStream(socket.getInputStream());
            } catch (IOException e) {
                e.printStackTrace();
                disconnect();
            }
        });
 
        sendItem.addActionListener(event -> {
            if (output == null) {
                System.err.println("disconnected");
                return;
            }
            updateSettings();
            try {
                objectOutputStream.writeObject(settings);
            } catch (IOException e) {
                e.printStackTrace();
            }
        });
 
        receiveItem.addActionListener(event -> {
            if (input == null) {
                System.err.println("disconnected");
                return;
            }
            try {
                settings = (Settings) objectInputStream.readObject();
                updateForm();
            } catch (IOException | ClassNotFoundException e) {
                e.printStackTrace();
            }
        });

Новые блоги и статьи Все статьи Все блоги /
Символические и жёсткие ссылки в Linux. algri14 15.03.2026 Существует два типа ссылок — символические и жёсткие. Ссылка в Linux — это дополнительная запись в каталоге, которая может указывать либо на inode «файла-ИСТОЧНИКА», тогда это будет «жёсткая. . .	[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ФедосеевПавел 14.03.2026 Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .	делаю науч статью по влиянию грибов на сукцессию anaschu 13.03.2026 прикрепляю статью	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 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .

@xoraxax 3639 / 2971 / 918 Регистрация: 05.07.2013 Сообщений: 14,220
	28.05.2021, 15:10
	https://cs.lmu.edu/~ray/notes/javanetexamples/ 1

@xoraxax 3639 / 2971 / 918 Регистрация: 05.07.2013 Сообщений: 14,220
	28.05.2021, 21:34
	Ну в примерах, как я помню, не было никаких ошибок 0