socket 多人聊天 求高手看看 怎么解决

Question

运行后 client端输入后会自动将输入信息显示一遍client：import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;public class SocketTest {

public static void main(String[] args) throws Exception {


 new SocketTest().run();
} public void run() throws Exception, IOException{
Socket s = new Socket("localhost",8888);
System.out.println("Connect!");

GetMessage g = new GetMessage(s);
new Thread(g).start();
do{
OutputStream os = s.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String str = br.readLine();
dos.writeUTF(str);
dos.flush();
}while(true);

}
}import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;public class GetMessage implements Runnable {
private Socket s;
private DataInputStream dis = null;
 public GetMessage (Socket s){
this.s = s;
}
 
 
public void run() {
try {
InputStream str1 = s.getInputStream();
while(true){
dis = new DataInputStream(str1);
String str = dis.readUTF();
System.out.println(str);
}
} catch (IOException e) {
e.printStackTrace();

}
}

}
server：import java.net.*;
import java.io.*;
import java.util.*;
public class Server {
boolean started = false;
ServerSocket ss = null;

List<Client> clients = new ArrayList<Client>();

public static void main(String[] agrs){
new Server().start();
}
public void start(){
try {
 ss = new ServerSocket(8888);
 started = true;
} catch(BindException e){
System.out.println("端口使用中...");
System.out.println("请关掉相关程序重新启动！");
System.exit(0);
} catch(IOException e){
e.printStackTrace();
}

try {
while(started){
Socket s = ss.accept();
Client c = new Client(s);

System.out.println("a client is connected!");
new Thread(c).start();
          clients.add(c);
}

} catch (IOException e) {
e.printStackTrace();

} finally {
try {
ss.close();
} catch(IOException e){
e.printStackTrace();
}
}}


    class Client implements Runnable {
private Socket s ;
private DataInputStream dis = null;
private DataOutputStream dos = null;
private boolean bConnected = false;

public Client(Socket s){
this.s=s;
try {
dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());
bConnected = true;
} catch (IOException e) {
e.printStackTrace();
}
}

public void send(String str){
try {
dos.writeUTF(str);

} catch (IOException e) {
clients.remove(this);
System.out.println("对方退出了！");
//e.printStackTrace();
}
}

public void run() {
try {  
            while(bConnected){
             String str = dis.readUTF();
System.out.println(str);
for(int i=0; i<clients.size(); i++) {
Client c = clients.get(i);
c.send(str);
}
Thread.sleep(10); }
            } catch(EOFException e){
            System.out.println("Client disconnect!");
            } catch(IOException e){
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try{
if(dis != null) dis.close();
if(dos != null) dos.close();
if(s != null) s.close();
}catch(IOException e){
e.printStackTrace();
}
}

}
}

}

Answer 1

我在第一行就说了 看来是没说明白
譬如 跑起server 跑2个客户端 
一个客户端下输入一句话，譬如：hello 但是它马上会在此客户端下 显示一个hello
虽然另外一个客户端和服务器都接受到了这个字符串。 
我想了解下为什么会出现多余的这个显示字符串以及如何修改可以去除掉这个多余的回显！！

Answer 2

很简单，给每个客户端分配一个独有的ID，然后每一次发消息的时候，附带将自己的ID加上。然后客户端在接收消息包的时候，先判断这个ID和自己是不是一样，如果不是一样才显示，一样就丢弃这个包。