欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  IT编程

java中UDP简单聊天程序实例代码

程序员文章站 2024-02-13 09:51:46
学过计算机网络通信的都知道，计算机之间传送数据由两种，即tcp通信和udp通信。tcp是可靠的面向连接的通信协议，二udp是不可靠的面向无连接的通信协议。 java中有基...

学过计算机网络通信的都知道，计算机之间传送数据由两种，即tcp通信和udp通信。tcp是可靠的面向连接的通信协议，二udp是不可靠的面向无连接的通信协议。

java中有基于tcp的网络套接字通信，也有基于udp的用户数据报通信，udp的信息传输速度快，但不可靠！

基于udp通信的基本模式：

（1）将数据打包，称为数据包（好比将信件装入信封一样），然后将数据包发往目的地。

（2）接受别人发来的数据包（好比接收信封一样），然后查看数据包中的内容。

客户机

复制代码 代码如下:

package com.client.view;

import java.awt.event.actionevent;
import java.awt.event.actionlistener;
import java.awt.event.windowadapter;
import java.awt.event.windowevent;
import java.io.objectoutputstream;

import javax.swing.imageicon;
import javax.swing.jbutton;
import javax.swing.jframe;
import javax.swing.joptionpane;
import javax.swing.jpanel;
import javax.swing.jtextarea;
import javax.swing.jtextfield;

import com.tools.clienttoserverthread;

/**
 * @author lenovo
 *
 */
public class jchatfrm extends jframe implements actionlistener{


 jtextarea jta;
 jtextfield jtf;
 jbutton jb;
 jpanel jp;
 string ownerid;
 string friendid;

 clienttoserverthread ctst;
 public static void main(string[] args) {
  // todo auto-generated method stub
  new jchatfrm();
 }

 public jchatfrm()
 {
  settitle("客户端");
  jta=new jtextarea();
  jtf=new jtextfield(15);
  jb=new jbutton("发送");
  jb.addactionlistener(this);
  jp=new jpanel();
  jp.add(jtf);
  jp.add(jb);

  this.add(jta,"center");
  this.add(jp,"south");
 // this.settitle(ownerid+" 正在和 "+friend+" 聊天");
  this.seticonimage((new imageicon("image/qq.gif").getimage()));
 // this.setsize(300, 200);
  this.setbounds(300, 200, 300, 200);
  this.setvisible(true);
  setdefaultcloseoperation(jframe.dispose_on_close);
  ctst = new clienttoserverthread(jta);
  ctst.start();

  /**窗体关闭按钮事件*/
  this.addwindowlistener(new windowadapter()
  {
   public void windowclosing(windowevent e)
   {
    if(joptionpane.showconfirmdialog(null, "<html><font size=3>确定退出吗？</html>","系统提示",joptionpane.ok_cancel_option,joptionpane.information_message)==0)
    {  
     system.exit(0);
     ctst.closesocket();
    }
    else
    {
     return;
    }
   }
  }
  );
 }

 //写一个方法，让它显示消息
 public void showmessage(string message)
 {
  string info= message;
  this.jta.append(info);
 }

 public void actionperformed(actionevent arg0) {
  // todo auto-generated method stub
  if(arg0.getsource()==jb)
  {   
   byte buffer[] = jtf.gettext().trim().getbytes();
   ctst.senddata(buffer);
  }

 }
}

复制代码 代码如下:

package com.tools;

import java.io.ioexception;
import java.io.inputstream;
import java.io.objectinputstream;
import java.net.datagrampacket;
import java.net.datagramsocket;
import java.net.inetaddress;
import java.net.socket;
import java.util.properties;

import javax.swing.jtextarea;

import com.common.user;

/**
 * @author lenovo
 *
 */
public class clienttoserverthread extends thread{

 private string serverip = "127.0.0.1";
 private int serverport = 8888;
 private int receiveport = 6666;
 //声明发送信息的数据报套结字
    private datagramsocket sendsocket = null;
    //声明发送信息的数据包
    private datagrampacket sendpacket = null;
    //声明接受信息的数据报套结字
    private datagramsocket receivesocket = null;
    //声明接受信息的数据报
    private datagrampacket receivepacket = null;
    //收发数据的端口
    private int myport = 0;
    //接收数据主机的ip地址
    private string friendip = null;
    private int friendport = 0;

