首先我的想法是写一个聊天室的程序，一个服务器可以连接多个客户端，不同客户端可以自由聊天，并且在客户端有的信息显示框中可以显示每个客户所发的信息（通过服务器发到每个客户端上）！
我现在的问题是：服务器可以连接多个客户端，但是每个客户端的信息显示框中只能显示自己所发的信息，不能显示别人发的信息！下面是我写的代码，请问大虾们错在哪里！给与指正，不胜感激！
package com.chat;
import java.net.*;
import java.io.*;
/**
@author 章黎
*@see 创建一个服务器端的端口，并接受客户端得端口，用一个线程来监听各个客户端
*/
public class Server {
private static int port=6788;
private static ServerSocket server;
private static Socket socket;
public Server()
{
try {
System.out.println("服务器已启动");
server=new ServerSocket(port);
while(true)
{
socket= server.accept();
System.out.println("连接上一个服务器");
MyThread myThread=new MyThread(socket);
myThread.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
class MyThread extends Thread
{
Socket socket;
BufferedReader reader;
PrintStream ps;
String msg;
public MyThread(Socket s)
{
this.socket=s;
}
public void run()
{
try {
reader=new BufferedReader(new InputStreamReader(socket.getInputStream()) );
PrintStream out=new PrintStream(socket.getOutputStream(),true);
while(true)
{
msg=reader.readLine();
if(msg==null)
{
return;
}
else
if(msg.equals("exit"))
break;
else
out.println(msg);
out.flush();
System.out.println(msg);
}
server.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String []args)
{
new Server();
}
}
package com.chat;
import javax.swing.*;
//import com.chat.Server.MyThread;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.awt.BorderLayout;
import java.awt.GridLayout;
import java.awt.event.*;
/**
@author 章黎
*@see客户端要创建一个套接字与服务器连上，不过在这之前得做好用户界面，
*客户端要做的事就是将信息发给服务器、同时接受服务器端传过来的信息
*/
public class Client extends JFrame implements ActionListener{
PrintStream ps;
InputStream in;
private int port=6788;
Socket socket;
JLabel label1,label2;
JTextField nameField;
JTextArea msgArea;
JTextArea showmsgArea;
JButton sendButton;
JPanel panel,panel1,panel2;
StringBuffer msg;
String s1;
Date datetime;
public Client()
{
super("Chating room");
panel=new JPanel();
panel1=new JPanel();
panel2=new JPanel();
showmsgArea=new JTextArea();
showmsgArea.setEditable(false);
sendButton=new JButton("发送");
sendButton.addActionListener(this);
label1=new JLabel("用户名：");
nameField=new JTextField(10);
label2=new JLabel("聊天信息：");
msgArea=new JTextArea(3,20);
JScrollPane p=new JScrollPane(msgArea);
panel1.setLayout(new GridLayout(2,1,3,3));
panel1.add(label1);
panel1.add(nameField);
panel2.add(label2);
panel2.add(p);
panel2.add(sendButton);
panel.add(panel1);
panel.add(panel2);
this.setLayout(new BorderLayout());
this.add(panel,BorderLayout.NORTH);
this.add(showmsgArea,BorderLayout.CENTER);
this.setSize(500,300);
this.setLocation(300, 280);
this.setVisible(true);
}
public void actionPerformed(ActionEvent e) {
try
{
if(e.getSource()==sendButton)
{
if(socket!=null)
{
datetime=new Date();
s1=nameField.getText();
msg=new StringBuffer(s1+":");
msg.append(msgArea.getText());
msgArea.setText("");
ps.println(datetime);
ps.println(msg);
ps.flush();
}
if(socket==null)
{
socket=new Socket("localhost",port);
ps=new PrintStream(socket.getOutputStream(),true);
s1=nameField.getText();
msg=new StringBuffer(s1+":");
msg.append(msgArea.getText());
ps.println(datetime);
ps.println(msg);
ps.flush();
}
MyThread myThread=new MyThread(this,socket);
myThread.start();
}
}catch(Exception e1)
{
e1.getMessage();
}
}
class MyThread extends Thread
{
BufferedReader reader;
Socket socket;
Client client;
public MyThread(Client c,Socket s)
{
this.client=c;
this.socket=s;
}
public void run()
{
try {
in = socket.getInputStream();
reader=new BufferedReader(new InputStreamReader(in));
} catch (IOException e) {
e.printStackTrace();
}
while (socket!=null)
{
try {
String msgin=reader.readLine();
if(msgin.equals(""))
return;
else
showmsgArea.append(msgin);
showmsgArea.append("\n");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
new Client();
}
}
你的服务器端，在从客户A接到一个消息后，只会发给A，而不会发给其它客户，所以结果当然是每个客户只收到自己的消息看不到别人的。
你需要把所有的MyThread对象都存在一起，然后某一个对象收到消息时，把所有的发消息。
帮你格式化一下：
[code="java"]
package com.chat;
import java.net.*;
import java.io.*;
/**
server.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String []args)
{
new Server();
}
}
package com.chat;
import javax.swing.*;
//import com.chat.Server.MyThread;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.awt.BorderLayout;
import java.awt.GridLayout;
import java.awt.event.*;
/**
}
public void actionPerformed(ActionEvent e) {
try
{
if(e.getSource()==sendButton)
{
if(socket!=null)
{
datetime=new Date();
s1=nameField.getText();
msg=new StringBuffer(s1+":");
msg.append(msgArea.getText());
msgArea.setText("");
ps.println(datetime);
ps.println(msg);
ps.flush();
}
if(socket==null)
{
socket=new Socket("localhost",port);
ps=new PrintStream(socket.getOutputStream(),true);
s1=nameField.getText();
msg=new StringBuffer(s1+":");
msg.append(msgArea.getText());
ps.println(datetime);
ps.println(msg);
ps.flush();
}
MyThread myThread=new MyThread(this,socket);
myThread.start();
}
}catch(Exception e1)
{
e1.getMessage();
}
}
class MyThread extends Thread
{
BufferedReader reader;
Socket socket;
Client client;
public MyThread(Client c,Socket s)
{
this.client=c;
this.socket=s;
}
public void run()
{
try {
in = socket.getInputStream();
reader=new BufferedReader(new InputStreamReader(in));
} catch (IOException e) {
e.printStackTrace();
}
while (socket!=null)
{
try {
String msgin=reader.readLine();
if(msgin.equals(""))
return;
else
showmsgArea.append(msgin);
showmsgArea.append("\n");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
new Client();
}
}
[/code]
Server 最好指定一个IP，否则默认为本机，这样的话，你能看见别人的聊天才怪 :lol: