chatserver.java

实现服务器端和客户端聊天交互功能

package chat;

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.Date;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JTextArea;

public class ChatServer {

	JFrame jf = new JFrame("Server");
	JPanel jp = new JPanel();
	JTextArea jtainput = new JTextArea();
	JTextArea jtaoutput = new JTextArea();
	JButton jb = new JButton("Send");
	Socket s;
	ObjectOutputStream oos;
	
	public ChatServer(){
		
		jp.setLayout(new GridLayout(2, 1, 15, 15));
		jp.add(jtainput);
		jp.add(jtaoutput);
		jf.add(jp, BorderLayout.CENTER);
		jf.add(jb, BorderLayout.SOUTH);
		jf.setSize(300, 300);
		jf.setVisible(true);
		
		try {
			
			ServerSocket ss = new ServerSocket(9999);
			s = ss.accept();
			oos = new ObjectOutputStream(s.getOutputStream());
			ServerThread st = new ServerThread();
			st.start();		
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		jb.addActionListener(new ActionListener(){

			public void actionPerformed(ActionEvent arg0) {
				// TODO Auto-generated method stub
				ChatMessage cm = new ChatMessage(new Date(), jtaoutput.getText());
				
				try {
//					oos = new ObjectOutputStream(s.getOutputStream());
					oos.writeObject(cm);
					jtaoutput.setText("");
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}		
		});
	}
	
	class ServerThread extends Thread{
		
		public void run(){
			
			try {
				
				ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
				
				while(true){
					
					jtainput.append(ois.readObject().toString());
				}				
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (ClassNotFoundException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
	public static void main(String[] args) {
		
		ChatServer sc = new ChatServer();
	}
}