Question

关于JAVA 聊天 多对多。

服务器端
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class SpeakServer {
private DataInputStream dis;
private DataOutputStream dos;
ServerSocket ss = null;
Socket sk = null;
ArrayList<Socket> list = new ArrayList<Socket>();

public static void main(String[] args) {
new SpeakServer().connect();

}

public void connect() {
boolean Start = false;
try {
ss = new ServerSocket(9999);
Start = true;
} catch (BindException e1) {
System.out.println("端口使用中");
System.exit(0);
}

catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {

while (Start) {

sk = ss.accept();
toClient c = new toClient(sk);
Thread t = new Thread(c);
t.start();
list.add(sk);

}
} catch (EOFException e) {
// TODO Auto-generated catch block
System.out.println("the Client closed");
}

catch (IOException e) {
// TODO Auto-generated catch block

} finally {
try {
if (dis != null) {
dis.close();
}
if (sk != null) {
sk.close();
}
}

catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
}
public class toClient implements Runnable {
DataInputStream dis;
Socket se = null;
boolean bConected = false;
String s1;

public toClient(Socket se) {
this.se = se;
try {
bConected = true;
dis = new DataInputStream(se.getInputStream());
System.out.println("a client Connected");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

public void run() {
while (bConected) {
try {
s1 = dis.readUTF();
System.out.println(s1);
send(s1);
}

catch (EOFException e) {
// TODO Auto-generated catch block
System.out.println("the Client closed");
}

catch (IOException e) {
// TODO Auto-generated catch block

} finally {
try {
if (dis != null) {
dis.close();
}
if (sk != null) {
sk.close();
}
}

catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
public void send(String s) {
try {

for (int i = 0; i < list.size(); i++) {
dos = new DataOutputStream(list.get(i).getOutputStream());

System.out.println("DOS = " + dos);
dos.writeUTF(s);
dos.flush();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public String getS1() {
return s1;
}
}

public ArrayList<Socket> getList() {
return list;
}
}
错在哪里；
客户端写不了，超过数字大小，加QQ328314674给你们。谢谢希望碰到好心人，我快疯了，救救我吧。我写的代码很乱吗？

Answer 1

ArrayList<Socket> list = new ArrayList<Socket>();
怎么放Socket ，应该放客户端吧 然后把说话内容发到每个客户端

Answer 2

是有点乱，

Answer 3

问题不明确哦。。还有我只看到send（）函数，没有看到receive（）的。。
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
服务器多对多应该是先收到内容然后send（）给客户端的吧。。

我觉得你应该再加一个connectmanager的类 管理客户端这里面放 receive和send 这样比较简单