`
hwei_344370758
  • 浏览: 20591 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

UDP socket server端

阅读更多
@Override
    public void run()
    {
        try
        {
            SocketAddress address = new InetSocketAddress(this.poolMngIp,  this.port);
            DatagramSocket socket = new DatagramSocket(address);
            while (true)
            {
                byte[] buffer = new byte[1024];
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                socket.receive(packet);
//              System.out.println(packet.getAddress().getHostAddress()+"\t"+packet.getPort());
                new Client(socket,packet).start();
            }
        }
        catch (Exception e)
        {
            throw new RuntimeException(e);
        }
    }
   
    class Client extends Thread
    {
        private DatagramSocket socket = null;
       
        private DatagramPacket packet = null;
       
        private byte[] buffer;
       
        public Client(DatagramSocket socket,DatagramPacket packet)
        {
            this.socket = socket;
            this.packet = packet;
            buffer = new byte[1024];
        }

        @Override
        public void run()
        {
            DatagramPacket returnPacket = new DatagramPacket(buffer, buffer.length,packet.getAddress(),packet.getPort());
            String returnResult = "OK";

            returnPacket.setData(returnResult.getBytes());
            socket.send(returnPacket);
        }
    }
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics