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

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

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第32,33,34,35届Android交流区 › 正文

为什么结束标记不能结束发送端

© NO? 中级黑马   /  2014-4-9 10:08  /  889 人查看  /  5 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

  1. package jichu;

  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;
  9. import java.net.SocketException;
  10. import java.net.UnknownHostException;

  12. public class Tests {
  13.         public static void main(String[] args) {
  14.                 new Thread(new Runnable() {
  15.                         public void run() {
  16.                                 new Rec().recive();

  18.                         }
  19.                 }).start();
  20.                 new Thread(new Runnable() {
  21.                         public void run() {
  22.                                 new Send().send();

  24.                         }
  25.                 }).start();
  26.         }
  27. }

  29. class Send {
  30.         public static void send() {
  31.                 DatagramSocket dSocket = null;
  32.                 BufferedReader bReader = new BufferedReader(new InputStreamReader(
  33.                                 System.in));
  34.                 while (true) {
  35.                         try {
  36.                                 dSocket = new DatagramSocket();
  37.                         } catch (SocketException e) {
  38.                                 e.printStackTrace();
  39.                         }
  40.                         String string = null;
  41.                         DatagramPacket dPacket = null;
  42.                         try {
  43.                                 string = bReader.readLine();
  44.                         } catch (IOException e) {
  45.                                 e.printStackTrace();
  46.                         }

  48.                         byte[] buf = string.getBytes();
  49.                         try {
  50.                                 dPacket = new DatagramPacket(buf, 0, buf.length,
  51.                                                 InetAddress.getLocalHost(), 10002);
  52.                         } catch (UnknownHostException e) {
  53.                                 e.printStackTrace();
  54.                         }
  55.                         try {
  56.                                 dSocket.send(dPacket);
  57.                         } catch (IOException e) {
  58.                                 e.printStackTrace();
  59.                         }
  60.                         if (string.equals("over")) {
  61.                                 break;
  62.                         }
  63.                 }
  64.                 dSocket.close();
  65.                 try {
  66.                         bReader.close();
  67.                 } catch (IOException e) {
  68.                         e.printStackTrace();
  69.                 }
  70.         }
  71. }

  73. class Rec {

  75.         public static void recive() {
  76.                 String string = null;
  77.                 DatagramSocket dSocket = null;
  78.                 try {
  79.                         dSocket = new DatagramSocket(10002);
  80.                 } catch (SocketException e1) {
  81.                         e1.printStackTrace();
  82.                 }
  83.                 DatagramPacket dPacket = null;
  84.                 while (true) {

  86.                         byte[] buf = new byte[1024];
  87.                         dPacket = new DatagramPacket(buf, 0, buf.length);
  88.                         try {
  89.                                 dSocket.receive(dPacket);
  90.                         } catch (IOException e) {
  91.                                 e.printStackTrace();
  92.                         }
  93.                         byte[] by = dPacket.getData();
  94.                         string = new String(by, 0, by.length);
  95.                         System.out.println(string);
  96.                         if (string.equals("over")) {
  97.                                 break;
  98.                         }
  99.                 }
  100.                 dSocket.close();
  101.         }
  102. }
复制代码

请各位大侠看看。。。。帮帮忙。谢谢

评分

参与人数 1技术分 +1 收起 理由
菜小徐 + 1

查看全部评分

5 个回复

倒序浏览
tiuwing 中级黑马 2014-4-9 22:01:06
| 只看该作者
沙发
你在接收端中设置的缓冲区：byte[] buf = new byte[1024];  
调用byte[] by = dPacket.getData(); 读取的数据也是1024字节，所以下边string = new String(by, 0, by.length);的string后边有很空字符，可以在比较之前调用下string.trim()函数。

评分

参与人数 1技术分 +1 收起 理由
itpower + 1

查看全部评分

回复 使用道具 举报
NO? 中级黑马 2014-4-10 00:14:24
| 只看该作者
藤椅
tiuwing 发表于 2014-4-9 22:01
你在接收端中设置的缓冲区：byte[] buf = new byte[1024];  
调用byte[] by = dPacket.getData(); 读取的数 ...

