黑马程序员技术交流社区

标题: UDP发包接包，接收端终止问题？Why？ 有奖回答，已解决. [打印本页]
作者: 陈淑飞    时间: 2012-8-1 10:41
标题: UDP发包接包，接收端终止问题？Why？ 有奖回答，已解决.
本帖最后由 陈淑飞 于 2012-8-1 15:50 编辑

小测试代码，目的是发送端从键盘中，输入字符。接收端接到字符后转成大写。当发送端发"over"时，接受端接到打开并结束，关闭流掉。
但测试代码存在问题，while循环停不了。下面是代码：
代码一： while循环用 类静态变量FLAG控制：
  1. import java.net.*;
  2. import java.io.*;
  3. import java.util.Date;
  4. public class UdpSocketTest{
  5. public static boolean FLAG = true ;
  6. public static void main(String[] args){

  8. }
  9. }

  11. class SerSocket{
  12. public static void main(String[] args) throws Exception{
  13. DatagramSocket ds = new DatagramSocket(40009);
  14. while(UdpSocketTest.FLAG)
  15. {
  16. byte[] buf = new byte[1024];
  17. DatagramPacket dp = new DatagramPacket(buf,buf.length);
  18. ds.receive(dp);
  19. InetAddress ia = dp.getAddress();
  20. String ip = ia.getHostAddress();
  21. System.out.println(ip+"..... connected");
  22. String content = new String(dp.getData(),0,dp.getLength());
  23. content = content.toUpperCase();
  24. System.out.println("content=="+content);
  25. Thread.sleep(5000); //先暂停5秒，等if over先执行，置FLAG为false
  26. Date d = new Date();
  27. System.out.println(d.toString()+"Ser执行UdpSocketTest.FLAG==::"+UdpSocketTest.FLAG);
  28. }
  29. ds.close();
  30. }

  32. }

  34. class CliSocket{

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

  38. DatagramSocket ds = new DatagramSocket();
  39. InetAddress ia = InetAddress.getByName("127.0.0.1");
  40. BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  41. String line = null;
  42. while((line=br.readLine())!=null){
  43. byte[] buf = line.getBytes();
  44. DatagramPacket dp = new DatagramPacket(buf,buf.length,ia,40009);
  45. ds.send(dp);
  46. if("over".equals(line))
  47. {
  48. UdpSocketTest.FLAG = false;
  49. Date d = new Date();
  50. System.out.println(d.toString()+"Cli执行UdpSocketTest.FLAG==::"+UdpSocketTest.FLAG);
  51. break ;
  52. }
  53. }
  54. ds.close();
  55. br.close();

  57. }
  58. }
复制代码
代码二： while循环用 单例 Flag成员变量  控制：
  1. import java.net.*;
  2. import java.io.*;
  3. import java.util.Date;
  4. public class UdpSocketTest2{
  5. //public static boolean FLAG = true ;
  6. private static final UdpSocketTest2 ut = new UdpSocketTest2(); //郁闷，换成单例类，还是一样存在问题。
  7. private boolean flag = true ;
  8. private UdpSocketTest2(){
  9. }
  10. public static UdpSocketTest2 getInstance(){
  11. return ut ;
  12. }
  13. public void setFlag(boolean flag){
  14. this.flag = flag;
  15. }
  16. public boolean getFlag(){
  17. return flag ;
  18. }

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

  22. }
  23. }

  25. class SerSocket{
  26. public static void main(String[] args) throws Exception{
  27. DatagramSocket ds = new DatagramSocket(40009);
  28. UdpSocketTest2 ut = UdpSocketTest2.getInstance();
  29. while(ut.getFlag())
  30. {
  31. byte[] buf = new byte[1024];
  32. DatagramPacket dp = new DatagramPacket(buf,buf.length);
  33. ds.receive(dp);
  34. InetAddress ia = dp.getAddress();
  35. String ip = ia.getHostAddress();
  36. System.out.println(ip+"..... connected");
  37. String content = new String(dp.getData(),0,dp.getLength());
  38. content = content.toUpperCase();
  39. System.out.println("content=="+content);
  40. Thread.sleep(5000); //先暂停5秒，等if over先执行，置FLAG为false
  41. Date d = new Date();
  42. System.out.println(d.toString()+"Ser 执行ut.getFlag()==::"+ut.getFlag());
  43. }
  44. ds.close();
  45. }

  47. }

  49. class CliSocket{

  51. public static void main(String[] args) throws Exception{
  52. UdpSocketTest2 ut = UdpSocketTest2.getInstance();
  53. DatagramSocket ds = new DatagramSocket();
  54. InetAddress ia = InetAddress.getByName("127.0.0.1");
  55. BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  56. String line = null;
  57. while((line=br.readLine())!=null){
  58. byte[] buf = line.getBytes();
  59. DatagramPacket dp = new DatagramPacket(buf,buf.length,ia,40009);
  60. ds.send(dp);
  61. if("over".equals(line))
  62. {
  63. ut.setFlag(false);
  64. Date d = new Date();
  65. System.out.println(d.toString()+"Cli 执行ut.getFlag()==::"+ut.getFlag());
  66. break ;
  67. }
  68. }
  69. ds.close();
  70. br.close();

  72. }
  73. }
复制代码
Why？为什么循环停不了，测试结果如图：



