学步园

package TestSocket01;</p> <p>import java.awt.Color;</p> <p>import javax.swing.JFrame;<br /> import javax.swing.JLabel;<br /> import javax.swing.JScrollPane;<br /> import javax.swing.JTextArea;</p> <p>public class MyForm extends JFrame{</p> <p> private static final long serialVersionUID = 1L;<br /> // private JButton jbSent = new JButton("发送");<br /> private JLabel jlabelName = new JLabel("用户昵称：");<br /> private JTextArea jtaName = new JTextArea("");<br /> private JTextArea jtaShow = new JTextArea("");<br /> private JTextArea jtaWrite = new JTextArea("");</p> <p> public MyForm() {<br /> //测试！<br /> }</p> <p> public MyForm(String str) {<br /> super(str);<br /> }</p> <p> public void mShow() {<br /> this.setVisible(true);<br /> }</p> <p> public void mClose() {<br /> this.setDefaultCloseOperation(EXIT_ON_CLOSE);<br /> }</p> <p> public void mform() {</p> <p> this.setLayout(null);<br /> this.setBounds(300, 300, 500, 500);<br /> //this.getContentPane().setBackground(new Color(200, 90, 30)); nothing<br /> this.getContentPane().setBackground(Color.gray);</p> <p> jlabelName.setBounds(10, 10, 900, 25);<br /> jtaName.setBounds(100, 10, 200, 25);</p> <p> // jbSent.setBounds(400, 400, 80, 30);<br /> JScrollPane jspShow = new JScrollPane(jtaShow);<br /> JScrollPane jspWrite = new JScrollPane(jtaWrite);</p> <p> jspShow.setBounds(30, 40, 350, 350);<br /> jtaShow.setLineWrap(true);<br /> jtaShow.setEditable(false);<br /> jtaShow.setCaretPosition(jtaShow.getDocument().getLength());</p> <p> jspWrite.setBounds(30, 400, 330, 35);<br /> jtaWrite.setLineWrap(true);<br /> jtaWrite.setCaretPosition(jtaWrite.getDocument().getLength());</p> <p> this.add(jlabelName);<br /> this.add(jtaName);<br /> this.add(jspShow);<br /> this.add(jspWrite);<br /> }</p> <p> public String getName() {<br /> return jtaName.getText();<br /> }</p> <p> public void setMessage(String message) {<br /> jtaShow.append(message+"/n"); //添加信息并换行。<br /> //jtaShow.setWrapStyleWord(true);<br /> }</p> <p> public String getMessage() {<br /> if (!(jtaWrite.getText()).equals("")) { //如果写的东西不为空<br /> if (!(jtaName.getText()).equals("")) { //判断是谁写的信息<br /> return (jtaName.getText() + "： " + jtaWrite.getText());<br /> } else {<br /> return ("ClientX： " + jtaWrite.getText()); //无名氏默认是ClientX<br /> }<br /> } else { //什么都没写<br /> return "";<br /> }<br /> }</p> <p> public void clearWrite() { //清空所写的东西。<br /> jtaWrite.setText("");<br /> }</p> <p> public static void main(String[] args) {<br /> MyForm mf = new MyForm(); //测试用的而已。<br /> mf.mform();<br /> mf.mShow();<br /> mf.mClose();</p> <p> }</p> <p>}</p> <p>

package TestSocket01;</p> <p>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.IOException;<br /> import java.net.Socket;<br /> import java.net.UnknownHostException;</p> <p>import javax.swing.JButton;</p> <p>public class socketClient implements Runnable {<br /> private Socket s;<br /> private DataInputStream dis;<br /> private DataOutputStream dos;<br /> private boolean flag = true; //标志 如果多个客户端则会出错。</p> <p> private MyForm mf = new MyForm("通讯客户端"); //新建了一个客户端的界面。<br /> private JButton jbSent = null;</p> <p> private boolean serverClose = false;// 标识服务器端是否关闭，true为关闭，false为没关闭</p> <p> public socketClient() {<br /> mf.mform();<br /> mf.mShow();<br /> mf.mClose(); </p> <p> try {<br /> jbSent = new JButton("发送");<br /> jbSent.setBounds(400, 400, 80, 30); //设置按钮的大小<br /> mf.add(jbSent); //添加到JFrame中<br /> s = new Socket("222.17.110.117", 55551); //此处新建了一个Socket，并连接服务器。通信从此位置开始。<br /> jbSent.addActionListener(new ActionListener() { //“发送”按钮监听<br /> public void actionPerformed(ActionEvent e) { //监听按钮的方法。必须实现的。<br /> try {<br /> if(!serverClose){ // 第一次执行时，默认是开着的。之后，如果服务器开着，即没有关闭,则发送下面内容<br /> String message = mf.getMessage(); //取得某人写的某些内容<br /> if (!message.equals("")) {<br /> System.out.println(message); //后台打印测试而已！<br /> dos = new DataOutputStream(s.getOutputStream());<br /> dos.writeUTF(message); //把message通过s输出去<br /> mf.clearWrite(); //此处只有发送按钮在监听，故发送之后，内容理应删掉。<br /> }<br /> }<br /> } catch (IOException ioe) {<br /> ioe.printStackTrace();<br /> }<br /> }<br /> });<br /> mf.addWindowListener(new WindowAdapter() { // 监听客户端是否关闭，如果关闭，则向服务器发送一个“exit”字符串<br /> public void windowClosing(WindowEvent e) {<br /> try {<br /> if (serverClose) { //serverClose 的值一直都是false。<br /> //此处永远不会被执行。<br /> } else { //因为监听到了窗口被关闭了。<br /> dos = new DataOutputStream(s.getOutputStream());<br /> dos.writeUTF("exit"); //既然关闭了，就发送个信号给服务器。删除该客户端。<br /> }<br /> } catch (IOException e1) {<br /> e1.printStackTrace();<br /> }<br /> }<br /> });</p> <p> new Thread(this).start(); //打开一个线程，即执行本类的run()函数。<br /> } catch (UnknownHostException e) {<br /> e.printStackTrace();//打印出错信息而已，别无他意。<br /> } catch (IOException e) {<br /> serverClose=true;<br /> mf.setMessage("服务器不存在或未打开!");<br /> }<br /> }</p> <p> public void run() {<br /> while (flag) {<br /> try {<br /> dis = new DataInputStream(s.getInputStream());<br /> mf.setMessage(dis.readUTF());<br /> } catch (IOException e) {<br /> serverClose = true; //服务器可能在有客户端存在的时候关闭，此时，客户端输入流会出错，刚执行此处<br /> mf.setMessage("服务器关闭了！");<br /> flag=false;//跳出循环<br /> }<br /> }<br /> }</p> <p> public static void main(String[] agrs) {<br /> new socketClient(); //先开服务器，再开客户端。代码入口处。<br /> }<br /> }<br />

package TestSocket01;</p> <p>import java.io.DataInputStream;<br /> import java.io.DataOutputStream;<br /> import java.io.IOException;<br /> import java.net.ServerSocket;<br /> import java.net.Socket;<br /> import java.util.Vector;<br /> //服务器端<br /> public class socketServer {<br /> private ServerSocket ss;<br /> private Socket s;<br /> private DataInputStream dis;<br /> private DataOutputStream dos;<br /> private static Vector<Client> v = new Vector<Client>();<br /> private Client client;</p> <p> public socketServer() {<br /> try {<br /> ss = new ServerSocket(55551);<br /> System.out.println("服务器已经启动！"); //后台提示<br /> while (true) {<br /> try {<br /> s = ss.accept(); //一直在等待连接<br /> System.out.println(s);<br /> dis = new DataInputStream(s.getInputStream()); //初始化Socket的两个流。<br /> dos = new DataOutputStream(s.getOutputStream());</p> <p> System.out.println(v.size()); //打印此时登陆客户端的个数。<br /> client = new Client(v.size(),dos, dis); //说明一个客户端连接上了，给个线程。只能定义一次。。。<br /> v.addElement(client); //往向量里面添加一个客户端。<br /> client.start(); //启动一个线程<br /> System.out.println(getVectorSize());//打印此时登陆客户端的个数。<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> } catch (IOException e) {<br /> System.out.println("服务器启动失败！");<br /> }<br /> }</p> <p> public static int getVectorSize() {<br /> return v.size();<br /> }</p> <p> public static Vector<Client> getVector() {<br /> return v;<br /> }</p> <p> public static void main(String[] args) {<br /> new socketServer();<br /> }<br /> }<br /> //每个客户端线程连接过去，则建立一个该对象<br /> class Client extends Thread {<br /> int id;<br /> DataOutputStream dos;<br /> DataInputStream dis;</p> <p> public Client( int id,DataOutputStream dos, DataInputStream dis) {<br /> this.id=id;<br /> this.dis = dis;<br /> this.dos = dos;<br /> }</p> <p> public void run() { //启动时便执行该段代码！<br /> boolean flag = true; //只是一个标志<br /> int m;<br /> while (flag) {<br /> try {<br /> String message = dis.readUTF(); //输入进来的流，简称输入流，拿到客户端的信息。<br /> System.out.println(message); //后台打印出来<br /> if (message.equals("exit")) {//如果接收到"exit"字符串，说明运行该线程的客户端断开了连接,则需退出该循环，退出线程<br /> flag = false; //退出循环<br /> socketServer.getVector().remove(this); //当客户端关闭时，从Vector里除去本对象<br /> } else {<br /> m = socketServer.getVectorSize(); //返回共有多少个客户端目前。<br /> for (int i = 0; i < m; i++) { //给每个客户端发送同样的信息。<br /> socketServer.getVector().get(i).dos.writeUTF(message); //输出信息给每个客户端。<br /> }<br /> }<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br /> }</p> <p>