Jul 27, 2017 01:07 AM
(This post was last modified: Jul 27, 2017 01:09 AM by +Ervinas.)
Hello, got a huge problem. Stuck here for a week now.. Need help with my code a bit.
I'm trying to send object from client to server.
Steps:
1. Run server
2. Run client
3. Connection - OK.
4. Server creates thread that waits for client input.
5. Client sends AUTH information to server , server RECEIVES and checks it.
6. Auth completed, client joined server.
7. Client sends String[] object to server
8. Server gets it and thows me error :
After all googling and reading, i know that 1 socket can have only 1 ObjectInputStream and 1 ObjectOutputStream on each sides (client/server).
I double checked my ServerComm.java and ServerThread.java if there are any more, but there arent!
Everything is fine. Don't know what to do.
ServerComm.java : It's class from Client side, to communicate with server.
ServerThread.java : it's a thread that accept client connections and check auths and waiting for new String[] object from client to accept.
P.S. This method gets me error.
I'm trying to send object from client to server.
Steps:
1. Run server
2. Run client
3. Connection - OK.
4. Server creates thread that waits for client input.
5. Client sends AUTH information to server , server RECEIVES and checks it.
6. Auth completed, client joined server.
7. Client sends String[] object to server
8. Server gets it and thows me error :
Code
java.io.StreamCorruptedException: invalid type code: ACAfter all googling and reading, i know that 1 socket can have only 1 ObjectInputStream and 1 ObjectOutputStream on each sides (client/server).
I double checked my ServerComm.java and ServerThread.java if there are any more, but there arent!
Everything is fine. Don't know what to do.
ServerComm.java : It's class from Client side, to communicate with server.
Code
package client;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class ServerComm{
private Socket socket;
private static ObjectOutputStream oos;
public ServerComm(Socket socket) throws UnknownHostException, IOException {
this.socket = socket;
oos = new ObjectOutputStream(socket.getOutputStream());
}
protected static void sendLine(String line, String type, Socket socket) throws IOException{
String[] a = {line,type};
sendToServerStringArray(a);
System.out.println("Sending line: " + line);
System.out.println("Sending type: " + type);
}
public Socket getSocket() {
return this.socket;
}
protected static boolean sendAuth(Socket socket) throws IOException {
String project_id = Config.getProject_id();
String user_id = Config.getUser_id();
String[] auths = {project_id, user_id};
sendToServerStringArray(auths);
System.out.println("Authentication process started");
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
if(ois.readBoolean() == true) {
System.out.println("Authentication successfull!");
return true;
}
System.out.println("Authentication failed, dropping connection.");
return false;
}
protected static void sendToServerStringArray(String[] array) throws IOException {
oos.reset();
oos.writeUnshared(array);
oos.flush();
}
}ServerThread.java : it's a thread that accept client connections and check auths and waiting for new String[] object from client to accept.
Code
package server;
import java.io.BufferedReader;
import java.io.EOFException;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
class ServerThread extends Thread {
public static String name;
String line = null;
BufferedReader is = null;
PrintWriter os = null;
public static Socket socket = null;
static ObjectInputStream ois;
@SuppressWarnings("static-access")
public ServerThread(Socket socket) throws ClassNotFoundException, IOException{
this.setName("Client");
name = this.getName();
this.socket = socket;
ois = new ObjectInputStream(socket.getInputStream());
}
public void run() {
try {
while(true) {
String[] variables = getInputFromClient();
for(String variable : variables) {
System.out.println(variable);
}
}
}
catch(NullPointerException e)
{
line = this.getName();
System.out.println("Client "+line+" Closed");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
finally
{
try{
System.out.println("Connection Closing..");
if (is != null){
is.close();
System.out.println("Socket Input Stream Closed");
}
if(os!=null){
os.close();
System.out.println("Socket Out Closed");
}
if (socket!=null){
socket.close();
System.out.println("Socket with :" + this.getName() + " were closed");
}
}
catch(IOException ie){
System.out.println("Socket Close Error");
}
}
}
protected static boolean checkAuth() throws IOException, ClassNotFoundException {
ArrayList<String> auths = new ArrayList<String>();
// read ois truksta
String[] authsFromClient = getInputFromClient();
for(String auth : authsFromClient) {
auths.add(auth);
}
int temp = 0;
for(int i = 0 ; i < auths.size() ; i++) {
if(Config.getProjectId().equals(auths.get(i)) || Config.getUserId().equals(auths.get(i)) ){
temp += 1;
}
else {
temp -= 1;
}
}
if(temp == auths.size()) {
temp = 0;
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeBoolean(true);
oos.flush();
return true;
}
else {
temp = 0;
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeBoolean(false);
oos.flush();
return false;
}
}
private static String[] getInputFromClient() throws ClassNotFoundException, IOException {
String[] temp = (String[]) ois.readObject();
return temp;
}
}P.S. This method gets me error.
Code
private static String[] getInputFromClient() throws ClassNotFoundException, IOException {
String[] temp = (String[]) ois.readObject();
return temp;
}Code
String[] temp = (String[]) ois.readObject();GET RICH OR DIE TRYING
