chat.java

用tcp,udp 实现的聊天室,都能正常运行,初学java网络编程的可参考

package chat;

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import javax.swing.event.*;
import java.io.*;
import java.net.*;

public class Chat {
	private JFrame chatFrame;

	private Container container;

	private JLabel addLabel;

	private JTextField addTextField;

	private JButton connectButton;

	private JPanel connectPanel;

	private JLabel stateLabel;

	private JTextArea msgTextArea;

	private JScrollPane msgPane;

	private JTextField sendTextField;

	private JButton sendButton;

	private JPanel sendPanel;

	private ServerSocket server;

	private Socket clientSocket;

	private PrintWriter pw;

	public Chat() {
		chatFrame = new JFrame("聊天");
		container = chatFrame.getContentPane();

		addLabel = new JLabel("IP地址:");
		addTextField = new JTextField(15);
		connectButton = new JButton("连接");
		stateLabel = new JLabel("当前状态:");
		connectPanel = new JPanel();

		msgTextArea = new JTextArea();
		msgPane = new JScrollPane(msgTextArea);
		msgTextArea.setEditable(false);
		msgTextArea.setAutoscrolls(true);

		sendTextField = new JTextField(50);
		sendButton = new JButton("提交");
		sendPanel = new JPanel();

		initGUI();
	}

	private void initGUI() {
		connectPanel.setLayout(new FlowLayout(FlowLayout.LEFT, 25, 5));
		connectPanel.add(addLabel);
		connectPanel.add(addTextField);
		connectPanel.add(connectButton);
		connectPanel.add(stateLabel);

		sendPanel.setLayout(new FlowLayout(FlowLayout.LEFT));
		sendPanel.add(sendTextField);
		sendPanel.add(sendButton);

		container.add(connectPanel, BorderLayout.NORTH);
		container.add(msgPane, BorderLayout.CENTER);
		container.add(sendPanel, BorderLayout.SOUTH);

		chatFrame.setSize(800, 600);
		chatFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

		ConnectListener conn = new ConnectListener();
		connectButton.addActionListener(conn);
		addTextField.addActionListener(conn);

		SendListener send = new SendListener();
		sendButton.addActionListener(send);
		sendTextField.addActionListener(send);
	}

	public void go() {
		chatFrame.setVisible(true);
		new Thread(new ConnectHost()).start();
	}

	private class ConnectHost implements Runnable {
		public void run() {

			while (true) { // System.out.println("while");
				if (clientSocket != null) {
					stateLabel.setText("当前状态:已连接...");
					try {
						pw = new PrintWriter(clientSocket.getOutputStream(),
								true);
						BufferedReader br = new BufferedReader(
								new InputStreamReader(clientSocket
										.getInputStream()));
						String strResive;
						while (true) {
							strResive = br.readLine();
							if (!strResive.equals("null"))
								msgTextArea.append(strResive + "\n");

						}
					} catch (Exception e) {
						server = null;
						clientSocket = null;
					}

				}
				try {

					server = new ServerSocket(10000);
					System.out.println("server socket created");
					stateLabel.setText("当前状态:正在监听...");
					clientSocket = server.accept();
					// System.out.println("new socket connnect");
					stateLabel.setText("当前状态:已连接...");
				} catch (Exception e) {
					stateLabel.setText("当前状态:本地端口已被占用...");
				}
			}
		}

	}

	private class SendListener implements ActionListener {
		public void actionPerformed(ActionEvent ae) {
			if (sendTextField.getText().trim().equals(""))
				return;
			if (clientSocket == null)
				return;

			pw.println(sendTextField.getText().trim());
			msgTextArea.append(sendTextField.getText() + "\n");
			sendTextField.setText("");
		}
	}

	private class ConnectListener implements ActionListener {
		public void actionPerformed(ActionEvent ae) {
			if (addTextField.getText().trim().equals(""))
				return;
			String ipAddress = addTextField.getText().trim();
			try {
				clientSocket = new Socket(ipAddress, 10000);
				stateLabel.setText("当前状态:已连接");
				server.close();

			} catch (Exception e) {

				stateLabel.setText("当前状态:连接失败");
			}
		}
	}

	public static void main(String[] args) {
		new Chat().go();
	}
}