作者:gaoyong0713 | 来源:互联网 | 2023-06-28 13:42
一朋友问java服务端如果解决这个问题,上次只是给出了解决这个问题的Delphi代码。flash客户端在网站上运行的时候,先进行Socket连接,然后发“<policy-file-reque
一朋友问java服务端如果解决这个问题,上次只是给出了解决这个问题的Delphi代码。
flash客户端在网站上运行的时候,先进行Socket连接,然后发“”信息,即安全策略请求,如果没有通过安全策略的检验,socket时连接不成功.
如果安全策略的检验通过了,socket也会先断开,然后在连接一次,这个时候一切正常了。
现在给出java和C#的代码
- import java.net.*;
- import java.io.*;
- import java.util.*;
- public class JavaServer {
- private static final int PORT = 8014;
- private ServerSocket server;
- private BManager bMan=new BManager();
- Map clientList = new HashMap();
- public JavaServer(){}
- void startServer()
- {
- String xml = "";
- xml = xml + "";
- xml = xml + "";
- xml = xml + "";
- try {
- server=new ServerSocket(PORT);
- System.out.println("服务器侦听:"+PORT);
- while(true)
- {
- try
- {
-
- Socket socket = server.accept();
- System.out.println("连接成功......");
- BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf8"));
- PrintWriter pw = new PrintWriter(socket.getOutputStream());
-
- char[] by = new char[22];
- br.read(by,0,22);
- String head = new String(by);
- System.out.println("消息头:" + head + ":");
- if(head.equals(""))//判断是不是安全策略请求
- {
- pw.print(xml + "/0");
- pw.flush();
- System.out.println("策略:" + xml + "/0");
- }
- else
- {
-
-
- Chat_Thread thread = new Chat_Thread(socket);
- thread.start();
- bMan.add(socket);
- bMan.sendClientInfo();
- String cmd=head.substring(0, 2);
- int a=Integer.parseInt(cmd);
- if (a==11)
- {
- String strName=head.substring(2).trim();
- System.out.println(strName+"登陆了");
- bMan.sendToAll("22"+strName+"登陆了");
- clientList.put(socket,strName);
- funList(clientList);
- }
-
- }
- }
- catch (Exception e)
- {
- System.out.println("服务器出现异常!" + e );
- }
- }
- }catch(Exception e){
- System.out.println(e);
- }
- }
-
- public static void main(String[] args) {
- JavaServer server=new JavaServer();
- server.startServer();
- }
- class Chat_Thread extends Thread
- {
- Socket socket;
- private BufferedReader reader;
- private PrintWriter writer;
- Chat_Thread(Socket socket)
- {
- this.socket=socket;
- }
- public void run()
- {
-
- try
- {
- reader=new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf8"));
- writer=new PrintWriter(socket.getOutputStream(),true);
- String msg;
- while((msg=reader.readLine())!=null)
- {
- System.out.println("get:"+msg);
- String str=msg.substring(0, 2);
- int a=Integer.parseInt(str);
- String[] arrMsg=msg.split("--");
- switch(a)
- {
- case 11 :
- String strName=msg.substring(2);
- System.out.println(strName+"登陆了");
- bMan.sendToAll("22"+strName+"登陆了");
- clientList.put(this.socket,strName);
- funList(clientList);
- break;
- case 22:
- System.out.println("公聊");
- msg=arrMsg[0]+arrMsg[1]+"说:"+arrMsg[2];
- bMan.sendToAll(msg);
- break;
- case 33:
- if(arrMsg[1].equals("所有人"))
- {
- msg=arrMsg[2]+"说:"+arrMsg[3];
- bMan.sendToAll("22"+msg);
- }else
- {
- Socket socketOne=new Socket();
- System.out.println("私聊");
- Set set = clientList.keySet();
- Iterator it = set.iterator();
- while (it.hasNext()) {
- Object ok=it.next();
- Object ov=clientList.get(ok);
- if(ov.equals(arrMsg[1]))
- {
- socketOne=(Socket)ok;
- bMan.sendToONE(socketOne,"22(悄悄话)"+arrMsg[2]+"对你说:"+arrMsg[3]);
- }else if(ov.equals(arrMsg[2]))
- {
- socketOne=(Socket)ok;
- bMan.sendToONE(socketOne,"22(悄悄话)你对"+arrMsg[1]+"说:"+arrMsg[3]);
- }
- }
- }
-
- break;
- }
-
- }
- }catch(Exception e)
- {
-
- }finally
- {
- try {
- bMan.remove(socket);
- if(reader !=null) reader.close();
- if(writer !=null) writer.close();
- if(socket !=null) socket.close();
- if(clientList.containsKey(socket))
- {
- bMan.sendToAll("22"+clientList.get(socket)+"离开了...");
- clientList.remove(socket);
- funList(clientList);
-
- }
- reader=null;
- writer=null;
- socket=null;
- System.out.println("客户机离开");
- bMan.sendClientInfo();
- } catch (Exception e) {}
- }
-
- }
- }
- void funList(Map clientList)
- {
- String strList="";
- Set set = clientList.keySet();
- System.out.println(set);
- Iterator it = set.iterator();
- System.out.println(it);
- while (it.hasNext()) {
- strList+="--";
- strList+=clientList.get(it.next());
- }
- bMan.sendToAll("11"+strList);
- }
- }
- class BManager extends Vector
- {
- BManager (){}
- void add(Socket sock)
- {
- super.add(sock);
- }
- void remove(Socket sock)
- {
- super.remove(sock);
- }
- synchronized void sendToAll(String msg)
- {
- PrintWriter writer=null;
- Socket sock;
- for(int i=0;i
- {
- sock=(Socket)elementAt(i);
- try
- {
- writer=new PrintWriter(sock.getOutputStream(),true);
- }catch(Exception ie){}
- if(writer!=null)writer.println(msg);
- }
- }
- synchronized void sendToONE(Socket socket,String msg)
- {
- PrintWriter writer=null;
- Socket sock;
- for(int i=0;i
- {
- sock=(Socket)elementAt(i);
- if(socket==sock)
- {
-
- try
- {
- writer=new PrintWriter(sock.getOutputStream(),true);
- }catch(Exception ie){}
- if(writer!=null)writer.println(msg);
- }
- }
-
- }
- synchronized void sendClientInfo()
- {
- String info="44当前聊天人数:"+size();
- System.out.println(info);
- sendToAll(info);
- }
- }
C#代码,Delphi代码
请到http://download.csdn.net/wind520下载