UDP协议的聊天程序，使用两个线程分别发生和接收,却出错...

韦念欣

本帖最后由张世威于 2012-7-17 12:05 编辑

   1、我用DatagramSocket写的聊天程序，用两个线程分别发送和接收数据，
            ①发生端：从控制台输入数据，每输入一行，便将数据发生出去
            ②接收端：监听端口，接收数据，并输出：发生端的ip和接收的数据

   2、在Eclipse里面，我输入数据，收到的数据却只有ip地址，没有数据部分，有时候还出现乱码，如下图。
           ①写几个英文字母的时候：就只会出来 127.0.0.1:

②写汉字的是，好像能完全出来：127.0.0.1：张三

      3、这真是奇了怪了，我还以为是用线程，两个线程之间互掐。于是我便在代码里面都添加了
            发送一次数据，线程休息一秒;接收一个数据，也休息一秒，还是这个模样，坑爹了。。

   4、代码：麻烦帮忙看看

package day23;
import java.io.*;
import java.net.*;
//1发送线程类
class Send implements Runnable {
private DatagramSocket ds;
private InetAddress ip;
private int port;
public Send(DatagramSocket ds,InetAddress ip,int port) {
this.ds = ds;
this.ip=ip;
this.port=port;
}
@Override
public void run() {
SendAndRece sr = new SendAndRece();
sr.send(ds,ip,port);
}
}
// 2接收线程类
class Rece implements Runnable {
private DatagramSocket ds;
public Rece(DatagramSocket ds) {
this.ds = ds;
}
@Override
public void run() {
SendAndRece sr = new SendAndRece();
sr.rece(ds);
}
}
// 4主调程序
public class ChatDemo {
/**
* @param args
*/
public static void main(String[] args) {
// ①发送的DatagramSocket,加上端口
try {
//目的地址和端口号
InetAddress ip = InetAddress.getByName("127.0.0.1");
int port=10001;
DatagramSocket dss = new DatagramSocket();
new Thread(new Send(dss,ip,port)).start();
// ②接收端DatagramSocket,加上端口
DatagramSocket dsr=new DatagramSocket(10001);
new Thread(new Rece(dsr)).start();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
// 3业务类:定义一个类，两方法：发送和接收
class SendAndRece {
// ①发送业务：发送udpsocket+目的地ip+目的端口
public void send(DatagramSocket ds, InetAddress ip,int port) {
try {
// 从键盘录入数据
BufferedReader bufr = new BufferedReader(new InputStreamReader(
System.in));
// 循环往bufr里面如
String line = null;
while ((line = bufr.readLine()) != null) {
if (line.equals("886")) {
break;
}
// 将数据封装到DatagramPacket
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, ip,
port);
ds.send(dp);
//发完一个，休息1秒
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.out.println("发送到失败");
e.printStackTrace();
}
}
ds.close();
} catch (Exception e) {
System.out.println(e);
}
}
// ②接收业务：接收udpSocket
public void rece(DatagramSocket ds) {
try {
while (true) {
// ①定义一个数据包
byte[] buf = new byte[1024 * 64];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// ②将接收的数据包存放如dp中
ds.receive(dp);
// ③处理接收的数据
String ip = dp.getAddress().getHostAddress();
String data = new String(buf, 0, buf.length);
//System.out.println(data);
System.out.println(ip + ":" + data);
//收完一个，休息1秒
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.out.println("发送到失败");
e.printStackTrace();
}
}
} catch (Exception e) {
System.out.println(e);
}
}
}

复制代码

5、无奈之下，我想可能是Eclipse控制台显示效果吧，于是我就用cmd控制台来试试。
      ①编译：javac ChatDemo.java 通过
      ②运行 :java ChatDemo   报错了。。。。Eclipse里面都能运行，控制台运行出错？？？
            错误如下图：

      ③竟然说找不到 ChatDemo？这怎么回事？

周恺 · 周恺

本帖最后由周恺于 2012-7-17 08:11 编辑

你的接收方法的循环,我帮你改了一下.
while (true) {
                              // ①定义一个数据包
                              byte[] buf = new byte[1024*64];
                           DatagramPacket dp = new DatagramPacket(buf,buf.length);

                              // ②将接收的数据包存放如dp中
                              ds.receive(dp);

                              // ③处理接收的数据
                              String ip = dp.getAddress().getHostAddress();
                              String data = new String(dp.getData(), 0, dp.getLength());//这里,你要打印的字符串,不能将所有的字节数组一起打印,而是接收多长的数据就打多长.
                                                                                                                        //使用dp.getData()方法获取数据缓冲区,dp.getLength())获取缓冲区长度.
                              //System.out.println(data);
                              System.out.println(ip + ":" + data);

                              //收完一个，休息1秒
                              try {
                                    Thread.sleep(1000);
                              } catch (InterruptedException e) {
                                    // TODO Auto-generated catch block
                                    System.out.println("发送到失败");
                                    e.printStackTrace();
                              }
在我的控制台上已经运行成功.
另外,由于receive()方法是阻塞式方法,也就是说receive()如果接收不到数据包,就会一直等着,
不会跟发送线程"打架",是不会存在你说的那种线程问题的,你把sleep去掉再试试.

还有,你在控制台运行不了,是因为你的程序前面有包名,是在eclipse的工作区里面定义的,CLASSPATH找不到,当然运行不了.

张世威 · 张世威

哥们，厉害呀，改完后就可以运行了。。谢谢你了

帐号		自动登录	找回密码
密码			加入黑马

UDP协议的聊天程序，使用两个线程分别发生和接收,却出错...

评分

2 个回复

评分