图上，显示证明了，FLAG已经被置为flase了，为什么5秒后打印却是true呢？
用单例模式也是一样的，求解?
----
ps: 不要说在接收端也弄个over的判断，再break循环。 我就想知道，为什么以上两种方式的while循环结束不了，为什么5秒前FLAG为false，5秒后为true了。

------------
问题解决，结贴。
作者: 王峰    时间: 2012-8-1 15:16
//楼主，这两段代码我都给你修改了一下，你看我的注释吧。。。。。。。。。。
//发送代码，这个发送代码你写一个类，类名叫CliSocket
import java.net.*;
import java.io.*;
import java.util.Date;
//这里去掉public，去掉类中的main方法，
class UdpSocketTest{
public static boolean FLAG = true ;

}
//这里加上public这个为主类，。。。。。。。。。。。注意这时这个flag为true,
public class CliSocket{

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

DatagramSocket ds = new DatagramSocket();
InetAddress ia = InetAddress.getByName("127.0.0.1");
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line=br.readLine())!=null){
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf,buf.length,ia,40009);
ds.send(dp);
//这里直到你输入一个over字符串才把flag赋值成false,但是一定注意这里是发送类中的flag，与另一个类SerSocket中的flag毫无关系和联系
if("over".equals(line))
{
UdpSocketTest.FLAG = false;
Date d = new Date();
System.out.println(d.toString()+"Cli执行UdpSocketTest.FLAG==::"+UdpSocketTest.FLAG);
break ;
}
}
ds.close();
br.close();

}
}




//接受代码写成一个类，类名称叫SerSocket

import java.net.*;
import java.io.*;
import java.util.Date;
//这里去掉public，去掉类中的main方法，

class UdpSocketTest{
public static boolean FLAG = true ;

}
//这里加上public这个为主类，注意这时这个flag为true,你这里之所以一直循环，就是因为这个flag一直为true,你并没有在这个SerSocket中赋值，我给你加了一些代码，你看

public class SerSocket{
public static void main(String[] args) throws Exception{
DatagramSocket ds = new DatagramSocket(40009);
while(UdpSocketTest.FLAG)
{
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
ds.receive(dp);
InetAddress ia = dp.getAddress();
String ip = ia.getHostAddress();
System.out.println(ip+"..... connected");
String content = new String(dp.getData(),0,dp.getLength());
content = content.toUpperCase();

//这是我给你添加的代码你看看。。。。。。。。。。。。。。。。。。。
if("over".equals(content) || "OVER".equals(content)){
UdpSocketTest.FLAG = false;
}

System.out.println("content=="+content);
Thread.sleep(5000); //先暂停5秒，等if over先执行，置FLAG为false
Date d = new Date();
System.out.println(d.toString()+"Ser执行UdpSocketTest.FLAG==::"+UdpSocketTest.FLAG);
}
ds.close();
}

}

11111111111111.jpg (112.55 KB, 下载次数: 26)

增加代码前

增加代码前

222222222222222222.jpg (103.3 KB, 下载次数: 23)

修改后的执行

修改后的执行
作者: 王峰    时间: 2012-8-1 15:19
{:soso_e100:}，我已经帮你解决了，给我点分数啊，怎么样，我正在上班，抽时间给你看的，你满意吗？补充，一个类叫CliSocket.java,一个叫SerSocket.java
{:soso_e181:}
作者: 陈淑飞    时间: 2012-8-1 15:43
龙卷风V龙卷风 发表于 2012-8-1 15:19
，我已经帮你解决了，给我点分数啊，怎么样，我正在上班，抽时间给你看的，你满意吗？补充， ...
ps: 不要说在接收端也弄个over的判断，再break循环。 我就想知道，为什么以上两种方式的while循环结束不了，为什么5秒前FLAG为false，5秒后为true了


抱歉，给不了你。你的说法，我不太认可。我并不想在接收端，弄个over这样的判断。再来结束掉while循环。
这题目，我自己已经解决了。

原因：接收端与发送端都是main函数，我启动了两个命令窗口两个java，即产生了两个JVM。
两个JVM之间，数据并不是共享的。两个JVM中 UdpSocketTest.FLAG都是独立的。

在接收端main中，我并没有改变UdpSocketTest.FLAG的值，所以无论在发送端做何动作，不修改接收端代码。UdpSocketTest.FLAG永远不可以为false。
所以与UDP发包接包，根本没有关系的。
至少目前我的电脑配置及环境搭配，还不支持 云服务或集群服务。
为了证明，以上说明。特此发个简单测试代码:

import java.util.Date;
class DataTest{
        public static int d1 = 1;

}


class JVM2{
        public static void main(String[] args) throws Exception{
               
                DataTest.d1 = 2 + DataTest.d1;
                System.out.println("JVM2停止5秒再打印 DataTest.d1="+DataTest.d1);
                Thread.sleep(5000);
                Date d = new Date();
                System.out.println(d+"  JVM2-------::"+DataTest.d1);
        }

}

class JVM1{

        public static void main(String[] args){
                DataTest.d1 = 3 + DataTest.d1;
                Date d = new Date();
                System.out.println(d+"  JVM1-------::"+DataTest.d1);
        }
}

--------
先运行 JVM2，d1值为3，此时立马运行JVM1，d1的值，不为因为JVM2中值为3了，再加3.而是4.


OVER,结题。
呵呵，自己动手解决，丰衣足食。:D



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