/**//*
*服务端
*/
package edu.jlu.fuliang;
import java.io.*;
import java.net.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import javax.swing.*;
public class Server extends JFrame implements Runnable {
private ServerSocket server;
private Socket connection;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;
public static void main(String args[]) {
Server s = new Server();
s.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
public Server() {
super("Server");
startButton = new JButton("Start the server");
text1 = new JTextField(20);
display = new JTextArea(7, 30);
display.setEditable(false);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(startButton,BorderLayout.NORTH);
container.add(new JScrollPane(display),BorderLayout.CENTER);
container.add(text1,BorderLayout.SOUTH);
/**//*
* 给开始按钮添加监听器。
*/
startButton.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
display.setText("启动服务器 ");
startButton.setEnabled(false);
try {
//端口设为5000，最大连接请求为100个
server = new ServerSocket(5000, 100);
connection = server.accept();
output = connection.getOutputStream();
input = connection.getInputStream();
output.write("连接成功! ".getBytes());
outThread = new Thread(Server.this);
outThread.start();
} catch (IOException ee) {
}
}
});
/**//*
/*给文本域添加键盘监听器，按回车发送信息。
*/
text1.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent ke) {
if(ke.getKeyCode() == KeyEvent.VK_ENTER){
byte writeBytes[] = new byte[50];
String s = "Server: " + text1.getText() + "";
text1.setText("");
writeBytes = s.getBytes();
display.append(s+" ");
try {
output.write(writeBytes);
} catch (IOException ee) {
}
if (s.trim().equals("Server: exit")) {
outThread.stop();
quit();
}
}
}
});
setSize(300, 400);
setResizable(false);
setVisible(true);
}
public void run() {
while (true) {
byte readBytes[] = new byte[50];
try {
input.read(readBytes);//读去对方发送的消息
} catch (IOException e) {
}
String s = new String(readBytes);
display.append(s+" ");
if (s.trim().equals("Client: exit"))
break;
}
quit();
}
public void quit() {
try {
output.close();
input.close();
connection.close();
} catch (IOException e) {
}
startButton.setEnabled(true);
}
}
/**//*
*客户端
*/
package edu.jlu.fuliang;
import java.io.*;
import java.net.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import javax.swing.*;
public class Client extends JFrame implements Runnable {
private Socket client;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;
private JMenu loginMenu = new JMenu("登录");
private JMenuItem register = new JMenuItem("注册");
private JMenuItem login = new JMenuItem("登录");
private JMenuBar bar = new JMenuBar();
private Register registerDlg ;
private Login loginDlg;
private RandomAccessFile file;
public static void main(String args[]) {
Client c = new Client();
c.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
public Client() {
super("Client");
startButton = new JButton("Connect to server");
text1 = new JTextField(20);
display = new JTextArea(7, 30);
display.setEditable(false);
loginMenu.add(register);
loginMenu.add(login);
bar.add(loginMenu);
setJMenuBar(bar);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(startButton,BorderLayout.NORTH);
container.add(new JScrollPane(display),BorderLayout.CENTER);
container.add(text1,BorderLayout.SOUTH);
try {
file = new RandomAccessFile(new File("E://login.txt"),"rw");
} catch (IOException e1) {
e1.printStackTrace();
}
registerDlg = new Register(this,file);
loginDlg = new Login(this,file);
startButton.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
display.setText("连接服务器");
startButton.setEnabled(false);
try {
client = new Socket("127.0.0.1", 5000);
output = client.getOutputStream();
input = client.getInputStream();
outThread = new Thread(Client.this);
outThread.start();
} catch (IOException ee) {
}
}
});
text1.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent ke) {
if(ke.getKeyCode() == KeyEvent.VK_ENTER){
byte writeBytes[] = new byte[50];
String s = loginDlg.getLoginName()+": " + text1.getText() + "";
text1.setText("");
writeBytes = s.getBytes();
display.append(s+" ");
try {
output.write(writeBytes);
} catch (IOException ee) {
}
if (s.trim().equals(loginDlg.getLoginName()+": exit")) {
outThread.stop();
quit();
}
}
}
});
register.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
registerDlg.setVisible(true);
}
});
login.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
loginDlg.setVisible(true);
}
});
setSize(300, 400);
setResizable(false);
setVisible(true);
}
public void run() {
while (true) {
byte readBytes[] = new byte[1024];
try {
input.read(readBytes);
} catch (IOException e) {
}
String s = new String(readBytes);
display.append(s+" ");
if (s.trim().equals("Server: exit"))
break;
}
quit();
}
public void quit() {
try {
output.close();
input.close();
client.close();
} catch (IOException e) {
}
startButton.setEnabled(true);
}
}
package edu.jlu.fuliang;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import javax.swing.*;
public class Login extends JDialog{
private JTextField textField;
private JButton loginButton;
private RandomAccessFile file;//保存注册信息的文件
private String loginName = "guest";//保存登录者的名字，为登陆为guest;
public Login(JFrame f,RandomAccessFile file){
super(f,"登陆",false);
this.file = file;
JPanel panel = new JPanel();
panel.add(new JLabel("昵称:"));
textField = new JTextField(10);
panel.add(textField);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(panel,BorderLayout.NORTH);
loginButton = new JButton("登陆");
container.add(loginButton,BorderLayout.SOUTH);
setVisible(false);
setBounds(100,200,200,200);
loginButton.addActionListe
