sockets - Java: Reading from ObjectInputStream -



sockets - Java: Reading from ObjectInputStream -

i have started learning java. task create file server accepts commands file get, file set , file delete multiple clients using threading. using custom class dataobject serialize , send commands , info may accompany it. client made interactive in sense involves manual user input of various commands. means objectinputstream readobject() function not work in while(true) loop because of eofexception. can server thread pauses @ readobject() until sees next object , resumes while(true) loop?

code @ server (runs each thread separately):

public void run() { objectinputstream = null; objectoutputstream os = null; try{ = new objectinputstream(clientsocket.getinputstream()); os = new objectoutputstream(clientsocket.getoutputstream()); while (true) { input = (dataobject) is.readobject(); //system.out.println("input has been read"); output = commandprocessor.process(input); if(output.data == null) { os.writeobject(output); if(output.message.comparetoignorecase("rsp bye")==0){ clientsocket.close(); } } } }

code @ client:

public talker() { dataobject input = new dataobject(0), output = new dataobject(0); seek { log = new printstream("/home/meher/log.txt"); inetaddress serveraddress = inetaddress.getbyname("127.0.0.1"); socket serversocket = new socket(serveraddress, port); os = new objectoutputstream(serversocket.getoutputstream()); = new objectinputstream(serversocket.getinputstream()); commandexecuter.hello(output); write(output); read(input); while(not-end-of-user-input){ //yet code part //execute commands } }

eofexception thrown readobject when stream ends. in case, when client closes connection. if client sends object server , quits, server read 1 object , eofexcpetion next time tries read object, on closed connection.

perhaps add together quit-command, in both agree terminate connection?

java sockets objectinputstream

Comments

Popular posts from this blog

java - How to set log4j.defaultInitOverride property to false in jboss server 6 -

c - GStreamer 1.0 1.4.5 RTSP Example Server sends 503 Service unavailable -

Using ajax with sonata admin list view pagination -