Пишу программу с использованием 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();
}
}
}
socket
не глобальным. И каждыйsocket
отправляйте в отделныйобработчик/поток
. Так же создайте прослушивателserver.bind(address);
послеserver.isBound()
можете получитьaccept