Chinaunix首页 | 论坛 | 博客
  • 博客访问: 194856
  • 博文数量: 76
  • 博客积分: 2500
  • 博客等级: 少校
  • 技术积分: 490
  • 用 户 组: 普通用户
  • 注册时间: 2009-12-12 16:58
文章分类

全部博文(76)

文章存档

2011年(3)

2010年(52)

2009年(21)

我的朋友

分类:

2010-03-01 19:09:29

三)多客户通信

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

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






服务端代码:Server4.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)
                                {
                                        //向客户机传送0-2之间的整型随机数
                                                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();  //获取客户机连接数

 

客户端代码:Client4.mxml
==================================================================================

  1.        
  2.        
  3.                 import flash.net.Socket;
  4.                 import flash.utils.ByteArray;
  5.                 import flash.events.ProgressEvent;
  6.                
  7.                 private var socket:Socket=new Socket();
  8.                 private var intClient:int;//定义客户端数字出拳
  9.                 private var intServer:int; //定义服务端数字出拳
  10.                 private var intSY:int;   //定义输赢判断
  11.                 private var strClient:String; //客户端文字出拳
  12.                 private var strServer:String;   //服务端的文字出拳
  13.                 internal function initApp():void
  14.                 {
  15.                         socket.connect("127.0.0.1",8888);
  16.                         socket.addEventListener(Event.CONNECT,funConnect);
  17.                         socket.addEventListener(Event.CLOSE,funClose);
  18.                         socket.addEventListener(ProgressEvent.SOCKET_DATA,funSocket);
  19.                        
  20.                 }
  21.                 internal function funConnect(event:Event):void
  22.                 {
  23.                         myText.text+="连接已建立 ";
  24.                 }
  25.                 internal function funClose(event:Event):void
  26.                 {
  27.                         myText.text+="连接已关闭 ";
  28.                 }
  29.                 internal function sendMessage(msg:String):void
  30.                 {
  31.                         var message:ByteArray=new ByteArray();
  32.                         message.writeUTF(msg); //发送出拳数字
  33.                         socket.writeBytes(message);
  34.                         socket.flush();
  35.                         intClient=int(msg);
  36.                         switch(intClient)  //将数字转换成文字用于发布到屏幕上
  37.                         {
  38.                                 case 0:
  39.                                         strClient="剪刀";
  40.                                         break;
  41.                                 case 1:
  42.                                         strClient="锤";
  43.                                         break;
  44.                                 case 2:
  45.                                         strClient="包袱";
  46.                                         break;
  47.                         }
  48.                         myText.text+="你出:"+strClient+";  ";
  49.                         myInput.text="";
  50.                 }
  51.                 internal function funSocket(event:ProgressEvent):void  //接到服务器信息
  52.                 {
  53.                         var msg:String="";
  54.                         while(socket.bytesAvailable)
  55.                         {
  56.                                 msg=socket.readUTF();
  57.                                 intServer=int(msg);
  58.                                 intSY=intClient-intServer;  //通过数值判断输赢
  59.                                 switch(intServer)  //将数字转换成文字用于发布到屏幕上
  60.                                 {
  61.                                         case 0:
  62.                                                 strServer="剪刀";
  63.                                                 break;
  64.                                         case 1:
  65.                                                 strServer="锤";
  66.                                                 break;
  67.                                         case 2:
  68.                                                 strServer="包袱";
  69.                                                 break;
  70.                                 }
  71.                                 myText.text+="服务器出:"+strServer+";  ";
  72.                                 //判断输赢的算法
  73.                                 if(intSY>0&&intSY<2)
  74.                                 {
  75.                                         myText.text+=" 结果:你赢了 ";
  76.                                 }else if(intClient==intServer)
  77.                                 {
  78.                                         myText.text+=" 结果:平手 ";
  79.                                 }else if(intSY<0&&intSY>-2)
  80.                                 {
  81.                                         myText.text+=" 结果:你输了 ";
  82.                                 }else if(intSY>=2)
  83.                                 {
  84.                                         myText.text+=" 结果:你输了 ";
  85.                                 }else if(intSY<=-2)
  86.                                 {
  87.                                         myText.text+=" 结果:你赢了 ";
  88.                                 }
  89.                                 myText.verticalScrollPosition = myText.maxVerticalScrollPosition;// myText滚动到最下面
  90.                         }
  91.                                
  92.                 }
  93.                
  94.         ]]>
  95.        
  96.        
  97.        
  98.        
  99.        
阅读(572) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~