Question

求一个java聊天室的源代码，要求必须可以运行，如果运行成功会加分

如题

Answer 1

只能群聊。想要私聊和传文件的话，就叫我一声。因为代码太长，字数超出范围了。而且代码很长，没有注释，如果只是应付作业的话，还是可以的。但是如果是自己用来研究的话，那就算了。

服务器
----------------------------------

import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.LinkedList;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JTextArea;

class RecvMegSock extends Thread
{
LinkedList SocketList = null;
Socket ClientSock = null;
JTextArea jTextArea1;

RecvMegSock(LinkedList list,Socket s,JTextArea t)
{
SocketList = list;
jTextArea1 = t;
ClientSock = s;
start();
}
public void run()
{
while(true)
{
try
{
DataInputStream in = new DataInputStream(ClientSock.getInputStream());
String word = in.readUTF();
jTextArea1.setText(jTextArea1.getText() + word + "\n");

for(int i = 0;i < SocketList.size();i++)
{
Socket s = (Socket)SocketList.get(i);
DataOutputStream out = new DataOutputStream(s.getOutputStream());
out.writeUTF(word);
}
}
catch (IOException ex)
{
for(int i = 0;i < SocketList.size();i++)
{
Socket s = (Socket)SocketList.get(i);
if(s == ClientSock)
SocketList.remove(s);
}
for(int i = 0;i < SocketList.size();i++)
{
Socket s = (Socket)SocketList.get(i);
try
{
DataOutputStream out = new DataOutputStream(s.getOutputStream());
out.writeUTF(ClientSock.getInetAddress() + "已经退出!!\n");
}
catch (IOException ex1)
{
Logger.getLogger(RecvMegSock.class.getName()).log(Level.SEVERE, null, ex1);
}
}
jTextArea1.setText(jTextArea1.getText() + ClientSock.getInetAddress() + "已经退出!!" + "\n");
return;
}
}
}
}

