Форум программистов [Powered by Invision Power Board]

Система строится по концепции тонкого клиента, где многие действия пользователя формирует обращение к серверу. Требовалось оценить скорость отклика, чтобы у пользователя не возникало дискомфорта.

Не очень понимаю, чем может помочь здесь много поточность? Меня же интересует именно отклик, а не пропускная способность.

В играх сигнал идет от клиента, обрабатывается на сервере и возвращается (для визуализации). Пусть реально это 20 fps, т.е. отклик всего 50 мс. И меня бы это устроило, но треть секунды - это очень много, и визуально очень заметно, это ещё без времени для отработки на самом сервере (кто знает какие там запросы).

Меня интересует "кто виноват?"

Если причина тому сама Java - это одно, значит придется менять концепцию. Если виновата ОС или сетевые настройки, то это совсем другое дело.

На всякий случай выкладываю код теста.

Код


import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;

public class ClientFrame extends JFrame{
    public JButton buttonStart = new JButton("Тест");
    public JLabel label = new JLabel("          ");
    public Socket socket = null;
    
    public void configurateGUI(){   
        setBounds(100, 100, 300, 200);
        setTitle("Клиентская сторона");
        JPanel mainPanel = new JPanel();
        mainPanel.add(buttonStart);
        mainPanel.add(label);
        getContentPane().add(mainPanel);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    
        buttonStart.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent ae) {
                buttonStart.setEnabled(false);
                try {
                    socket = new Socket(ServerFrame.HOST_NAME, ServerFrame.HOST_PORT);
                    DataInputStream inputStream = new DataInputStream(socket.getInputStream());
                    DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
                    long timeStart = System.currentTimeMillis();
                    outputStream.writeUTF("Packet ");
                    outputStream.writeInt(0);
                    outputStream.flush();
                    while(true){
                        String s = inputStream.readUTF();
                        int value = inputStream.readInt();
                        if(value<1000){
                            outputStream.writeUTF(s);
                            outputStream.writeInt(value);
                            outputStream.flush();
                        }else{
                            break;
                        }
                    }
                    socket.close();
                    long timeFinish = System.currentTimeMillis();
                    label.setText("Ушло "+(timeFinish-timeStart));
                    buttonStart.setEnabled(true);
                } catch (IOException ex) {
                }
            }
        });
    }
    
    public static void main(String _a[]){
        ClientFrame frame = new ClientFrame();
        frame.configurateGUI();
        frame.setVisible(true);
    }
}

Код


import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;

public class ServerFrame extends JFrame{
    
    public static final String HOST_NAME="127.0.0.1";
    //public static final String HOST_NAME="192.168.0.17";
    public static final int HOST_PORT = 1049;
    
    public ServerSocket server = null;
    public boolean isRun = true;
    
    JButton buttonStart = new JButton("Старт");
    JButton buttonFinish = new JButton("Окончание");
    
    public void configurateGUI(){
        
        setBounds(100, 100, 300, 200);
        setTitle("Серверная сторона");
        buttonFinish.setEnabled(false);
        JPanel mainPanel = new JPanel();
        mainPanel.add(buttonStart);
        mainPanel.add(buttonFinish);
        getContentPane().add(mainPanel);
        setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
        
        buttonStart.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent ae) {
                buttonFinish.setEnabled(true);
                try {
                    server = new ServerSocket(HOST_PORT);
                    Thread serverThread = new Thread(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                while(isRun){
                                    Socket s = server.accept();
                                    SocketRunner runner = new SocketRunner(s, ServerFrame.this);
                                    Thread thread = new Thread(runner);
                                    thread.start();  
                                }
                            } catch (IOException ex) {
                            }
                        }
                    });
                    serverThread.start();
                } catch (IOException ex) {
                    System.out.println("Не удалось создать сервер");
                    System.exit(0);
                }
                buttonStart.setEnabled(false);
            }
        });
        buttonFinish.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent ae) {
                isRun = false;
                try {
                    server.close();
                } catch (IOException ex) {
                }
                System.exit(0);
            }
        });
    }
    
    public static void main(String _a[]){
        ServerFrame frame = new ServerFrame();
        frame.configurateGUI();
        frame.setVisible(true);
    }
}

Код



import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class SocketRunner implements Runnable{
    public Socket socket = null;
    public DataInputStream inputStream = null;
    public DataOutputStream outputStream = null;
    public ServerFrame frame = null;
            
    
    public SocketRunner(Socket _socket, ServerFrame _frame){
        frame = _frame;
        socket = _socket;
    }

    @Override
    public void run() {
        try {
            inputStream = new DataInputStream(socket.getInputStream());
            outputStream = new DataOutputStream(socket.getOutputStream());
            while(frame.isRun){
                String s = inputStream.readUTF();
                int value = inputStream.readInt();
                
                outputStream.writeUTF(s);
                outputStream.writeInt(value+10);
                outputStream.flush();
            }
        } catch (IOException ex) {
            try {
                socket.close();
            } catch (IOException ex1) {
            }
        }
    }
    
}