Я занимаюсь разработкой приложения для чата в Java, и у меня возникла проблема с развертыванием.Несмотря на то, что мое приложение работает гладко, когда выполняется через IDE (сервер в IntelliJ и клиент в Netbeans), когда я пытаюсь запустить сервер через терминал, сервер не работает должным образом.Под неправильным пониманием я подразумеваю, что сервер получает сообщения от пользователя, но не отвечает.
Например, первые три шага, которые выполняет клиент:
- Войти
- Получить список пользователей
- Получить список групп
Даже если сервер получает эти сообщения / запросы, он не отвечает обратно.
Я назначаюкаждое соединение с сервером в новом потоке, потому что это многоклиентное приложение.
Есть идеи, что происходит?
Вот примерная картинка того, что выводится в терминале:
, а затем сервер висит там.
Реализация сервера
Вот код для запуска сервера.
public class ThreadedServer {
ServerSocket serverSocket;
private static Socket welcomeSocket = null;
public ThreadedServer() {
try {
serverSocket = new ServerSocket(ServerConfiguration.SERVER_PORT);
System.out.println("Server started");
} catch (Exception e) {
e.printStackTrace();
}
while (true) {
try {
welcomeSocket = serverSocket.accept();
System.out.println("Connection accepted: " + welcomeSocket.getInetAddress() + ":" + welcomeSocket.getLocalPort());
Thread t = new Thread(new ClientConnection(welcomeSocket));
t.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
Это класс клиентского соединения, где я обрабатываю сообщения, которые я получаю, и отправляю сообщения, которые я хочу.
открытый класс ClientConnection реализует Runnable {
private final Socket clientSocket;
private DataInputStream dis;
private DataOutputStream dos;
private int sessionId;
private int userId;
private String username;
private ClientConnection self;
public ClientConnection(Socket client) {
this.clientSocket = client;
this.self = this;
}
public DataOutputStream getOutputStream() {
return dos;
}
@Override
public void run() {
System.out.println("Client Thread started!");
initializeDataStreams();
startListeningForMessages();
}
private void initializeDataStreams() {
try {
dis = new DataInputStream(clientSocket.getInputStream());
dos = new DataOutputStream(clientSocket.getOutputStream());
System.out.println("Server: Initialized Streams");
} catch (IOException ex) {
Logger.getLogger(ClientConnection.class.getName()).log(Level.SEVERE, null, ex);
}
}
private void startListeningForMessages() {
new Thread(new Runnable() {
@Override
public void run() {
try {
String message;
while ((message = dis.readUTF()) != null) {
System.err.println("Recieved from client: " + message);
if (ServerConfiguration.LOG_COMMUNICATION_MESSAGES) {
System.out.println("client message string recieved \" "
+ message + " \"");
}
processMessage(message);
}
} catch (IOException ex) {
// 1) Remove the connection from the list of connections.
ConnectionManager.getInstance().removeConnection(self);
// 2) Inform database for logout time AND Error Messege!
DatabaseAction.logout(sessionId, "Unknown Error occurred");
}
}
}).start();
}
private void processMessage(String messege) {
Messege inbound = new Gson().fromJson(messege, Messege.class);
if (inbound.getType() == MessegeType.login) {
performLogin(inbound);
} else if (inbound.getType() == MessegeType.logout) {
performLogout(inbound);
} else if (inbound.getType() == MessegeType.simple_messege) {
sendMessege(inbound);
} else if (inbound.getType() == MessegeType.group_messege) {
sendGroupMessege(inbound);
} else if (inbound.getType() == MessegeType.get_all_users) {
getAllUsers();
} else if (inbound.getType() == MessegeType.get_groups_im_involved_in) {
getGroupsImInvolvedIn();
} else if (inbound.getType() == MessegeType.get_messeges_from_user) {
getMessegesFromUser(inbound);
} else if (inbound.getType() == MessegeType.get_messeges_from_group) {
getMessegesFromGroup(inbound);
} else if (inbound.getType() == MessegeType.create_new_group) {
createNewGroup(inbound);
}
}
private void sendGroupMessege(Messege inbound) {
new SendGroupMessegeAction(this, inbound);
}
public void close() {
try {
dis.close();
dos.close();
clientSocket.close();
} catch (IOException ex) {
Logger.getLogger(ClientConnection.class.getName()).log(Level.SEVERE, null, ex);
}
}
private void performLogin(Messege messege) {
LoginAction la = new LoginAction(messege.getUser(), messege, this);
this.username = messege.getUser();
this.sessionId = la.getSessionId();
this.userId = la.getUserId();
}
private void performLogout(Messege messege) {
new LogoutAction(this, messege);
}
public void sendMessege(Messege messege) {
new SendSimpleMessegeAction(this, messege);
}
public int getSessionId() {
return sessionId;
}
public int getUserId() {
return userId;
}
public String getUsername() {
return username;
}
private void getAllUsers() {
try {
System.out.println("Sending all users to client " + username);
UsersObject uo = DatabaseAction.getAllUsers(userId);
GetAllUsersMessege gaum = new GetAllUsersMessege(uo.getUsernames(), uo.areOnline(), uo.getHasSentMessegesThatAreUnread());
Messege m = new Messege("", MessegeType.get_all_users, new Gson().toJson(gaum));
System.out.println("Sent from server: " + new Gson().toJson(m));
dos.writeUTF(new Gson().toJson(m));
dos.flush();
} catch (IOException ex) {
Logger.getLogger(ClientConnection.class.getName()).log(Level.SEVERE, null, ex);
}
}
HЭто соединение с сервером со стороны клиента
public class ServerConnection {
DataInputStream dis;
static DataOutputStream dos;
Socket socket;
public static ServerConnection instance;
public static ServerConnection getInstance() {
if (instance == null) {
instance = new ServerConnection();
}
return instance;
}
private ServerConnection() {
initializeConnection();
startListeningThread();
}
private void initializeConnection() {
try {
socket = new Socket(MyStatics.server_address, 3333);
dis = new DataInputStream(socket.getInputStream());
dos = new DataOutputStream(socket.getOutputStream());
System.out.println("Client: Connection Initialized");
} catch (IOException ex) {
Logger.getLogger(ServerConnection.class
.getName()).log(Level.SEVERE, null, ex);
}
}
private void startListeningThread() {
new Thread(new Runnable() {
@Override
public void run() {
try {
String line = "";
while (!socket.isClosed() && (line = dis.readUTF()) != null) {
System.out.println("Recieved from Server: " + line);
Messege m = new Gson().fromJson(line, Messege.class);
processMessege(m);
}
} catch (IOException ex) {
// Logger.getLogger(ServerConnection.class.getName()).log(Level.SEVERE, null, ex);
if (!ex.getMessage().equals("Socket closed")) {
`enter code here`Logger.getLogger(ServerConnection.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}).start();
}
private void processMessege(Messege m) {
if (m.getType() == MessegeType.get_all_users) {
GetAllUsersMessege gaum = new Gson().fromJson(m.getEnv(), GetAllUsersMessege.class);
MainWindow.usersData = gaum.getUsers();
MainWindow.usersOnline = gaum.getOnline();
MainWindow.usersWhoSentSomething = gaum.getHasSentMessegesThatAreUnread();
MainWindow.changeData();
} else if (m.getType() == MessegeType.get_groups_im_involved_in) {
GetGroupsImInvolvedInMessege ggiiim = new Gson().fromJson(m.getEnv(), GetGroupsImInvolvedInMessege.class);
MainWindow.groupsData = ggiiim.getGroups();
MainWindow.changeData();
} else if (m.getType() == MessegeType.simple_messege) {
SimpleMessege sm = new Gson().fromJson(m.getEnv(), SimpleMessege.class);
MainWindow.informThatMessegeIsRecieved(m.getUser());
System.out.println("Recieved simple messege");
for (ChatBox chatBox : MyInstances.chatBoxes) {
if (chatBox.getTo().equals(m.getUser())) {
System.out.println("Chatbox was found");
chatBox.appendRecievedMessege(sm.getMessege());
}
}
...
...
}
}
РЕДАКТИРОВАТЬ: я добавил фрагменты кода.