Flex通信-与Java实现Socket通信实例

• 实例效果

 Java控制台：

 

• 注意事项

• Java Socket服务器

      public class SocketUtil {
	
	/**
	 * 创建ServerSocket
	 * @param port
	 * @return
	 */
	public static ServerSocket getServerSocket(int port){
		ServerSocket server = null;
		try {
			server = new ServerSocket(port);
			System.out.println("------ServerSocket创建成功，Port:"+port);
			return server;
		} catch (IOException e) {
			if(server!=null && !server.isClosed()){
				try {
					server.close();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
			throw new RuntimeException("创建ServerSocket时发生异常，Port:"+port,e);
		}
	}
	
	/**
	 * 获取Socket
	 * @param server
	 * @return
	 */
	public static Socket getSocket(ServerSocket server){
		Socket socket = null;
		try {
			socket = server.accept();
			System.out.println("------Socket连接成功，IP:"+socket.getInetAddress());
			return socket;
		} catch (IOException e) {
			if(socket!=null && !socket.isClosed()){
				try {
					socket.close();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
			throw new RuntimeException("创建Socket时发送异常",e);
		}
	}
	
}
    

      public class SocketThread implements Runnable {
	private Socket socket;
	private String encoding;
	
	public SocketThread(Socket socket,String encoding) {
		this.socket = socket;
		this.encoding = encoding;
	}
	
	/**
	 * 与客户端交互代码
	 */
	@Override
	public void run() {
		try {
			BufferedReader br = new BufferedReader(new InputStreamReader(socket
					.getInputStream(), encoding));
			BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
					socket.getOutputStream(), encoding));
			
			String getMsg;
			while ((getMsg = br.readLine()) != null && !"exit".equalsIgnoreCase(getMsg)) {
				// 客户端未提出"exit"命令，则循环交流
				System.out.println("From client message:" + getMsg);
				bw.append("你好[" + socket.getInetAddress() + "],服务器收到你的信息："
						+ getMsg + "\r\n");
				bw.flush();
			}
			
			//客户端提出"exit"请求，关闭当前socket...
			br.close();
			bw.close();
			socket.close();
			System.out.println("当前Socket连接结束......");
		} catch (Exception e) {
			if(!socket.isClosed()){
				try {
					socket.close();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
			throw new RuntimeException("Socket线程类发送异常...",e);
		}
	}
}
    

      public class SocketServer implements Runnable {
	private int port = 10086;
	private boolean status = true;
	private ServerSocket server = null;
	
	@Override
	public void run() {
		//创建Socket服务器
		server = SocketUtil.getServerSocket(port);
		while(status){
			Socket socket = SocketUtil.getSocket(server);
			new Thread(new SocketThread(socket,"UTF-8")).start();
		}
	}
	
	/**
	 * 启动服务器
	 */
	public void startSocket(){
		new Thread(this).start();
	}
	
	/**
	 * 关闭服务器
	 */
	public void stopSocket(){
		status = false;
		if(server!=null && !server.isClosed()){
			try {
				server.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

    

• 安全沙箱

      /**
 * 处理与Flex认证的线程类
 * @author Administrator
 */
public class PolicyThread implements Runnable {
	private final String policy_xml = "<policy-file-request/>";
	private final String cross_xml = "<?xml version=\"1.0\"?><cross-domain-policy><site-control permitted-cross-domain-policies=\"all\"/><allow-access-from domain=\"*\" to-ports=\"*\"/></cross-domain-policy>\0";
	private Socket socket;
	
	public PolicyThread(Socket socket){
		this.socket = socket;
	}
	
	@Override
	public void run() {
		try {
			//接收并发送Flex安全验证请求
			BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			PrintWriter pw = new PrintWriter(socket.getOutputStream());
			char[] by = new char[22];
			br.read(by, 0, 22);
			String s = new String(by);
			if(s.equals(policy_xml)){
				System.out.println("接收policy-file-request认证");
				pw.print(cross_xml);
				pw.flush();
				br.close();
				pw.close();
				socket.close();
				System.out.println("完成policy-file-request认证");
			}
		} catch (IOException e) {
			if(!socket.isClosed()){
				try {
					socket.close();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
			throw new RuntimeException("执行policy认证时发生异常",e);
		}
	}

}

    

      public class PolicyServer implements Runnable{
	
	private final int policy_port = 843;
	private boolean status = true;
	
	private ServerSocket server = null;
	@Override
	public void run() {
		//创建安全验证服务器
		server = SocketUtil.getServerSocket(policy_port);
		
		while(status){
			Socket socket = SocketUtil.getSocket(server);
			new Thread(new PolicyThread(socket)).start();
		}
	}
	
	
	/**
	 * 启动服务器
	 */
	public void startPolicy(){
		new Thread(this).start();
	}
	
	/**
	 * 关闭服务器
	 */
	public void stopPolicy(){
		status = false;
		if(server!=null && !server.isClosed()){
			try {
				server.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

    

• Servlet启动ServerSocket

        public class InitServers extends HttpServlet {
	private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public InitServers() {
        super();
    }

	/**
	 * @see Servlet#init(ServletConfig)
	 */
	public void init(ServletConfig config) throws ServletException {
		new PolicyServer().startPolicy();
		new SocketServer().startSocket();
	}

	/**
	 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub
	}

	/**
	 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub
	}

}

      

      <servlet>
		<display-name>InitServers</display-name>
		<servlet-name>InitServers</servlet-name>
		<servlet-class>socket.InitServers</servlet-class>
		<load-on-startup>1</load-on-startup>
	</servlet>