class AcceptSockThread extends Thread
{
ServerSocket ServerSock = null;
LinkedList SocketList = null;
JTextArea TextArea;
AcceptSockThread(ServerSocket s,LinkedList list,JTextArea t)
{
ServerSock = s;
SocketList = list;
TextArea = t;
start();
}
public void run()
{
while(true)
{
Socket ClientSock = null;
try
{
boolean same = false;
ClientSock = ServerSock.accept(); /*
for(int i = 0;i < SocketList.size();i++)
{
Socket s = (Socket)SocketList.get(i);
if(s.getInetAddress().equals(ClientSock.getInetAddress()) && s.getPort() == ClientSock.getPort())
{
DataOutputStream out = new DataOutputStream(s.getOutputStream());
out.writeUTF(ClientSock.getInetAddress() + "你已经连接了服务器！！\n");
same = true;
}
}
if(same == true)
continue;
*/
new RecvMegSock(SocketList,ClientSock,TextArea);
SocketList.add(ClientSock);

for(int i = 0;i < SocketList.size();i++)
{
Socket s = (Socket)SocketList.get(i);
DataOutputStream out = new DataOutputStream(s.getOutputStream());
out.writeUTF(ClientSock.getInetAddress() + "成功连接服务器\n");
}
TextArea.setText(TextArea.getText() + ClientSock.getInetAddress() + "连接到服务器\n");
}
catch (IOException ex)
{
Logger.getLogger(AcceptSockThread.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
public class ServerDialog extends javax.swing.JDialog
{
ServerSocket Server = null;
LinkedList SocketList = null;

public ServerDialog(java.awt.Frame parent, boolean modal)
{
super(parent, modal);
initComponents();
try
{
Server = new ServerSocket(8888);
SocketList = new LinkedList();
new AcceptSockThread(Server,SocketList,jTextArea1);
}
catch (IOException ex)
{
Logger.getLogger(ServerDialog.class.getName()).log(Level.SEVERE, null, ex);
}
}

@SuppressWarnings("unchecked")
// <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
private void initComponents() {

jScrollPane1 = new javax.swing.JScrollPane();
jTextArea1 = new javax.swing.JTextArea();
jTextField1 = new javax.swing.JTextField();
jButton1 = new javax.swing.JButton();

setDefaultCloseOperation(javax.swing.WindowConstants.DISPOSE_ON_CLOSE);
getContentPane().setLayout(null);

jTextArea1.setColumns(20);
jTextArea1.setEditable(false);
jTextArea1.setRows(5);
jScrollPane1.setViewportView(jTextArea1);

getContentPane().add(jScrollPane1);
jScrollPane1.setBounds(10, 10, 380, 250);
getContentPane().add(jTextField1);
jTextField1.setBounds(10, 270, 290, 21);

jButton1.setText("发送");
jButton1.addActionListener(new java.awt.event.ActionListener() {
public void actionPerformed(java.awt.event.ActionEvent evt) {
jButton1ActionPerformed(evt);
}
});
getContentPane().add(jButton1);
jButton1.setBounds(310, 270, 80, 25);

pack();
}// </editor-fold>//GEN-END:initComponents

private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jButton1ActionPerformed

if(SocketList.size() == 0)
{
jTextArea1.setText(jTextArea1.getText() + "没有人连接!!" + "\n");
return;
}
for(int i = 0;i < SocketList.size();i++)
{
DataOutputStream out;
try
{
out = new DataOutputStream(((Socket) SocketList.get(i)).getOutputStream());
if(jTextField1.getText() != null)
out.writeUTF(jTextField1.getText());
}
catch (IOException ex)
{
Logger.getLogger(ServerDialog.class.getName()).log(Level.SEVERE, null, ex);
}
}
jTextArea1.setText(jTextArea1.getText() + jTextField1.getText() + "\n");
}//GEN-LAST:event_jButton1ActionPerformed

public static void main(String args[])
{
ServerDialog dlg = new ServerDialog(null,true);
dlg.setBounds(300, 200, 400, 325);
dlg.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
System.exit(0);
}
});
dlg.setVisible(true);
}
// Variables declaration - do not modify//GEN-BEGIN:variables
private javax.swing.JButton jButton1;
private javax.swing.JScrollPane jScrollPane1;
private javax.swing.JTextArea jTextArea1;
private javax.swing.JTextField jTextField1;
// End of variables declaration//GEN-END:variables

}

客户端
-------------------------------------

import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.logging.Level;
import java.util.logging.Logger;

class RecvMegThread extends Thread
{
DataInputStream in;
DataOutputStream out;
Socket ServerSock;
javax.swing.JTextArea TextArea;
ClientDialog MainDialog;
RecvMegThread(ClientDialog dlg)
{
MainDialog = dlg;
ServerSock = dlg.ServerSock;
TextArea = dlg.jTextArea1;
try
{
in = new DataInputStream(ServerSock.getInputStream());
out = new DataOutputStream(ServerSock.getOutputStream());
}
catch (IOException ex)
{
Logger.getLogger(RecvMegThread.class.getName()).log(Level.SEVERE, null, ex);
}
start();
}
public void run()
{
while(true)
{
try
{
String word = in.readUTF();
TextArea.setText(TextArea.getText() + word + "\n");
}
catch (IOException ex)
{
TextArea.setText(TextArea.getText() + "和服务器失去了联系！！" + "\n");
MainDialog.ServerSock = null;
return;
}
}
}
}
public class ClientDialog extends javax.swing.JDialog
{
Socket ServerSock;
public ClientDialog(java.awt.Frame parent, boolean modal)
{
super(parent, modal);
initComponents();
}

@SuppressWarnings("unchecked")
// <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
private void initComponents() {

jScrollPane1 = new javax.swing.JScrollPane();
jTextArea1 = new javax.swing.JTextArea();
jTextField1 = new javax.swing.JTextField();
jButton1 = new javax.swing.JButton();
jLabel1 = new javax.swing.JLabel();
IP = new javax.swing.JTextField();
jLabel2 = new javax.swing.JLabel();
Port = new javax.swing.JTextField();
jButton2 = new javax.swing.JButton();

setDefaultCloseOperation(javax.swing.WindowConstants.DISPOSE_ON_CLOSE);
getContentPane().setLayout(null);

jTextArea1.setColumns(20);
jTextArea1.setEditable(false);
jTextArea1.setRows(5);
jScrollPane1.setViewportView(jTextArea1);

getContentPane().add(jScrollPane1);
jScrollPane1.setBounds(10, 40, 380, 220);
getContentPane().add(jTextField1);
jTextField1.setBounds(10, 270, 290, 21);

jButton1.setText("发送");
jButton1.addActionListener(new java.awt.event.ActionListener() {
public void actionPerformed(java.awt.event.ActionEvent evt) {
jButton1ActionPerformed(evt);
}
});
getContentPane().add(jButton1);
jButton1.setBounds(313, 270, 80, 25);

jLabel1.setText("服务器IP：");
getContentPane().add(jLabel1);
jLabel1.setBounds(10, 10, 70, 20);

IP.setText("127.0.0.1");
getContentPane().add(IP);
IP.setBounds(70, 10, 100, 21);

jLabel2.setText("端口：");
getContentPane().add(jLabel2);
jLabel2.setBounds(180, 10, 50, 20);

Port.setText("8888");
getContentPane().add(Port);
Port.setBounds(220, 10, 70, 21);

jButton2.setText("连接");
jButton2.addActionListener(new java.awt.event.ActionListener() {
public void actionPerformed(java.awt.event.ActionEvent evt) {
jButton2ActionPerformed(evt);
}
});
getContentPane().add(jButton2);
jButton2.setBounds(300, 10, 90, 25);

pack();
}// </editor-fold>//GEN-END:initComponents

private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jButton1ActionPerformed

if(ServerSock == null)
{
jTextArea1.setText(jTextArea1.getText() + "没有连接服务器！！" + "\n");
return;
}
try
{
DataOutputStream out = new DataOutputStream(ServerSock.getOutputStream());
if(jTextField1.getText() != null)
out.writeUTF(jTextField1.getText());
}
catch (IOException ex)
{
Logger.getLogger(ClientDialog.class.getName()).log(Level.SEVERE, null, ex);
}
}//GEN-LAST:event_jButton1ActionPerformed

private void jButton2ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jButton2ActionPerformed

if(IP.getText().isEmpty() || Port.getText().isEmpty())
{
this.jTextArea1.setText(this.jTextArea1.getText() + "IP 和 端口不能为空！！\n");
return;
}
try
{
Integer.parseInt(Port.getText());
}
catch(Exception e)
{
this.jTextArea1.setText(this.jTextArea1.getText() + "端口号应为数字！！\n");
return;
}

try
{
if(ServerSock != null)
{
String str = "" + ServerSock.getInetAddress() + ServerSock.getPort();
System.out.println(str);
System.out.println("/" + IP.getText() + Port.getText());
if(str.equals("/" + IP.getText() + Port.getText()))
{
this.jTextArea1.setText(this.jTextArea1.getText() + "已经连接了服务器！！\n");
return;
}
}
ServerSock = new Socket(IP.getText(), Integer.parseInt(Port.getText()));
new RecvMegThread(this);
}
catch (UnknownHostException ex)
{
jTextArea1.setText(jTextArea1.getText() + "连接不上服务器！！\n");
return;
}
catch (IOException ex)
{
jTextArea1.setText(jTextArea1.getText() + "连接不上服务器！！\n");
return;
}
}//GEN-LAST:event_jButton2ActionPerformed

public static void main(String args[])
{

ClientDialog dlg = new ClientDialog(null,true);
dlg.setBounds(300, 200, 405, 325);
dlg.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
System.exit(0);
}
});
dlg.setVisible(true);
}

// Variables declaration - do not modify//GEN-BEGIN:variables
private javax.swing.JTextField IP;
private javax.swing.JTextField Port;
private javax.swing.JButton jButton1;
private javax.swing.JButton jButton2;
private javax.swing.JLabel jLabel1;
private javax.swing.JLabel jLabel2;
private javax.swing.JScrollPane jScrollPane1;
public javax.swing.JTextArea jTextArea1;
private javax.swing.JTextField jTextField1;
// End of variables declaration//GEN-END:variables

}

---------------------------

Answer 2

问句，只有服务器端和客户端行么。。。
而且你连邮箱都没给，怎么发给你。。。