Простой клиент-сервер с многопоточностью

@uLong · Регистрация: 18.04.2015

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

Hello. Разбираюсь с сетью в Java и у меня есть несколько вопросов и одна проблема, помогите, пожалуйста.

1. Какой основной принцип работы клиент-сервера с многопоточностью? Под каждого клиента сервер должен выделять отдельный поток? Я видимо не совсем понял с уроков.

2. Что бы пользователи могли обмениваться информацией, то один из них должен быть сервером или между ними должен быть посредник-сервер? Тогда они смогу обмениваться так сказать "в обе стороны" ?

3. Ранее писал простое подключение без многопоточности и получилось отлично, но сейчас же я хочу сделать маленький чат и получается плохо.
А именно: происходит соединение (проверял) с сервером, но при отправке через мою функцию sendData есть ошибки, хотя у меня все как в уроке, почти.

Исходные коды:

Сервер

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
import java.io.*;
import java.net.*;
 
public class Server implements Runnable {
 
    private static ServerSocket serverSocket;
    private static Socket connection;
    private static ObjectInputStream inputStream;
    private static ObjectOutputStream outputStream;
 
    Server()
    {
        new Thread(this).start();
    }
 
    @Override
    public void run() {
        System.out.println("System message: Server started successfully!");
        System.out.println("System message: Waiting for clients...");
        System.out.println("============================================");
        try {
            serverSocket = new ServerSocket(4364, 10);
            while (true) {
                connection = serverSocket.accept();
                System.out.println("System message: Client connected.");
                inputStream = new ObjectInputStream(connection.getInputStream());
                outputStream = new ObjectOutputStream(connection.getOutputStream());
                outputStream.writeObject("Your message: " + (String)inputStream.readObject());
            }
        } catch (Exception e) { e.printStackTrace(); }
    }
}

Клиент

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
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
 
public class Client extends JFrame implements Runnable {
    private static Socket connection;
    private static ObjectInputStream inputStream;
    private static ObjectOutputStream outputStream;
 
    JTextField textField1;
    JButton buttonSend;
    MyActionListener myActionListener;
 
    public Client(String title, int width, int height)
    {
        setTitle(title);
        setSize(width,height);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setLayout(new FlowLayout());
        setLocationRelativeTo(null);
        setVisible(true);
 
        myActionListener = new MyActionListener();
        textField1 = new JTextField(15);
        buttonSend = new JButton("Send");
        buttonSend.addActionListener(myActionListener);
 
        add(textField1);
        add(buttonSend);
 
       new Thread(this).start();
    }
 
    @Override
    public void run() {
        try {
            while (true) {
                connection = new Socket(InetAddress.getByName("10.132.121.47"), 4364);
                inputStream = new ObjectInputStream(connection.getInputStream());
                outputStream = new ObjectOutputStream(connection.getOutputStream());
                JOptionPane.showMessageDialog(null, (String)inputStream.readObject());
            }
        } catch (Exception e) { e.printStackTrace(); }
    }
 
    public static void sendData(Object obj)
    {
        try {
            outputStream.flush();
            outputStream.writeObject(obj);
        } catch (Exception e) { e.printStackTrace(); }
    }
 
    private class MyActionListener implements ActionListener {
 
        public void actionPerformed(ActionEvent e)
        {
            if(e.getSource().equals(buttonSend))
                sendData(textField1.getText());
        }
    }
}

Main

Java
1
2
3
4
5
6
7
public class Main {
    public static void main(String[] argc)
    {
        Server server = new Server();
        Client client = new Client("Test", 300,80);
    }
}

Ошибки появляется при отправке текста (клик по кнопке buttonSend).

Errors:

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
System message: Server started successfully!
System message: Waiting for clients...
============================================
System message: Client connected.
java.lang.NullPointerException
    at Client.sendData(Client.java:51)
    at Client$MyActionListener.actionPerformed(Client.java:61)
    at javax.swing.AbstractButton.fireActionPerformed(AbstractButton.java:2022)
    at javax.swing.AbstractButton$Handler.actionPerformed(AbstractButton.java:2346)
    at javax.swing.DefaultButtonModel.fireActionPerformed(DefaultButtonModel.java:402)
    at javax.swing.DefaultButtonModel.setPressed(DefaultButtonModel.java:259)
    at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(BasicButtonListener.java:252)
    at java.awt.Component.processMouseEvent(Component.java:6525)
    at javax.swing.JComponent.processMouseEvent(JComponent.java:3324)
    at java.awt.Component.processEvent(Component.java:6290)
    at java.awt.Container.processEvent(Container.java:2234)
    at java.awt.Component.dispatchEventImpl(Component.java:4881)
    at java.awt.Container.dispatchEventImpl(Container.java:2292)
    at java.awt.Component.dispatchEvent(Component.java:4703)
    at java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4898)
    at java.awt.LightweightDispatcher.processMouseEvent(Container.java:4533)
    at java.awt.LightweightDispatcher.dispatchEvent(Container.java:4462)
    at java.awt.Container.dispatchEventImpl(Container.java:2278)
    at java.awt.Window.dispatchEventImpl(Window.java:2750)
    at java.awt.Component.dispatchEvent(Component.java:4703)
    at java.awt.EventQueue.dispatchEventImpl(EventQueue.java:758)
    at java.awt.EventQueue.access$500(EventQueue.java:97)
    at java.awt.EventQueue$3.run(EventQueue.java:709)
    at java.awt.EventQueue$3.run(EventQueue.java:703)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.security.ProtectionDomain$1.doIntersectionPrivilege(ProtectionDomain.java:75)
    at java.security.ProtectionDomain$1.doIntersectionPrivilege(ProtectionDomain.java:86)
    at java.awt.EventQueue$4.run(EventQueue.java:731)
    at java.awt.EventQueue$4.run(EventQueue.java:729)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.security.ProtectionDomain$1.doIntersectionPrivilege(ProtectionDomain.java:75)
    at java.awt.EventQueue.dispatchEvent(EventQueue.java:728)
    at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:201)
    at java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:116)
    at java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:105)
    at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:101)
    at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:93)
    at java.awt.EventDispatchThread.run(EventDispatchThread.java:82)
 
Process finished with exit code 0

Я думаю что я просто грубо говоря "протупил" с этими потоками где-то.

P.S. — Если есть какие-то советы по написанию чата, всегда готов выслушать. Это почти первый опыт работы с сокетами и многопоточностью

@asdzxc · 20.10.2015, 16:58

Сервер

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
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
 
public class Server implements Runnable {
 
    static Client[] clients = new Client[10];
    static ServerSocket serverSocket;
 