    //缓冲数组的大小
    public static final int buffer_size = 5120;

    private byte inbuf[] = null; //接收数据的缓冲数组
    private byte outbuf[] = null; //发送数据的缓冲数组

    jtextarea jta;

 // 构造函数
 public clienttoserverthread(jtextarea jta) {
  this.jta = jta;
  getpropertiesinfo();
 }

 public void run() {
  string receiveinfo = "";
  try{
   inbuf = new byte[buffer_size];
   receivepacket = new datagrampacket(inbuf,inbuf.length);
   receivesocket = new datagramsocket(receiveport);
  }catch (exception e) {
   e.printstacktrace();
   // todo: handle exception
  }

  while (true) {
   if(receivesocket == null){
    break;
   } else {
    try {
     receivesocket.receive(receivepacket);
     string message = new string(receivepacket.getdata(),0,receivepacket.getlength());
     jta.append("收到数据"+message+"\n");
    } catch (exception e) {
     e.printstacktrace();
     // todo: handle exception
    }
   }
  }
 }
 /**
  * 该方法用来获得服务器属性文件中的ip、port
  */
 private void getpropertiesinfo(){
  properties prop = new properties();
  inputstream instream = thread.currentthread().getcontextclassloader()
    .getresourceasstream("serverinfo.properties");
  try{
   //获得相应的键值对
   prop.load(instream);
  }catch(ioexception e){
   e.printstacktrace();
  }

  //根据相应的键获得对应的值
  serverip = prop.getproperty("serverip");
  serverport = integer.parseint(prop.getproperty("serverudp.port"));
  receiveport = integer.parseint(prop.getproperty("receiveudp.port"));

       
 }
 public void senddata(byte buffer[]){
  try{
   inetaddress address = inetaddress.getbyname(serverip);
  // outbuf = new byte[buffer_size];
   sendpacket = new datagrampacket(buffer,buffer.length,address,serverport);
   sendsocket = new datagramsocket();
   sendsocket.send(sendpacket);
  }catch (exception e) {
   e.printstacktrace();
   // todo: handle exception
  }
 }
    public void closesocket(){
     receivesocket.close();
    }
}

服务器：

复制代码 代码如下:

package com.server.view;

import java.awt.event.actionevent;
import java.awt.event.actionlistener;
import java.awt.event.windowadapter;
import java.awt.event.windowevent;
import java.io.objectoutputstream;

import javax.swing.imageicon;
import javax.swing.jbutton;
import javax.swing.jframe;
import javax.swing.joptionpane;
import javax.swing.jpanel;
import javax.swing.jtextarea;
import javax.swing.jtextfield;

import com.tools.clienttoserverthread;

/**
 * @author lenovo
 *
 */
public class jchatfrm extends jframe implements actionlistener{


 jtextarea jta;
 jtextfield jtf;
 jbutton jb;
 jpanel jp;
 string ownerid;
 string friendid;

 clienttoserverthread ctst;
 public static void main(string[] args) {
  // todo auto-generated method stub
  new jchatfrm();
 }

 public jchatfrm()
 {
  settitle("服务器");
  jta=new jtextarea();
  jtf=new jtextfield(15);
  jb=new jbutton("发送");
  jb.addactionlistener(this);
  jp=new jpanel();
  jp.add(jtf);
  jp.add(jb);

  this.add(jta,"center");
  this.add(jp,"south");
 // this.settitle(ownerid+" 正在和 "+friend+" 聊天");
  this.seticonimage((new imageicon("image/qq.gif").getimage()));
 // this.setsize(300, 200);
  this.setbounds(300, 200, 300, 200);
  this.setvisible(true);
  setdefaultcloseoperation(jframe.dispose_on_close);
  ctst = new clienttoserverthread(jta);
  ctst.start();

  /**窗体关闭按钮事件*/
  this.addwindowlistener(new windowadapter()
  {
   public void windowclosing(windowevent e)
   {
    if(joptionpane.showconfirmdialog(null, "<html><font size=3>确定退出吗？</html>","系统提示",joptionpane.ok_cancel_option,joptionpane.information_message)==0)
    {  
     system.exit(0);
     ctst.closesocket();
    }
    else
    {
     return;
    }
   }
  }
  );
 }

