flex与java之间socket通信的教程3

三）多客户通信

目的：做一个简单的多玩家多线程的猜拳游戏。每个客户机都与服务端的一个套接字进行通信，但是各个客户机之间不进行通信。服务器受到客户机的连接请求时会 创建新的套接字并使其与客户机连接。然后启动线程与客户机进行数据交换。套接字管理器是一个Vector，用于管理套接字的个数及其连接状态。

游戏描述：玩家通过向服务器发送０，１，２这个三个数字，用来代表剪刀，锤包，袱。服务器接到信息后会随机产生0,1,2这三个数字的其中的一个。在客户机上通过比较来进行判断输赢。

服务端代码：Server４.java
＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝
import java.net.*;
import java.io.*;
import java.util.*;

public class Server4 {
        private ServerSocket server;
        Vector sManager=new Vector();//管理套接字的Vector
        Random rnd=new Random();//创建随机数的发生器
       
        public Server4(){}
        void startServer()　//运行服务器
        {
                try
                {
                        server=new ServerSocket(8888);
                        System.out.println("服务器套接字已创建成功！");
                        while(true)
                        {
                                Socket socket=server.accept();
                                System.out.println("已经与客户机连接");
                                new KBBCom_Thread(socket).start();
                                sManager.add(socket);
                                System.out.println("当前客户机连结数："+sManager.size());
                        }
                }catch(Exception e){}
        }
        public static void main(String[] args) {
               
                Server4 server=new Server4();
                server.startServer();
        }
        class KBBCom_Thread extends Thread　　//与客户机进行通信的线程累
        {
                Socket socket;　　 //套接字引用变量
                private DataInputStream reader;　　 //套接字输入流
                private DataOutputStream writer;　 //套接字输出流
                KBBCom_Thread(Socket socket)　　 //构造函数
                {
                        this.socket=socket;
                }
                public void run()
                {
                        try
                        {
                        //获取套接字的输入输出流
                                reader=new DataInputStream(socket.getInputStream());
                                writer=new DataOutputStream(socket.getOutputStream());
                                String msg;
//如果收到客户端发来的数据
                                while((msg=reader.readUTF())!=null)
                                {
                                        //向客户机传送０-２之间的整型随机数
                                                writer.writeUTF(rnd.nextInt(3)+" ");
                                                writer.flush();
                                                System.out.println("来自客户机："+msg);

                                }
                        }catch(Exception e){}finally
                        {
                                try
                                {
                                        sManager.remove(socket); 　//删除套接字
                                        //关闭输入输出流及套接字
                                        if(reader!=null)reader.close();
                                        if(writer!=null)writer.close();
                                        if(socket!=null)socket.close();
                                        reader=null;
                                        writer=null;
                                        socket=null;
//向屏幕输出相关信息
                                        System.out.println("客户机离开");
                                        System.out.println("当前客户机的连接数："+sManager.size());
                                }catch(Exception e){}
                        }
                }
        }

}
＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝
知识点：套接字管理器（Vector）会将于客户机连接的套接字添加到其列表中，在客户机断开连接后，在将相应的套接自从列表中删除，从中可以看出，客户机连接数与列表中添加套接字数目是一致的。
Vector sManager=new Vector();
sManager.add(socket);  // 向列表添加套接字
sManager.remove(socket);　　 //从列表移除套接字
sManager.size();　　//获取客户机连接数

 

客户端代码：Client４.mxml
==================================================================================

1. <?xml version="1.0" encoding="utf-8"?>
2. <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" fontSize="12" creationComplete="initApp()" width="353" height="336">
3. <mx:Script>
4.         <![CDATA[
5.        
6.                 import flash.net.Socket;
7.                 import flash.utils.ByteArray;
8.                 import flash.events.ProgressEvent;
9.                
10.                 private var socket:Socket=new Socket();
11.                 private var intClient:int;//定义客户端数字出拳
12.                 private var intServer:int; //定义服务端数字出拳
13.                 private var intSY:int;　　 //定义输赢判断
14.                 private var strClient:String;　//客户端文字出拳
15.                 private var strServer:String;　　 //服务端的文字出拳
16.                 internal function initApp():void
17.                 {
18.                         socket.connect("127.0.0.1",8888);
19.                         socket.addEventListener(Event.CONNECT,funConnect);
20.                         socket.addEventListener(Event.CLOSE,funClose);
21.                         socket.addEventListener(ProgressEvent.SOCKET_DATA,funSocket);
22.                        
23.                 }
24.                 internal function funConnect(event:Event):void
25.                 {
26.                         myText.text+="连接已建立 ";
27.                 }
28.                 internal function funClose(event:Event):void
29.                 {
30.                         myText.text+="连接已关闭 ";
31.                 }
32.                 internal function sendMessage(msg:String):void
33.                 {
34.                         var message:ByteArray=new ByteArray();
35.                         message.writeUTF(msg); //发送出拳数字
36.                         socket.writeBytes(message);
37.                         socket.flush();
38.                         intClient=int(msg);
39.                         switch(intClient)　 //将数字转换成文字用于发布到屏幕上
40.                         {
41.                                 case 0:
42.                                         strClient="剪刀";
43.                                         break;
44.                                 case 1:
45.                                         strClient="锤";
46.                                         break;
47.                                 case 2:
48.                                         strClient="包袱";
49.                                         break;
50.                         }
51.                         myText.text+="你出："+strClient+";  ";
52.                         myInput.text="";
53.                 }
54.                 internal function funSocket(event:ProgressEvent):void　　//接到服务器信息
55.                 {
56.                         var msg:String="";
57.                         while(socket.bytesAvailable)
58.                         {
59.                                 msg=socket.readUTF();
60.                                 intServer=int(msg);
61.                                 intSY=intClient-intServer;　　//通过数值判断输赢
62.                                 switch(intServer)　 //将数字转换成文字用于发布到屏幕上
63.                                 {
64.                                         case 0:
65.                                                 strServer="剪刀";
66.                                                 break;
67.                                         case 1:
68.                                                 strServer="锤";
69.                                                 break;
70.                                         case 2:
71.                                                 strServer="包袱";
72.                                                 break;
73.                                 }
74.                                 myText.text+="服务器出："+strServer+";  ";
75.                                 //判断输赢的算法
76.                                 if(intSY>0&&intSY<2)
77.                                 {
78.                                         myText.text+=" 结果:你赢了 ";
79.                                 }else if(intClient==intServer)
80.                                 {
81.                                         myText.text+=" 结果:平手 ";
82.                                 }else if(intSY<0&&intSY>-2)
83.                                 {
84.                                         myText.text+=" 结果:你输了 ";
85.                                 }else if(intSY>=2)
86.                                 {
87.                                         myText.text+=" 结果:你输了 ";
88.                                 }else if(intSY<=-2)
89.                                 {
90.                                         myText.text+=" 结果:你赢了 ";
91.                                 }
92.                                 myText.verticalScrollPosition = myText.maxVerticalScrollPosition;// myText滚动到最下面
93.                         }
94.                                
95.                 }
96.                
97.         ]]>
98. </mx:Script>
99.         <mx:TextArea x="10" y="32" width="331" height="263" id="myText"/>
100.         <mx:TextInput x="10" y="303" width="245" id="myInput"/>
101.         <mx:Button x="273" y="304" label="发送" id="myBtn" click="sendMessage(myInput.text)"/>
102.         <mx:Label x="10" y="10" text="规则：0代表剪刀；1代表锤；2代表包袱" width="331" fontWeight="bold"/>
103.        
104. </mx:Application>