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

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 程序爱好者 中级黑马   /  2014-5-9 15:42  /  1161 人查看  /  3 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 程序爱好者 于 2014-5-12 11:17 编辑
  1. import java.net.*;
  2. import java.io.*;

  3. class Send implements Runnable{
  4.         private DatagramSocket ds;
  5.         public Send(DatagramSocket ds)
  6.         {
  7.                 this.ds=ds;
  8.         }
  9.         public void run()
  10.         {
  11.                 try {               
  12.                         BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
  13.                         String line=null;
  14.                         while((line=bf.readLine())!=null)
  15.                         {
  16.                                 if("886".equals(line))
  17.                                         break;
  18.                                 byte[] buf=line.getBytes();
  19.                                 DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10002);
  20.                                 ds.send(dp);
  21.                         }                        
  22.                 } catch (Exception e) {
  23.                         System.out.println("发送端口失败!");
  24.                 }        
  25.         }
  26. }
  27. class Rece implements Runnable{
  28.         private DatagramSocket ds;
  29.         public Rece(DatagramSocket ds)
  30.         {
  31.                 this.ds=ds;
  32.         }
  33.         public void run()
  34.         {
  35.                 try {
  36.                         while(true){
  37.                                 byte[] buf=new byte[1024];
  38.                                 DatagramPacket dp=new DatagramPacket(buf,buf.length);
  39.                                 ds.receive(dp);
  40.                                 String ip=dp.getAddress().getHostAddress();
  41.                                 String data=new String(dp.getData(),0,dp.getLength());
  42.                                 System.out.println(ip+"::"+data);
  43.                         }
  44.                 } catch (Exception e) {
  45.                         // TODO: handle exception
  46.                         System.out.println("接收端口失败!");
  47.                 }
  48.         }
  49. }
  50. class ChatDemo
  51. {
  52.         public static void main(String[] args) throws Exception
  53.         {
  54.                 DatagramSocket sendSocket=new DatagramSocket();
  55.                 DatagramSocket receSocket=new DatagramSocket(10002);
  56.                 new Thread(new Send(sendSocket)).start();
  57.                 new Thread(new Rece(sendSocket)).start();
  58.         }
  59. }
复制代码


我用MyEclipse 开发软件运行, 只能输入 没见在控制台打印,看了几个小时了,还不出来是代码问题还是软件操作错了,我创的是一个类 Send  里面就写下这些代码!  求高手帮我看一下

3 个回复

倒序浏览
UDP不能实现聊天效果吧?只能发送和接收。聊天的用TCP。三次握手。
回复 使用道具 举报
看我下面的代码,你出错的地方,我都你给代码注释了,你看一下,我这里运行没有问题,给你的是正确的代码
记得要看我给你的注释,记得修改成你自己电脑的ip
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();
        }
}

运行结果截图:
C:\Users\Pual\Desktop\运行结果.png
回复 使用道具 举报
不要太紧张,只是粗心大意而已,,,接收端没打开。。。。这就是UDP啊,只管发送,也不管是否能收到数据,,,但是聊天确实是用UDP做的,讲求快速嘛。。。
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马