中国IT动力,最新最全的IT技术教程
最新100篇 | 推荐100篇 | 专题100篇 | 排行榜 | 搜索 | 在线API文档 | 网通镜像
首 页 | 程序开发 | 操作系统 | 软件应用 | 图形图象 | 网络应用 | 精文荟萃 | 教育认证 | 硬件维护 | 未整理篇 | 站长教程
ASP JS PHP工程 ASP.NET 网站建设 UML J2EESUN .NET VC VB VFP 网络维护 数据库 DB2 SQL2000 Oracle Mysql
服务器 Win2000 Office C DreamWeaver FireWorks Flash PhotoShop 上网宝典 CorelDraw 协议大全 网络安全 微软认证
硬件维护  CPU  主板  硬盘  内存  显卡  显示器  键盘鼠标  声卡音箱  打印机  机箱电源  BIOS  网卡  C#  Java  Delphi  vs.net2005
  当前位置:> 程序开发 > 编程语言 > Java > 网络
用udp方式进行聊天的java实现.
作者:bootcool 时间:2001-11-23 11:13 出处:互联网 责编:chinaitpower
              摘要:用udp方式进行聊天的java实现.

 

我最近也在研究用java实现oicq。
这是我的客户端的简单编程实现。
主要是通过udp方式,实现用户间的对话。
其中运用了序列化类的方法。
以下是源代码,请多提意见。

//发送消息类
Message.java

import java.io.Serializable;

public class Message implements Serializable{

    private String msg;
    private String id;
    private String destid;

   public Message(String msg, String id, String destid) {
        this.msg = msg;
        this.id = id;
        this.destid = destid;
    }
    
   //获得消息内容
    public String getMessage() {
        return msg;
    }
   
   //获得发送方的ip
    public String getID() {
        return id;
    }
 
   //获得接受方的ip
    public String getDestID() {
        return destid;
    }
  }

 

//接受方
Receiver.java
import java.net.*;
import java.io.*;

public class Receiver extends Thread {
   
    private Message msg;
    private DatagramPacket packet;
    private DatagramSocket socket;
    private byte[] recvBuf = new byte[500];
   
    public Receiver() {
    try{
       //创建udp包以接受数据。
       packet = new DatagramPacke(recvBuf,recvBuf.length);
      
       //创建接受方的udp端口以接收数据
       socket = new DatagramSocket(7002);
    }
      catch(Exception e){}   
    }

   public void run() {
     try {
      while(true){
      //接受数据
      socket.receive(packet);

      ByteArrayInputStream byteStream = new
                           ByteArrayInputStream(recvBuf);
      ObjectInputStream is = new ObjectInputStream(new    
                           BufferedInputStream(byteStram));
      Object o = is.readObject();
      msg = (Message)o;
      is.close();

      System.out.println(msg.getMessage());
      }
     }
     catch(Throwable t) {
            t.printStackTrace();
    }
  }
}


//发送方
Sender.java
import java.net.*;
import java.io.*;

public class Sender extends Thread {

private Message msg;
    private DatagramSocket socket;
    private DatagramPacket packet;
   
    public Sender(Message msg) {
        try {
            this.msg = msg;
            //获得目的方的ip地址
            String destID = msg.getDestID();
           
            //获得将要发送的消息内容
            String destID = msg.getDestIDString message = msg.getMessage();
           
            ByteArrayOutputStream byteStream = new ByteArrayOutputStream(500);
            ObjectOutputStream os = new ObjectOutputStream(new
                                    BufferedOutputStream(byteStream));
            os.writeObject(msg);
            os.flush();
            byte[] sendBuf = byteStream.toByteArray();
            
           //创建udp数据包以发送数据
           packet = new  DatagramPacket(sendBuf,sendBuf.length,
                                        InetAddress.getByName(destID),7002);
           //创建发送udp套接字,指定套接字口。
           socket = new DatagramSocket(7000);
           os.close();
        }
        catch(Throwable t) {
            t.printStackTrace();
        }
    }

    public void run() {
        try {
         //发送消息
         socket.send(packet);
         //发送完毕关闭套接字。
         socket.close();
        }
        catch(Throwable t) {
            t.printStackTrace();
        }
    }
}


//测试程序
Udp_Chat.java
import java.io.*;
import java.net.*;

public class UDP_Chat {
   
   public UDP_Chat(String s){
   }

public static void main(String args[])throws Exception{
    Message a = new Message("阿飞的卡","211.92.155.200" ,"211.92.155.200");
    new Sender(a).start();
    new Receiver().start();  
    }
}

参考文章:Java 技巧 40:通过数据报包输送对象 利用数据报包在网上输送 Java 对象
bootcool@263.net

关闭本页
 
首页 | 投资与合作 | 服务条款 | 隐私政策 | 收藏本站 | 设为首页 | 新用户注册 | 免责声明 | 使用帮助
Copyright ©2005-2008 chinaitpower.com All rights reserved. www.chinaitpower.com 版权所有