1

Пишу программу с использованием socket. Пользовался поисковой системой Google, не нашел нормального примера для использования. С socket работаю впервые и поэтому не настолько сильно в них разбираюсь. Логика следующая, есть некий клиент, который постоянно будет отправлять данные в виде string. Я должен создать серверную часть, которая будет постоянно прослушивать, и считывать данные. Делать некие манипуляции и сохранять в базу. Если в течении 30 сек не будет никаких данных, то закрыть связь с этим клиентом, но другие клиенты могут подключаться. Socket должен постоянно работать. Есть у кого-нибудь готовый кусок кода как это реализовать? Выручайте. Мой код

public class TRSServerInterface implements Runnable {

    private ServerSocket serverSocket = null;
    private Socket socket = null;
    ObjectInputStream objectIn = null;
    ObjectOutputStream objectOut = null;
    boolean runner = true;
    String message = "";

    public TRSServerInterface(int port) {
        try {
            //init server socket with port
            serverSocket = new ServerSocket(port, 3);
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    @Override
    public void run() { // default run method of Thread class and Runnable interface

        try {
            while(true) {
                System.out.println("Waiting for connection...");
                socket = serverSocket.accept();
                System.out.println("Connected to " + socket.getInetAddress().getHostName());
                //get the input and output streams
                objectOut = new ObjectOutputStream(socket.getOutputStream());
                objectOut.flush();
                objectIn = new ObjectInputStream(socket.getInputStream());
                sendResponse("Connection successful!");
                do {

                    try {
                        message = (String)objectIn.readObject();
                        System.out.println("client>" + message);
                    } catch (ClassNotFoundException ex) {
                        System.err.println("Data received in unknown format");
                    }

                } while (!message.equals(""));
            }

        } catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            try {
                //we must close all open connections 
                objectOut.close();
                objectIn.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }

    private void sendResponse(String response) {
        try{
            objectOut.writeObject(response);
            objectOut.flush();
            System.out.println("server>" + response);
        }
        catch(IOException ioException){
            ioException.printStackTrace();
        }
    }
}
2
  • @Regent просмотрите изменения пжл. 29 июн 2015 в 5:17
  • сделайте socket не глобальным. И каждый socket отправляйте в отделный обработчик/поток. Так же создайте прослушивател server.bind(address); после server.isBound() можете получить accept
    – Saidolim
    29 июн 2015 в 5:21

2 ответа 2

4

вот часть кода который вам может помочь

@Override
public void run() {
    try {
        // Starting the listener
        log.info("starting TCP Server, port: " + this.port);

        int index = 0;

        ServerSocket server = new ServerSocket();
        InetSocketAddress address = new InetSocketAddress(this.host, this.port);
        server.bind(address);

        if (server.isBound()) {
            if (log.isDebugEnabled()) {
                log.debug("Waitting Client Connection.......");
            }

            /* Continue receiving clients while canWork stays TRUE */
            while (this.canWork) {
                if (log.isDebugEnabled()) {
                    log.debug("tcp client: " + index);
                }
                Socket socket = server.accept();
                TCPSession tcpSessionLocal = new TCPSession(socket);
                index++;
                tcpSessionLocal.setTcpConnectionTimeout(tcpConnectionTimeout);
                tcpSessionLocal.start();
            }
        }
    } catch (IOException ex) {
        if (log.isDebugEnabled()) {
            log.debug("tcp receiver main try-catch error " + ex.getMessage());

        }
    }
}

тут tcpConnectionTimeout поможет закрыть не нужный сокет. А так принимает клиентов без остановки. Можете завершить, задав значение this.canWork=false

UPD

Добавляю часть кода класса TCPSession

public class TCPSession extends Thread {


    // Local variables
    private Socket socket = null;
    private int error_num = Constants.ERR_SUCCESS;
    private int tcpConnectionTimeout = 300000;

    /**
     * A session to read from input stream and pars binary data.
     *
     * @param socket the socket Handle of incoming connection
     */
    public TCPSession(Socket socket) {
        this.socket = socket;
        try {
            this.socket.setSoTimeout(tcpConnectionTimeout);
        } catch (SocketException e) {
            log.warn("TimeOut not set");
        }
    }

    public void run() {

        try {
            if (socket != null) {
                if (!socket.isClosed()) {

                    // Read data from stream
                    InputStream inputStream = socket.getInputStream();
                    OutputStream outputStream = socket.getOutputStream();

                    int firstByte = inputStream.read();

                    int read = 0;
                    while (read != -1) {
                    read = inputStream.read();
                        log.debug("Thread " + Thread.currentThread().getId() + String.format(" %02X", read));

                    // Если что то не так, делаете выход из цикла
                    // если read = -1 значит нет больше данных в InputStream

                    }

                }
            }
        } catch (IOException ioe) {
            log.error("Session exception in ERR:" + error_num);
            log.error(Trace.getStackTrace(ioe));
        }

        // Close socket
        if (this.socket != null && !this.socket.isClosed()) {
            try {
                this.socket.close();
            } catch (IOException ex) {
                log.error("Socket close in ERR:" + error_num);
            }
        }

    }

}
9
  • TCPSession это стандартный класс джава или мне его самому надо написать? среди стандартных я его не нашел. и да, считываение и отправку ответа мне надо производить внутри while(this.canWork) {}. я прав? 29 июн 2015 в 5:27
  • Это не стандартный класс. Это я сам сделал. а тут как пример дал.
    – Saidolim
    29 июн 2015 в 5:35
  • ну мне это и было интересно как реализовать то, чтобы закрыть свзять с клиентом. в данном случае просто название класса и вызов метода никак не описывают логику этого метода. 29 июн 2015 в 5:40
  • а поток вы закрываете внутри класса TCPSession там можете и задержку проверять и что угодно. на ваше расмотрение. Я тут пример дал для того что бы у вас которая будет постоянно прослушивать и считывать данные работало. Тут у вас 2 вопроса из этого такая путеница.
    – Saidolim
    29 июн 2015 в 5:43
  • 1
    ааа да, ошибся) тот старт просто поток запускает. все, понял теперь. спасибо большое 29 июн 2015 в 7:16
1

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

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

Метод серверного сокета accept() будет постоянно ждать клиента и код далее не выполнится, пока клиент не будет найден, а клиент не сможет отправить String строки, пока не подключится к серверу, т.е. в никуда на удачу, что сервер что-то получит, кидать не получится.

9
  • в принципе я разобрался. но у меня появился другой вопрос. всегда ли сервер-клиент работают в режиме запрос-ответ? т.е. нельзя чтобы клиент непереставая отправлял сообщения, а получил бы ответ только в случае ошибки в сообщении, который отправляет клиент? а так получая сообщение от клиента, я должен сразу отправлять ответ. как сделать так, чтобы сервер мог отправить ответ при особых услових. 29 июн 2015 в 9:17
  • Простите, но я не совсем понял, что вы написали. Когда клиент подключился к серверу, то можно делать обмен сообщениями. При использовании метода send, насколько я помню, он должен вернуть количество переданных байт, по этому количеству и можно будет судить о том, передалась ли инфа или нет. А дальше уже можете отправлять ответ об удачной посылке или не отправлять, но учтите, что при большом количестве обмена данными это затормозит работу и без того не быстрой ява-машины. Что вы имели ввиду под особыми условиями?
    – BORSHEVIK
    29 июн 2015 в 9:44
  • вот есть сервер и клиент, так? клиент подключается к серверу через accept. после этого сервер ждет команды от клиента. как только клиент пошлет данные, сервер обрабатывает их и отсылает результаты или ответ о проделанной работе клиенту. но можно ли сделать так, что бы сервер отправлял ответ клиенту только в случае ошибки например, а не каждый раз как проделал работу 29 июн 2015 в 9:49
  • 1
    Сервер не обязан ничего отправлять, если вы этого сами не захотите. По ссылке, которую я вам дал, там описано про созданные потоки получения и отправки, через них вы обмениваетесь инфой. Сервер ждёт клиента в методе accept, как клиент подключится, сервер получит сокет для конкретного клиента, но это не значит, что сервер сам магическим образом что-то будет делать, далее всё зависит от вас и вашей реализации сервера. Если вы хотите, то можете сделать так, что сервер будет давать ответ только после возникновения ошибки, но это немного неправильно.
    – BORSHEVIK
    29 июн 2015 в 9:56
  • В C++ есть более конкретные методы send для передачи и recv для чтения, можете реализовать их подобие для java, просто передавать только ошибку, это не есть хорошо, как минимум вы должны сразу после пересылки ответить клиенту о том сколько байт он получил, чтобы сравнить их и быть уверенным в том, что все ваши байты были переданы, но если у вас не будет слишком большого обена данными между сервером и клиентом, то можете реализовать не просто ответ клиенту в виде количества переданных байт, а передать ту же строку обратно, чтобы клиент точно знал, что пересылка была именно той, как вам надо.
    – BORSHEVIK
    29 июн 2015 в 10:00

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.