学步园

ChatServer

import java.io.DataInputStream;<br /> import java.io.DataOutputStream;<br /> import java.io.EOFException;<br /> import java.io.IOException;<br /> import java.net.ServerSocket;<br /> import java.net.Socket;<br /> import java.net.SocketException;<br /> import java.util.ArrayList;<br /> import java.util.List;</p> <p>/*<br /> * 聊天雏形服务端<br /> */<br /> public class ChatServer {<br /> private boolean started = false;<br /> private ServerSocket ss = null;<br /> private List<Client> list = new ArrayList<Client>();</p> <p> public static void main(String[] args) {<br /> new ChatServer().start();<br /> }</p> <p> /*<br /> * 接受连接<br /> */<br /> public void start() {<br /> try {<br /> ss = new ServerSocket(8888);<br /> started = true;<br /> } catch (IOException e1) {<br /> e1.printStackTrace();<br /> }<br /> try {<br /> while (started) {<br /> Socket s = ss.accept();<br /> Client c = new Client(s);<br /> list.add(c);<br /> new Thread(c).start();<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> } finally {<br /> try {<br /> if (ss != null) {<br /> ss.close();<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }</p> <p> /*<br /> * 处理信息<br /> */<br /> class Client implements Runnable {<br /> private Socket s = null;<br /> private DataInputStream dis = null;<br /> private DataOutputStream dos = null;<br /> private boolean connected = false;</p> <p> public Client(Socket s) {<br /> this.s = s;<br /> try {<br /> dis = new DataInputStream(s.getInputStream());<br /> dos = new DataOutputStream(s.getOutputStream());<br /> connected = true;<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> public void send(String t) {<br /> try {<br /> dos.writeUTF(t);<br /> } catch (IOException e) {<br /> System.out.println("Client is closed!");<br /> }<br /> }</p> <p> public void run() {<br /> try {<br /> while (connected) {<br /> String t = dis.readUTF();<br /> for (Client c : list) {<br /> c.send(t);<br /> }<br /> }<br /> } catch (SocketException e) {<br /> list.remove(this);<br /> } catch (EOFException e) {<br /> System.out.println("Client is closed!");<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> } finally {<br /> try {<br /> if (dis != null) {<br /> dis.close();<br /> }<br /> if (dos != null) {<br /> dos.close();<br /> }<br /> if (s != null) {<br /> s.close();<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br /> }<br /> }

ChatClient

import java.awt.BorderLayout;<br /> import java.awt.Frame;<br /> import java.awt.TextArea;<br /> import java.awt.TextField;<br /> import java.awt.event.ActionEvent;<br /> import java.awt.event.ActionListener;<br /> import java.awt.event.WindowAdapter;<br /> import java.awt.event.WindowEvent;<br /> import java.io.DataInputStream;<br /> import java.io.DataOutputStream;<br /> import java.io.EOFException;<br /> import java.io.IOException;<br /> import java.net.Socket;<br /> import java.net.SocketException;<br /> import java.net.UnknownHostException;</p> <p>/*<br /> * 聊天雏形客户端<br /> */<br /> public class ChatClient extends Frame {<br /> private TextField tf = new TextField();<br /> private TextArea ta = new TextArea();<br /> private Socket s = null;<br /> private DataOutputStream dos = null;<br /> private DataInputStream dis = null;<br /> private boolean connected = false;<br /> private Thread t = new Thread(new Recv());</p> <p> public static void main(String[] args) {<br /> new ChatClient().launchFrame();<br /> }</p> <p> /*<br /> * 初始化窗口<br /> */<br /> public void launchFrame() {<br /> this.setLocation(400, 300);<br /> this.setSize(300, 300);<br /> this.add(ta, BorderLayout.NORTH);<br /> this.add(tf, BorderLayout.SOUTH);<br /> this.pack();<br /> this.addWindowListener(new WindowAdapter() {<br /> public void windowClosing(WindowEvent e) {<br /> unconnect();<br /> System.exit(0);<br /> }<br /> });<br /> tf.addActionListener(new TFListener());<br /> this.setVisible(true);<br /> this.connect();<br /> t.start();<br /> }</p> <p> /*<br /> * 连接<br /> */<br /> public void connect() {<br /> try {<br /> s = new Socket("127.0.0.1", 8888);<br /> dos = new DataOutputStream(s.getOutputStream());<br /> dis = new DataInputStream(s.getInputStream());<br /> connected = true;<br /> } catch (UnknownHostException e) {<br /> e.printStackTrace();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> /*<br /> * 关闭连接<br /> */<br /> public void unconnect() {<br /> try {<br /> if (dis != null) {<br /> dis.close();<br /> }<br /> if (dos != null) {<br /> dos.close();<br /> }<br /> if (s != null) {<br /> s.close();<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> /*<br /> * 发送信息<br /> */<br /> private class TFListener implements ActionListener {<br /> public void actionPerformed(ActionEvent e) {<br /> String t = tf.getText().trim();<br /> tf.setText("");<br /> try {<br /> dos.writeUTF(t);<br /> dos.flush();<br /> } catch (IOException e1) {<br /> e1.printStackTrace();<br /> }<br /> }<br /> }</p> <p> /*<br /> * 接受信息<br /> */<br /> private class Recv implements Runnable {<br /> public void run() {<br /> try {<br /> while (connected) {<br /> String t = dis.readUTF();<br /> ta.setText(ta.getText() + t + "/n");<br /> }<br /> } catch (SocketException e) {<br /> System.out.println("退出了，bye！");<br /> } catch (EOFException e) {<br /> System.out.println("Client is closed!");<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br /> }