问题描述
在一台电脑上实现，客户端的端口不一样，至少要两个客户端才能实现？异常在Client50中由衷感谢服务器importjava.io.*;importjava.net.*;importjava.util.ArrayList;importjava.util.Collection;importjava.util.Scanner;classUserimplementsSerializable{privateStringname;privateInetAddressid;privateintport;publicUser(Stringname,InetAddressid,intport){setName(name);setId(id);setPort(port);}publicStringgetName(){returnname;}publicvoidsetName(Stringname){this.name=name;}publicInetAddressgetId(){returnid;}publicvoidsetId(InetAddressid){this.id=id;}publicintgetPort(){returnport;}publicvoidsetPort(intport){this.port=port;}}//输出线程classWriterextendsThread{privateObjectOutputStreamoos=null;privatePipedInputStreampis=null;publicWriter(ObjectOutputStreamoos){this.oos=oos;}publicvoidrun(){try{while(true){pis=newPipedInputStream();inti=0;byteb[]=newbyte[1024];intn=0;for(;(i=pis.read())!=-1;n++){b[n]=(byte)i;}oos.write(b,0,n);oos.flush();}}catch(Exceptione){e.printStackTrace();}}publicPipedInputStreamgetPis(){returnpis;}publicvoidsetPis(PipedInputStreampis){this.pis=pis;}}//输入线程classSendsextendsThread{privateObjectInputStreamois=null;privatePipedOutputStreampos=null;publicSends(ObjectInputStreamois){this.ois=ois;}publicvoidrun(){try{while(true){byteb[]=(byte[])ois.readObject();pos=newPipedOutputStream();setPos(pos);pos.write(b);}}catch(Exceptione){e.printStackTrace();}}publicPipedOutputStreamgetPos(){returnpos;}publicvoidsetPos(PipedOutputStreampos){this.pos=pos;}}classReaderextendsThread{privateintport=1;privatestaticintn=0;publicReader(){}publicvoidrun(){try{while(true){//但n等于一的是后开始执行for(inti=0;i<=n;i++){Objecto=ChatRoomCase5.ois.get(i).readObject();if(o!=null){for(intj=0;j<=n;j++){intp=(ChatRoomCase5.user.get(j)).getPort();if(o==(Object)p){//记录客户输入的内容判断是谁的端口号setOis(ChatRoomCase5.ois.get(i));//这是自己的输入流setPort(p);//这是别人的端口号yield();}}}}}}catch(Exceptione){e.printStackTrace();}}ObjectInputStreamo=null;publicObjectInputStreamgetOis(){returno;}publicvoidsetOis(ObjectInputStreamois){this.o=ois;}publicintgetPort(){returnthis.port;}publicvoidsetPort(intport){this.port=port;}}classChatRoomCase5{privateServerSocketserver=null;privateSocketsocket[]=null;staticArrayList<ObjectInputStream>ois=newArrayList();staticArrayList<ObjectOutputStream>oos=newArrayList();staticArrayList<User>user=newArrayList();privatestaticinti=0;publicChatRoomCase5(){try{server=newServerSocket(5000,45);socket=newSocket[45];while(true){if(i<45){socket[i]=server.accept();//连接服务器System.out.println("-------1-------");ois.add(newObjectInputStream(newBufferedInputStream(socket[i].getInputStream())));oos.add(newObjectOutputStream(socket[i].getOutputStream()));System.out.println("-------2-------");user.add((User)ois.get(i).readObject());//服务器获取用户的信息反序列化System.out.println("-------3-------");System.out.println("-------4-------");System.out.println(user.get(i).getName()+"已经登录；");Strings=""+user.get(i).getName()+"上线了";if((i>=1)&&(i<45)){anline(s,socket[i]);//通知各个用户有人已经上线了sendM();}i++;}}}catch(Exceptione){e.printStackTrace();}}publicvoidsendM(){try{Readerr=newReader();r.start();//等待每个用户输入的第一条信息if(r.isInterrupted()){inti=r.getPort();Objecto="你已经和端口号为"+i+"连接上了,可以聊天了";System.out.println("-----6----"+i);oos.get(i-5001).writeObject(o);sender(r.getOis(),i);sendM();}}catch(Exceptione){e.printStackTrace();}}//接受每个人发过来的信息publicvoidsender(ObjectInputStreamo,intp){try{Writerw=newWriter(oos.get(p-5001));Sendss=newSends(o);s.getPos().connect(w.getPis());w.start();s.start();}catch(Exceptione){e.printStackTrace();}}publicvoidanline(Objecto,Socketsoc){//向每个人通知自己上线了try{for(inti=0;i<45;i++){if((socket[i]!=null)&&(socket[i]!=soc)){ObjectOutputStreamoos=newObjectOutputStream(socket[i].getOutputStream());oos.writeObject(o);System.out.println("-------5-------");}else{continue;}}}catch(Exceptione){e.printStackTrace();}}}publicclassChatRoom5{publicstaticvoidmain(Stringagrs[]){newChatRoomCase5();}}客户端importjava.io.BufferedInputStream;importjava.io.ObjectInputStream;importjava.io.ObjectOutputStream;importjava.net.InetAddress;importjava.net.Socket;importjava.util.Scanner;classSend5extendsThread{privateObjectOutputStreamoos=null;publicSend5(ObjectOutputStreamoos){this.oos=oos;}publicsynchronizedvoidrun(){try{while(true){Objecto=newScanner(System.in).next();oos.writeObject(o);oos.flush();}}catch(Exceptione){e.printStackTrace();}}}classRead5extendsThread{ObjectInputStreamois=null;publicRead5(ObjectInputStreamois){this.ois=ois;}publicsynchronizedvoidrun(){try{while(true){if(ois!=null)System.out.println(ois.readObject());}}catch(Exceptione){e.printStackTrace();}}}classClientCase5{privateSocketsocket=null;privateObjectOutputStreamoos=null;privateObjectInputStreamois=null;Useru=null;publicClientCase5(){try{this.socket=newSocket(InetAddress.getLocalHost(),5000,InetAddress.getLocalHost(),5001);System.out.println("-------1-------");oos=newObjectOutputStream(socket.getOutputStream());ois=newObjectInputStream(newBufferedInputStream(socket.getInputStream()));System.out.println("-------2-------");u=newUser("菜鸟莱特",InetAddress.getLocalHost(),5001);Objecto=u;oos.writeObject(o);System.out.println("-------3-------");newSend5(oos).start();newRead5(ois).start();}catch(Exceptione){e.printStackTrace();}}}publicclassClient50{publicstaticvoidmain(Stringagrs[]){newClientCase5();}}
解决方案
解决方案二：
太长了帮顶了
解决方案三：
谢谢，不长就是，有一个异常java.io.StreamCorruptedException:invalidtypecode:AC解决不了
解决方案四：
出错原因是在online方法取oos的地方，因为你对同一个socket.getOutputStream()做了两次封装，所以出错。修改方法是从ArrayList<ObjectOutputStream>里取出oospublicvoidonline(Objecto,Socketsoc){try{for(inti=0;i<45;i++){if((socket[i]!=null)&&(socket[i]!=soc)){ObjectOutputStreamoos=outputList.get(i);//这边直接取已经封装好的oosoos.writeObject(o);logger.info("---------5-------");}}}catch(Exceptione){e.printStackTrace();}}