chatserver.java

java编写的聊天室服务器端程序

package Server;

import java.net.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.*;

public class ChatServer extends Frame implements ActionListener, Runnable {
	static ChatServer frm = new ChatServer();

	static Button Close = new Button("close server");

	static Button Start = new Button("start server");

	static TextArea textArea = new TextArea();

	boolean bool = false, start = false;

	int i = 0;

	Thread thread;

	ServerSocket server = null;

	Socket clientSocket;

	boolean flag = true;

	Thread ConnenThread;

	BufferedReader cin;

	DataInputStream in;

	DataOutputStream out;

	DataOutputStream cout;

	public static void main(String args[]) {
		frm.setTitle("Server");
		frm.addWindowListener(new WindowAdapter() {
			public void windowClosing(WindowEvent e) {
				System.exit(0);
			}
		});
		frm.setSize(400, 400);
		frm.setLayout(null);

		textArea.setText("");
		textArea.setBounds(150, 50, 250, 300);

		Close.setBounds(10, 40, 89, 25);
		Close.addActionListener(frm);
		Start.setBounds(10, 70, 73, 25);
		Start.addActionListener(frm);

		frm.add(textArea);

		frm.add(Close);
		frm.add(Start);

		frm.setVisible(true);
	}

	public void actionPerformed(ActionEvent e) {
		// TODO Auto-generated method stub
		if (e.getSource() == Close) {
			bool = false;
			start = false;
			// thread.destroy();
			frm.setVisible(false);
			// frm.addWindowListener(new WindowAdapter(){
			// public void windowClosing(WindowEvent e){System.exit(0);}});
		} else if (e.getSource() == Start) {
			try {
				server = new ServerSocket(8765);
				System.out.println("端口号：" + server.getLocalPort());
				while (flag) {
					System.out.println("连接建立完毕!");
					clientSocket = server.accept();
					System.out.println("连接建立完毕dddd!");
					InputStream is = clientSocket.getInputStream();
					in = new DataInputStream(is);

					/** ************************ */
					// textArea.setText(sin);
					/** ************************************ */
					OutputStream os = clientSocket.getOutputStream();
					out = new DataOutputStream(os);

					// ConnenThread=new Thread(this);
					// ConnenThread.start();
				}
			} catch (Exception e2) {
			}
		}
	}

	public void run() {
		// TODO Auto-generated method stub
		while (true) {
			try {
				int ch;
				while ((ch = System.in.read()) != -1) {
					out.write((byte) ch);
					if (ch == '\n') {
						out.flush();
					}
				}
			} catch (Exception e) {
				System.out.println(e);
			}
		}
	}
}