学步园

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>public class ChatClient extends Frame {<br /> DataOutputStream dos = null;</p> <p> DataInputStream dis = null;</p> <p> private boolean bConnection = false;</p> <p> Socket s = null; // 服务器连接对象</p> <p> private String userName = "潜水人员";</p> <p> private boolean hasUsername = false;</p> <p> TextField tfTxt = new TextField(); // 添加一个文本框</p> <p> TextArea taContent = new TextArea(); // 添加一个文件域</p> <p> public static void main(String[] args) {<br /> // TODO Auto-generated method stub<br /> new ChatClient().launchFrame();<br /> }</p> <p> public void launchFrame() {<br /> this.setLocation(300, 400); // 设置窗体的位置<br /> this.setSize(300, 300); // 设置窗体的大小<br /> add(tfTxt, BorderLayout.SOUTH); // 往窗体中添加文本框 位置为窗体的确南方<br /> add(taContent, BorderLayout.NORTH); // 往窗体中添加文件域 位置为窗体的确北方<br /> pack(); // 自到调整窗体的位置<br /> taContent.setText("您的昵称：");<br /> this.addWindowListener(new WindowAdapter() {<br /> @Override<br /> public void windowClosing(WindowEvent e) {<br /> disconnect(); // 释放资源<br /> System.exit(0); // 正常终止程序<br /> }</p> <p> });<br /> tfTxt.addActionListener(new TFlistener());<br /> this.setVisible(true);<br /> connect(); // 调用连接服务器的方法</p> <p> new Thread(new RecvThread()).start(); // 启动线程<br /> }</p> <p> // 连接服务器<br /> private void connect() {<br /> try {<br /> // s = new Socket("127.0.0.1", 8888);<br /> s = new Socket("192.168.0.5", 8888);<br /> dos = new DataOutputStream(s.getOutputStream());<br /> dis = new DataInputStream(s.getInputStream());<br /> System.out.println("content");<br /> bConnection = true;<br /> } catch (UnknownHostException e) {<br /> e.printStackTrace();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> /**<br /> * 释放资源<br /> */<br /> public void disconnect() {<br /> try {<br /> dos.close();<br /> s.close();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }</p> <p> }</p> <p> // 添加一个程序响应事件<br /> private class TFlistener implements ActionListener {</p> <p> public void actionPerformed(ActionEvent e) {<br /> String str = tfTxt.getText().trim(); // 得到tfTxt文本框中的内容<br /> // taContent.setText(str); //设置taContent文件域中的内容<br /> tfTxt.setText(""); // 设置tfTxt文本框中的内容<br /> try {<br /> if (hasUsername == false) {<br /> userName = "".equals(str) ? userName : str;<br /> // dos.writeUTF(userName + "上线了!!!!!!");<br /> taContent.setText(taContent.getText() + userName + "/n");<br /> hasUsername = true;<br /> } else {<br /> dos.writeUTF("【" + userName + "】说:" + str);<br /> }<br /> dos.flush();<br /> // dos.close();<br /> } catch (IOException e1) {<br /> e1.printStackTrace();<br /> }<br /> }</p> <p> }</p> <p> private class RecvThread implements Runnable {</p> <p> public void run() {<br /> try {<br /> while (bConnection) {<br /> if (hasUsername == true) {<br /> String str = dis.readUTF();<br /> // System.out.println(str);<br /> taContent.setText(taContent.getText() + str + "/n");<br /> }<br /> }<br /> } catch (SocketException e) {<br /> System.out.println("退出了!byebye!");<br /> } catch (EOFException e) {<br /> System.out.println("推出了! bye!");<br /> } catch (IOException ex) {<br /> ex.printStackTrace();<br /> }</p> <p> }</p> <p> }<br /> }<br /> import java.io.*;<br /> import java.net.*;<br /> import java.util.*;</p> <p>public class ChatServer {</p> <p> boolean started = false;</p> <p> ServerSocket ss = null;</p> <p> List<Client> clients = new ArrayList<Client>();</p> <p> public static void main(String[] args) {<br /> ChatServer chatServer = new ChatServer();<br /> chatServer.start();<br /> }</p> <p> public void start() {<br /> try {<br /> ss = new ServerSocket(8888); // 8888表示的是端口名<br /> started = true;<br /> } catch (BindException ex) {<br /> System.out.println("端口使用中．．．．");<br /> System.out.println("请关掉相关程序！关重新运行服务器！");<br /> System.exit(0);<br /> } catch (IOException ex) {<br /> ex.printStackTrace();<br /> }<br /> try {</p> <p> while (started) {<br /> Socket s = ss.accept(); // 表示接收客戶端<br /> Client c = new Client(s);<br /> System.out.println("a Client contend!");<br /> new Thread(c).start();<br /> clients.add(c); // 把对象添加到集合中去<br /> // dis.close();<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> } finally {<br /> try {<br /> ss.close();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }</p> <p> class Client implements Runnable {<br /> private Socket s; // 代表与客户端的连接</p> <p> private DataInputStream dis = null;</p> <p> private DataOutputStream dos = null;</p> <p> private boolean bConnection = 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 /> bConnection = true;<br /> } catch (IOException e) {</p> <p> e.printStackTrace();<br /> }<br /> }</p> <p> public void send(String str) {<br /> try {<br /> dos.writeUTF(str);<br /> } catch (IOException es) {<br /> clients.remove(this);<br /> System.out.println("对方退出了!我从list里面去除了!");<br /> // es.printStackTrace();<br /> }<br /> }</p> <p> public void run() {<br /> try {<br /> while (bConnection) {<br /> String str = dis.readUTF();<br /> System.out.println(str);<br /> for (int i = 0; i < clients.size(); i++) {<br /> Client c = clients.get(i);<br /> c.send(str);<br /> }</p> <p> /*<br /> * for(Iterator<Client> it =<br /> * clients.iterator();it.hasNext();) { Client c = it.next();<br /> * c.send(str); }<br /> */</p> <p> /*<br /> * Iterator<Client> it = clients.iterator();<br /> * while(it.hasNext()) { Client c = it.next(); c.send(str); }<br /> */<br /> }<br /> } catch (EOFException e) {<br /> System.out.println("Client Closed");<br /> } catch (IOException e) {<br /> // e.printStackTrace();<br /> } finally {<br /> try {<br /> if (dis != null)<br /> dis.close();<br /> if (dos != null)<br /> dos.close();<br /> if (s != null)<br /> s.close();<br /> } catch (IOException e1) {<br /> e1.printStackTrace();<br /> }</p> <p> }</p> <p> }</p> <p> }<br /> }