A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第19届Android交流区 › 正文

关于网络编程的问题

© ぺsimon☆ 中级黑马   /  2013-5-6 16:36  /  1497 人查看  /  3 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

  1. /*
  2. 这是一个聊天程序
  3. */

  5. import java.io.*;
  6. import java.net.*;

  8. class UdpSend2 implements Runnable
  9. {
  10.         private DatagramSocket dgs;
  11.         UdpSend2(DatagramSocket dgs)
  12.         {
  13.         this.dgs=dgs;
  14.         }

  16.         public void run()
  17.         {
  18.         try
  19.         {
  20.         //键盘录入
  21.         BufferedReader bur=new BufferedReader(new InputStreamReader

  23. (System.in));

  25.         String line=null;
  26.         //读取键盘的数据
  27.         while((line=bur.readLine())!=null)
  28.         {
  29.         if("886".equals(line)) //判断结束标记
  30.         break;
  31.         byte[] buf=line.getBytes();//把字符串转为字节数组
  32.        
  33.         //定义一个数据包,并把数据存储在包中
  34.         DatagramPacket dgp=new DatagramPacket

  36. (buf,buf.length,InetAddress.getByName("169.254.0.254"),1003);

  38.         dgs.send(dgp);//把数据包发送到指定的端口

  40.         }
  41.         dgs.close();//关闭资源
  42.         }
  43.         catch(Exception e)
  44.         {
  45.         throw new RuntimeException("发送失败");
  46.         }
  47.         }
  48. }

  50. class UdpRece2 implements Runnable
  51. {
  52.         private DatagramSocket dgs;
  53.         UdpRece2(DatagramSocket dgs)
  54.         {
  55.         this.dgs=dgs;
  56.         }

  58.         public void run()
  59.         {
  60.         while(true)
  61.         {
  62.         try
  63.         {
  64.         byte[] buf=new byte[1024];//定义数组
  65.         //定义一个数据包
  66.         DatagramPacket dgp=new DatagramPacket(buf,buf.length);

  68.         dgs.receive(dgp);//接受端口发来的数据,存储在dgp包中,阻塞式语句

  70.         String ip=dgp.getAddress().getHostAddress();//得到数据的ip地址
  71.         //得到数据包中的内容
  72.         String data=new String(dgp.getData(),dgp.getLength());
  73.         //得到数据包的端口
  74.         int port=dgp.getPort();

  76.         System.out.println("ip:"+ip+"..."+"data:"+data+"port:"+port);
  77.         }

  79.         catch(Exception e)
  80.         {
  81.         throw new RuntimeException("接受信息失败");
  82.         }
  83.         }
  84.         }
  85. }

  87. class UdpDemo
  88. {
  89.         public static void main(String[] args)throws Exception
  90.         {
  91.         DatagramSocket send=new DatagramSocket();
  92.         DatagramSocket rece=new DatagramSocket(1003);//指定端口

  94.         UdpSend2 usend=new UdpSend2(send);
  95.         UdpRece2 urece=new UdpRece2(rece);
  96.         //开启线程
  97.         new Thread(usend).start();
  98.         new Thread(urece).start();
  99.         }
  100. }

  102. /*
  103. 谢谢各位兄弟
  104. 错误提示:
  105. E:\Java\jdk1.6.0_23\experience_heima\23>javac UdpDemo.java
  106. 注意：UdpDemo.java 使用或覆盖了已过时的 API。
  107. 注意：要了解详细信息，请使用 -Xlint:deprecation 重新编译。
  108. */
复制代码

评分

参与人数 1技术分 +1 收起 理由
黄玉昆 + 1

查看全部评分

网络编程的

3 个回复

倒序浏览
HM朱蛟 高级黑马 2013-5-7 00:17:42
| 只看该作者
沙发
本帖最后由 HM朱蛟 于 2013-5-7 00:25 编辑



2个问题
1:
72行 改成  String data=new String(dgp.getData(),dgp.0,getLength());
2:
try 的作用域应该涵盖while语句

评分

参与人数 1技术分 +1 收起 理由
黄玉昆 + 1

查看全部评分

回复 使用道具 举报
孙金鑫 中级黑马 2013-5-7 00:41:32
| 只看该作者
藤椅
本帖最后由 孙金鑫 于 2013-5-7 00:43 编辑

  2. <DIV class=blockcode>
  3. <BLOCKQUOTE>/*
  4. 这是一个聊天程序
  5. */

  7. import java.io.*;
  8. import java.net.*;

  10. class UdpSend2 implements Runnable
  11. {
  12. private DatagramSocket dgs;
  13. UdpSend2(DatagramSocket dgs)
  14. {
  15. this.dgs=dgs;
  16. }

  18. public void run()
  19. {
  20. try
  21. {
  22. //键盘录入
  23. BufferedReader bur=new BufferedReader(new InputStreamReader(System.in));

  25. String line=null;
  26. //读取键盘的数据
  27. while((line=bur.readLine())!=null)
  28. {
  29. if("886".equals(line)) //判断结束标记
  30. break;
  31. byte[] buf=line.getBytes();//把字符串转为字节数组

  33. //定义一个数据包,并把数据存储在包中
  34. DatagramPacket dgp=new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.0.102"),10003);

  36. dgs.send(dgp);//把数据包发送到指定的端口

  38. }
  39. // dgs.close();//关闭资源
  40. }
  41. catch(Exception e)
  42. {
  43. throw new RuntimeException("发送失败");
  44. }
  45. }
  46. }

  48. class UdpRece2 implements Runnable
  49. {
  50. private DatagramSocket dgs;
  51. UdpRece2(DatagramSocket dgs)
  52. {
  53. this.dgs=dgs;
  54. }

  56. public void run()
  57. {
  58. while(true)
  59. {
  60. try
  61. {
  62. byte[] buf=new byte[1024];//定义数组
  63. //定义一个数据包
  64. DatagramPacket dgp=new DatagramPacket(buf,buf.length);

  66. dgs.receive(dgp);//接受端口发来的数据,存储在dgp包中,阻塞式语句

  68. String ip=dgp.getAddress().getHostAddress();//得到数据的ip地址
  69. //得到数据包中的内容
  70. String data=new String(dgp.getData(),0,dgp.getLength()); //注意这里！！！！！！！你少了一个0……
  71. //得到数据包的端口
  72. int port=dgp.getPort();

  74. System.out.println("ip:"+ip+"..."+"data:"+data+"port:"+port);
  75. }

  77. catch(Exception e)
  78. {
  79. throw new RuntimeException("接受信息失败");
  80. }
  81. }
  82. }
  83. }

  85. class UdpDemo
  86. {
  87. public static void main(String[] args)throws Exception
  88. {
  89. DatagramSocket send=new DatagramSocket();
  90. DatagramSocket rece=new DatagramSocket(10003);//指定端口

  92. UdpSend2 usend=new UdpSend2(send);
  93. UdpRece2 urece=new UdpRece2(rece);
  94. //开启线程
  95. new Thread(usend).start();
  96. new Thread(urece).start();
  97. }
  98. }


  101. /*
  102. 换了下IP地址，自己改回来，注意下70行
  103. */
复制代码

评分

参与人数 1技术分 +1 收起 理由
黄玉昆 + 1

查看全部评分

回复 使用道具 举报
黄玉昆 黑马帝 2013-5-8 21:10:43
| 只看该作者
板凳
如果问题未解决，请继续追问，如果问题解决了，请将分类改为“已解决”，谢谢
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马