黑马程序员技术交流社区

标题: 网络编程的问题 [打印本页]
作者: 陈洋    时间: 2013-9-24 00:18
标题: 网络编程的问题
本帖最后由 陈洋 于 2013-9-24 10:09 编辑
  1. package cn.itcast.UDP;

  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.net.DatagramPacket;
  7. import java.net.DatagramSocket;
  8. import java.net.InetAddress;

  10. class S implements Runnable{

  12.         @Override
  13.         public void run() {
  14.                 try {
  15.                         
  16.                         DatagramSocket ds = new DatagramSocket(88);
  17.                         BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  18.                         
  19.                         String str=null;
  20.                         while((str=br.readLine())!=null){
  21.                                 byte[] buf = str.getBytes();
  22.                                 DatagramPacket dp = new DatagramPacket(
  23.                                                                                 buf,buf.length,InetAddress.getByName("192.168.1.101"),10005);
  24.                                 ds.send(dp);
  25.                         }
  26.                         
  27.                         ds.close();        
  28.                 } catch (Exception e) {
  29.                         // TODO Auto-generated catch block
  30.                         e.printStackTrace();
  31.                 }
  32.                         
  33.                
  34.         }

  36. }


  39. class R implements Runnable{

  41.         @Override
  42.         public void run() {
  43.                 try{
  44.                         
  45.                         DatagramSocket ds = new DatagramSocket(10005);
  46.                         while(true){
  47.                                 byte[] by = new byte[10];
  48.                                 DatagramPacket dp = new DatagramPacket(by, by.length);
  49.                                 ds.receive(dp);
  50.                                 
  51.                                 System.out.println(new String(dp.getData(),0,by.length));
  52.                         }
  53.                         ds.close();//这里怎么关闭不了，报错。
  54.                 }catch(Exception e){}

  56.         }
  57. }

  59. public class UDP2{

  61.         public static void main(String[] args) {

  63.                 new Thread(new S()).start();
  64.                 new Thread(new R()).start();
  65.                
  66.         }
  67. }
复制代码
问题在注释处
作者: 李锡碧    时间: 2013-9-24 00:32
while（true）｛｝......后面的执行不到了，，，
作者: 陈洋    时间: 2013-9-24 00:38
李锡碧 发表于 2013-9-24 00:32
while（true）｛｝......后面的执行不到了，，，

不是这个问题，去掉循环也报错。
作者: 陈国柱    时间: 2013-9-24 10:19
有while循环，那里根本关闭不了，所以后面的close（）语句是到达不了的，改动了一下
  1. package cn.itcast.UDP;


  4. import java.io.BufferedReader;
  5. import java.io.IOException;
  6. import java.io.InputStreamReader;
  7. import java.net.DatagramPacket;
  8. import java.net.DatagramSocket;
  9. import java.net.InetAddress;

  11. class S implements Runnable{
  12.         private DatagramSocket ds;
  13.         public S(DatagramSocket ds){//弄一个构造方法，传入DataGramSocket
  14.                 this.ds = ds;
  15.         }
  16.        

  18.         @Override
  19.         public void run() {
  20.                 try {
  21.                         
  22.                         BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  23.                         
  24.                         String str=null;
  25.                         while((str=br.readLine())!=null){
  26.                                 byte[] buf = str.getBytes();
  27.                                 DatagramPacket dp = new DatagramPacket(
  28.                                                                                 buf,buf.length,InetAddress.getByName("localhost"),10005);
  29.                                 ds.send(dp);
  30.                         }
  31.                         
  32.                         ds.close();        
  33.                 } catch (Exception e) {
  34.                         // TODO Auto-generated catch block
  35.                         e.printStackTrace();
  36.                 }
  37.                         
  38.                
  39.         }

  41. }


  44. class R implements Runnable{
  45.         private DatagramSocket ds;

  47.         public R( DatagramSocket ds){//弄一个构造方法，传入DataGramSocket
  48.                 this.ds = ds;
  49.         }

  51.         @Override
  52.         public void run() {
  53.                 try{
  54.                         
  55.                         while(true){
  56.                                 byte[] by = new byte[10];
  57.                                 DatagramPacket dp = new DatagramPacket(by, by.length);
  58.                                 ds.receive(dp);
  59.                                 
  60.                                 System.out.println(new String(dp.getData(),0,by.length));
  61.                         }
  62. //                        ds.close();//这里怎么关闭不了，报错。有while循环，这里就读不到：Unreachable code，
  63.                                                 //去掉while之后，我觉等应该是关闭了，因为只有发送端在发数据，而没有接收端接收数据了
  64.                 }catch(Exception e){}

  66.         }
  67. }

  69. public class UDP2{

  71.         public static void main(String[] args)throws Exception {

  73.                 new Thread(new S(new DatagramSocket())).start();
  74.                 new Thread(new R(new DatagramSocket(10005))).start();//接收端要知道端口
  75.                
  76.         }
  77. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2