 //写一个方法，让它显示消息
 public void showmessage(string message)
 {
  string info= message;
  this.jta.append(info);
 }

 public void actionperformed(actionevent arg0) {
  // todo auto-generated method stub
  if(arg0.getsource()==jb)
  {      
   byte buffer[] = jtf.gettext().trim().getbytes();
   ctst.senddata(buffer);
  }

 }
}

复制代码 代码如下:

package com.tools;

import java.io.ioexception;
import java.io.inputstream;
import java.io.objectinputstream;
import java.net.datagrampacket;
import java.net.datagramsocket;
import java.net.inetaddress;
import java.net.socket;
import java.util.properties;

import javax.swing.jtextarea;

import com.common.user;

/**
 * @author lenovo
 *
 */
public class clienttoserverthread extends thread{

 private string sendip = "127.0.0.1"; 
 private int sendport = 6666;
 private int receiveport = 8888;
 //声明发送信息的数据报套结字
    private datagramsocket sendsocket = null;
    //声明发送信息的数据包
    private datagrampacket sendpacket = null;
    //声明接受信息的数据报套结字
    private datagramsocket receivesocket = null;
    //声明接受信息的数据报
    private datagrampacket receivepacket = null;
    //收发数据的端口
    private int myport = 0;
    //接收数据主机的ip地址
    private string friendip = null;
    private int friendport = 0;

    //缓冲数组的大小
    public static final int buffer_size = 5120;

    private byte inbuf[] = null; //接收数据的缓冲数组
    private byte outbuf[] = null; //发送数据的缓冲数组

    jtextarea jta;

 // 构造函数
 public clienttoserverthread(jtextarea jta) {
  this.jta = jta;
  getpropertiesinfo();
 }

 public void run() {
  string receiveinfo = "";
  try{
   inbuf = new byte[buffer_size];
   receivepacket = new datagrampacket(inbuf,inbuf.length);
   receivesocket = new datagramsocket(receiveport);
  }catch (exception e) {
   e.printstacktrace();
   // todo: handle exception
  }

  while (true) {
   if(receivesocket == null){
    break;
   } else {
    try {
     receivesocket.receive(receivepacket);
     string message = new string(receivepacket.getdata(),0,receivepacket.getlength());
     jta.append("收到数据"+message+"\n");
    } catch (exception e) {
     e.printstacktrace();
     // todo: handle exception
    }
   }
  }
 }
 /**
  * 该方法用来获得服务器属性文件中的ip、port
  */
 private void getpropertiesinfo(){
  properties prop = new properties();
  inputstream instream = thread.currentthread().getcontextclassloader()
    .getresourceasstream("serverinfo.properties");
  try{
   //获得相应的键值对
   prop.load(instream);
  }catch(ioexception e){
   e.printstacktrace();
  }

  //根据相应的键获得对应的值

  receiveport = integer.parseint(prop.getproperty("serverudp.port"));

  

 }
 public void senddata(byte buffer[]){
  try{
   inetaddress address = inetaddress.getbyname(sendip);
  // outbuf = new byte[buffer_size];
   sendpacket = new datagrampacket(buffer,buffer.length,address,sendport);
   sendsocket = new datagramsocket();
   sendsocket.send(sendpacket);
  }catch (exception e) {
   e.printstacktrace();
   // todo: handle exception
  }
 }
 public void closesocket(){
     receivesocket.close();
    }
}

运行截图：

java中UDP简单聊天程序实例代码

上一篇： C#中out与ref的区别实例解析

下一篇： Android横竖屏切换实例总结

推荐阅读