谢谢。可是咱么说的不是一码事
回复 使用道具 举报
duanyoujiji 中级黑马 2014-4-10 08:37:20
| 只看该作者
板凳
eclipse？你看看是不是这种情况：演示的时候没display吧？我记得刚开始演示的时候就是跑到receive端输入，然后即使标记也停止不了 后来找了半天，结果是没切换窗口！。！
回复 使用道具 举报
leon_hm 中级黑马 2014-4-10 08:48:46
| 只看该作者
报纸
  1. //package jichu;

  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;
  9. import java.net.SocketException;
  10. import java.net.UnknownHostException;

  12. class Tests {
  13.         public static void main(String[] args) {
  14.                 new Thread(new Runnable() {
  15.                         public void run() {
  16.                                 new Rec().recive();

  18.                         }
  19.                 }).start();
  20.                 new Thread(new Runnable() {
  21.                         public void run() {
  22.                                 new Send().send();

  24.                         }
  25.                 }).start();
  26.         }
  27. }

  29. class Send {
  30.         public static void send() {
  31.                 DatagramSocket dSocket = null;
  32.                 BufferedReader bReader = new BufferedReader(new InputStreamReader(
  33.                                 System.in));
  34.                 while (true) {
  35.                         try {
  36.                                 dSocket = new DatagramSocket();
  37.                         } catch (SocketException e) {
  38.                                 e.printStackTrace();
  39.                         }
  40.                         String string = null;
  41.                         DatagramPacket dPacket = null;
  42.                         try {
  43.                                 string = bReader.readLine();
  44.                         } catch (IOException e) {
  45.                                 e.printStackTrace();
  46.                         }

  48.                         byte[] buf = string.getBytes();
  49.                         try {
  50.                                 dPacket = new DatagramPacket(buf, 0, buf.length,
  51.                                                 InetAddress.getLocalHost(), 10002);
  52.                         } catch (UnknownHostException e) {
  53.                                 e.printStackTrace();
  54.                         }
  55.                         try {
  56.                                 dSocket.send(dPacket);
  57.                         } catch (IOException e) {
  58.                                 e.printStackTrace();
  59.                         }
  60.                         if (string.equals("over")) {
  61.                                 break;
  62.                         }
  63.                 }
  64.                 dSocket.close();
  65.                 try {
  66.                         bReader.close();
  67.                 } catch (IOException e) {
  68.                         e.printStackTrace();
  69.                 }
  70.         }
  71. }

  73. class Rec {

  75.         public static void recive() {
  76.                 String string = null;
  77.                 DatagramSocket dSocket = null;
  78.                 try {
  79.                         dSocket = new DatagramSocket(10002);
  80.                 } catch (SocketException e1) {
  81.                         e1.printStackTrace();
  82.                 }
  83.                 DatagramPacket dPacket = null;
  84.                 while (true) {

  86.                         byte[] buf = new byte[1024];
  87.                         dPacket = new DatagramPacket(buf, 0, buf.length);
  88.                         try {
  89.                                 dSocket.receive(dPacket);
  90.                         } catch (IOException e) {
  91.                                 e.printStackTrace();
  92.                         }
  93.                         byte[] by = dPacket.getData();
  94.                         //string = new String(by, 0, by.length);
  95.                                                 string=new String(dPacket.getData(),0,dPacket.getLength());
  96.                                                 System.out.println("receive:"+string);
  97.                         if (string.equals("over")) {
  98.                                 break;
  99.                         }
  100.                 }
  101.                 dSocket.close();
  102.         }
  103. }
复制代码
我的运行结果如下：


回复 使用道具 举报
tiuwing 中级黑马 2014-4-11 11:57:22
| 只看该作者
地板
NO? 发表于 2014-4-10 00:14
谢谢。可是咱么说的不是一码事

不是吗？不然你说的是啥？我copy你那代码执行了，输入over是不结束啊，照我那个改下，输入了就结束啦！！
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马