server.java

简单的网络聊天室

package com.oristand;

import java.awt.BorderLayout;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.*;


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





public class Server {

	JFrame jf=new JFrame("Server");
	ServerSocket ss;
	Socket s;
	Date date;
	String username;
	JTextArea jtainput = new JTextArea();
	JScrollPane jspinput = new JScrollPane(jtainput); 
	
	JTextArea jtaoutput = new JTextArea();
	JButton jb = new JButton("send");
	JPanel jp = new JPanel();
	ObjectOutputStream oos;
	
	public Server(){
		
		jp.setLayout(new GridLayout(2, 1, 15, 15));
		jp.add(jspinput);
		jp.add(jtaoutput);
		jf.add(jp, BorderLayout.CENTER);
		jf.add(jb, BorderLayout.SOUTH);
		jf.setSize(300, 400);
		jf.setVisible(true);
		
		jb.addActionListener(new ActionListener(){

			public void actionPerformed(ActionEvent e) {
				// TODO Auto-generated method stub
				
				
				Message cm = new Message(jtaoutput.getText(),username,date);
				
				try {
					oos.writeObject(cm);
				} catch (IOException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				jtaoutput.setText("");
				
			}		
			
		});
		
	}

	public void start() {
		try {
			ss = new ServerSocket(9999);
			while (true) {
				s = ss.accept();
				MyThread mth = new MyThread(s);
				mth.start();
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			// e.printStackTrace();
		}

	
	}

	class MyThread extends Thread {
		Socket s;

		public MyThread() {

		}

		public MyThread(Socket s) {
			this.s = s;
			
		}

		public void run() {
		
			try {
		ObjectInputStream ois = new ObjectInputStream(s.
				getInputStream());
	     while(true){
	    	
				jtainput.append(ois.readObject().toString());
			} 
	    	 
	     }
			catch (ClassNotFoundException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} 
			
			catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
	
		}
				
			
			
		
					
	}
	public static void main(String[] args) {
		Server s=new Server();
		s.start();
		}


}