See More

--------------------------- NettyÍøÂç±à³Ì»ù´¡ | --------------------------- --------------------------- Netty-UDP·¢ËÍ | --------------------------- //´´½¨udp·þÎñ,ͨ¹ý DatagramSocet¶ÔÏó,°ó¶¨±¾»ú¶Ë¿Ú DatagramSocket ds = new DatagramSocket(8888); //È·¶¨Êý¾Ý£¬²¢·â×°³ÉÊý¾Ý°ü byte[] buf = "KevinBlandy".getBytes();//String.getBytes();°Ñ×Ö·û´®×ª»»³É×Ö½ÚÊý×é¡£ //¹¹½¨Êý¾Ý°ü,Ö¸¶¨Êý¾Ý,³¤¶È,µØÖ·,¶Ë¿Ú DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.132.245"),10000); //ͨ¹ýsocket·þÎñ½«ÒÑÓеÄÊý¾Ý°üͨ¹ý send·½·¨¡£·¢ËͳöÈ¥¡£ ds.send(dp);//×èÈûʽ·½·¨¡£Èç¹ûûÊý¾Ý¾Í»áÒ»Ö±µÈ(Ï̻߳úÖÆ)¡£ //¹Ø±Õ×ÊÔ´ ds.close(); /* ´ÓÖ¸¶¨¶Ë¿Ú·¢ËÍÊý¾Ý,ÄÄŸö˿ÚÒѾ­±»¼àÌý(¶Ë¿ÚÖØÓÃ) */ DatagramSocket socket = new DatagramSocket(null); //¸ÃÖµÓ¦¸ÃÉèÖÃΪnull socket.setReuseAddress(true); //¸ÃÖµÓ¦¸ÃΪtrue socket.bind(new InetSocketAddress(1024)); //°ó¶¨Òª´Ó±¾µØµÄÄĸö¶Ë¿Ú·¢ËÍ byte[] bytes = hexStringToBytes(message); DatagramPacket p = new DatagramPacket(bytes, 0, bytes.length, new InetSocketAddress(ip, Integer.parseInt(port))); socket.send(p); --------------------------- Netty-UDP½ÓÊÕ | --------------------------- //´´½¨udpsocket·þÎñ.½¨Á¢¶Ëµã,¼àÌý¶Ë¿Ú DatagramSocket ds = new DatagramSocket(10000); while(true){ //¶¨ÒåÊý¾Ý°ü£¬ÓÃÓÚ´æ´¢Êý¾Ý byte[] buf = new byte[1024];//»º³åÇø DatagramPacket dp = new DatagramPacket(buf,buf.length); //ͨ¹ýsocket·þÎñreceive·½·¨½«ÊÕµ½µÄÊý¾Ý´æÈëÊý¾Ý°üÖÐ(×èÈû·½·¨) ds.receive(dp); //ͨ¹ýÊý¾Ý°üµÄ·½·¨»ñÈ¡ÆäÖеÄÊý¾Ý String ip = dp.getAddress().getHostAddress(); //»ñÈ¡IP¡£ String data = new String(dp.getData(),0,dp.getLength());//»ñÈ¡Êý¾Ý¡£ int port = dp.getPort(); //»ñÈ¡¶Ë¿Ú¡£ System.out.println(ip+"::"+data+"::"+port); //ds.close(); ¹Ø±Õ×ÊÔ´ } --------------------------- Netty-TCP·¢ËÍ | --------------------------- Socket s = new Socket("120.76.182.243",8080); OutputStream os = s.getOutputStream(); //´ËÊä³öÁ÷ÊÇ OutputStream();ÊdzéÏóµÄ¡£ InputStream is = s.getInputStream(); //´ËÊäÈëÁ÷ÊÇ InputStream();ÊdzéÏóµÄ¡£ --------------------------- Netty-TCP½ÓÊÕ | --------------------------- ServerSocket ss = new ServerSocket(8888); while(true){ Socket s = ss.accept(); //Ïß³Ì×èÈû InputStream is = s.getInputStream(); //»ñÈ¡ InputStream OutputStream os = s.getOutputStream(); //»ñÈ¡ OutputStream }