黑马程序员技术交流社区

标题: UDP的通讯问题 [打印本页]

作者: 宋美成    时间: 2014-5-9 18:14
标题: UDP的通讯问题
本帖最后由 宋美成 于 2014-5-9 18:15 编辑

请教大家一个问题,我用eclipse在做关于UDP的通讯时,我把接收端和发送端放到了两个工程里,然后分别编译,结果会报错,还是模拟不了相互通讯,问问这个大家是怎么处理这个问题的啊?

作者: 苍穹的雨    时间: 2014-5-9 19:13
我是用awt做成了图形化界面,然后运行的,你可以先保存个图形界面的框架,以后把需要练习的东西往里面填,反正是练习嘛,顺便把awt也练习了。。。。。
作者: jsjchenlong    时间: 2014-5-9 23:42
给你一段代码,你看一下,希望对你有帮助

package Test;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

class Send
implements Runnable {
        private DatagramSocket ds;
        public Send(DatagramSocket ds) {
                this.ds = ds;
        }

        public void run() {
                try {
                        BufferedReader bf = new BufferedReader(new InputStreamReader(
                                        System.in));
                        String line = null;
                        while ((line = bf.readLine()) != null) {
                                if ("886".equals(line))
                                        break;
                                byte[] buf = line.getBytes();
                                //这里记着修改成你自己的ip,这里的端口号一定要和接收时你输入的端口号一致。
                                DatagramPacket dp = new DatagramPacket(buf, buf.length,
                                                InetAddress.getByName("192.168.1.100"), 8888);
                                ds.send(dp);
                       
                        }
                } catch (Exception e) {
                        System.out.println("发送端口失败!");
                }
        }
}

class Rece implements Runnable {
        private DatagramSocket ds;

        public Rece(DatagramSocket ds) {
                this.ds = ds;
        }

        public void run() {
                try {
                        while (true) {
                                byte[] buf = new byte[1024];
                                DatagramPacket dp = new DatagramPacket(buf, buf.length);
                                ds.receive(dp);
                                String ip = dp.getAddress().getHostAddress();
                                String data = new String(dp.getData(), 0, dp.getLength());
                                System.out.println(ip + "::" + data);
                        }
                } catch (Exception e) {
                       
                        System.out.println("接收端口失败!");
                }
        }
}

class ChatDemo {
        public static void main(String[] args) throws Exception {
                DatagramSocket sendSocket = new DatagramSocket();
                //我用的是8888端口这个比较稳定那个10002老是有问题,我用的地址是我自己的,你到时候修改成你的地址就可以了。
                DatagramSocket receSocket = new DatagramSocket(8888);
                //正确的代码如下
                new Thread(new Send(sendSocket)).start();
                new Thread(new Rece(receSocket)).start();
                //你的代码是这么写的,只有发送没有接收当然会有问题了
                //new Thread(new Send(sendSocket)).start();
                //new Thread(new Rece(sendSocket)).start();
        }
}
作者: 宋美成    时间: 2014-5-9 23:54
jsjchenlong 发表于 2014-5-9 23:42
给你一段代码,你看一下,希望对你有帮助

package Test;

用两个线程~我试试
作者: code2014    时间: 2014-5-10 07:40
过来学习~~~
作者: 天外的星    时间: 2014-5-12 17:28
粘贴到本地试试




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