    @Override
    public void run() {
        try {
            serverSocket = new ServerSocket(1234, 10);
            while (!serverSocket.isClosed()){
                Socket socket = serverSocket.accept();
                for (int i = 0; i < 9; i++){
                    if (clients[i] == null){
                        (clients[i] = new Client(socket, clients)).start();
                        break;
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Все еще сервер, только отдельный поток для каждого подключения.

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
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
 
public class Client extends Thread {
 
    private Socket socket;
    private Client[] clients;
    private ObjectInputStream input;
    private ObjectOutputStream output;
 
    Client(Socket socket, Client[] clients){
        this.socket = socket;
        this.clients = clients;
    }
 
    @Override
    public void run() {
        try {
            input = new ObjectInputStream(socket.getInputStream());
            String login = input.readObject().toString();
            output = new ObjectOutputStream(socket.getOutputStream());
            output.writeObject("Welcome! " + login + ".");
            String line = login + " connected to chat!";
            ChatFrame.addMsg(line);
            for (int i = 0; i < 9; i++){
                if ((clients[i] != null) && (clients[i] != this)){
                    clients[i].sendMsg(login + " connected to chat!");
                }
            }
 
            while (true){
                String msg = input.readObject().toString();
                if (msg.equals("quit")){
                    ChatFrame.addMsg(login + " left chat. Bye Bye Bye");
                    for (int i = 0; i < 9; i++){
                        if ((clients[i] != null) && (clients[i] != this)){
                            clients[i].sendMsg(login + " left chat. Bye Bye Bye");
                        }
                    }
                    break;
                }
                ChatFrame.addMsg(login + ": " + msg);
                for (int i = 0; i < 9; i++){
                    if ((clients[i] != null) && (clients[i] != this)){
                        clients[i].sendMsg(login + ": " + msg);
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        finally {
            try {
                input.close();
                output.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    void sendMsg(String msg){
        try {
            output.flush();
            output.writeObject(msg);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Клиент

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
import javax.swing.*;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.InetAddress;
import java.net.Socket;
 
public class Network implements Runnable {
 
    static Socket socket;
    static ObjectInputStream input;
    private JPanel botPanel;
    private JTextField textField;
 
    Network(JPanel botPanel, JTextField textField){
        this.botPanel = botPanel;
        this.textField = textField;
    }
 
    static void closeNetwork(){
        try {
            Output.output.flush();
            Output.output.close();
            Network.input.close();
            Network.socket.close();
            Database.disconnectDatabase();
            System.exit(1);
        } catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
    @Override
    public void run() {
        try {
            socket = new Socket(InetAddress.getByName("127.0.0.1"), 1234);
            new Thread(new Output(botPanel, textField, socket)).start();
            input = new ObjectInputStream(socket.getInputStream());
            while (socket.getKeepAlive()){
                String msg = input.readObject().toString();
                if (msg.equals("Server closed!")){
                    closeNetwork();
                } else {
                    ChatFrame.addMsg(msg);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}

Клиент. Поток для отправки сообщений

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
import javax.swing.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
 
public class Output implements Runnable {
 
    Socket socket;
    static ObjectOutputStream output;
    JPanel botPanel;
    JTextField textField;
 
    Output(JPanel botPanel, JTextField textField, Socket socket){
        this.socket = socket;
        this.botPanel = botPanel;
        this.textField = textField;
    }
 
    @Override
    public void run() {
        try {
            output = new ObjectOutputStream(socket.getOutputStream());
            output.writeObject(LauncherFrame.getLogin());
            JButton button = new JButton("Send");
            button.setFocusable(false);
            botPanel.add(button);
            botPanel.repaint();
            botPanel.revalidate();
            button.addActionListener(new ActionListener() {
                @Override
                public void actionPerformed(ActionEvent e) {
                    if (textField.getText().equalsIgnoreCase("quit")){
                        try {
                            output.flush();
                            output.writeObject(textField.getText());
                            output.close();
                            Network.input.close();
                            Network.socket.close();
                            Database.disconnectDatabase();
                            System.exit(1);
                        } catch (IOException e1) {
                            e1.printStackTrace();
                        }
                    } else {
                        ChatFrame.addMsg("You: " + textField.getText());
                        try {
                            output.flush();
                            output.writeObject(textField.getText());
                            textField.setText("");
                        } catch (IOException e1) {
                            e1.printStackTrace();
                        }
                    }
                }
            });
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Я много чего пропустил, дальше сам.

@uLong · 20.10.2015, 18:40 **[ТС]**

Комментарий модератора

Избегайте черезмерного цитирования.

Спасибо, разберу код.

Добавлено через 5 минут

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

Я много чего пропустил, дальше сам

Это хорошо построенная архитектура чата ? Если нет, то в двух словах что бы было хорошо добавить. Мне вот интересно почему для вывода отдельный класс, а входные данные в этом же основном классе чата.

@asdzxc · 20.10.2015, 22:57

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

Это хорошо построенная архитектура чата

нет)

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

Если нет, то в двух словах что бы было хорошо добавить. Мне вот интересно почему для вывода отдельный класс, а входные данные в этом же основном классе чата.

Для входных тоже можно создать отдельный класс, просто руки не дошли.

А отдельный поток, чтобы не было системы "тик-так" как у вас.

Java
1
2
3
4
5
6
while (true) {
                connection = new Socket(InetAddress.getByName("10.132.121.47"), 4364);
                inputStream = new ObjectInputStream(connection.getInputStream());
                outputStream = new ObjectOutputStream(connection.getOutputStream());
                JOptionPane.showMessageDialog(null, (String)inputStream.readObject());
            }

Новые блоги и статьи Все статьи Все блоги /
http://iceja.net/ математические сервисы iceja 20.01.2026 Обновила свой сайт http:/ / iceja. net/ , приделала Fast Fourier Transform экстраполяцию сигналов. Однако предсказывает далеко не каждый сигнал (см ограничения http:/ / iceja. net/ fourier/ docs ). Также. . .	http://iceja.net/ сервер решения полиномов iceja 18.01.2026 Выкатила http:/ / iceja. net/ сервер решения полиномов (находит действительные корни полиномов методом Штурма). На сайте документация по API, но скажу прямо VPS слабенький и 200 000 полиномов. . .	Расчёт переходных процессов в цепи постоянного тока igorrr37 16.01.2026 / * Дана цепь постоянного тока с R, L, C, k(ключ), U, E, J. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа, решает её и находит переходные токи и напряжения на элементах схемы. . . .	Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .
Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .	Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .

Простой клиент-сервер с многопоточностью

Решение