当前位置：移动技术网 > IT编程>开发语言>Java > java中UDP简单聊天程序实例代码

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

2019年07月22日 | 移动技术网IT编程 | 我要评论

学过计算机网络通信的都知道，计算机之间传送数据由两种，即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 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);
}

复制代码代码如下:

package com.tools;

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;

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();
    }
}

运行截图：

您可能感兴趣的文章:

如对本文有疑问，点击进行留言回复！！

IDEA使用Gradle构建SpringBoot项目工程的详细教程

背景最近在研究搭建spring源码调试环境时，接触到到gradle项目构建工具。由于之前习惯于maven项目的构建，故通过此文记录相关gradle的项目构建知识... [阅读全文]
SpringBoot整合阿里云OSS对象存储服务的实现

今天来整合一下springboot和阿里云oss对象存储服务。一、配置oss服务先在阿里云开通对象存储服务，拿到accesskeyid、accesskeysec... [阅读全文]
springboot+mybatis配置clickhouse实现插入查询功能

说明clickhouse 是一款用于大数据实时分析的列式数据库管理系统，在大数据量查询时有着非常优秀的性能，但是也有缺点，就是不支持事务，不支持真正的删除 / ... [阅读全文]
IDEA遇到Internal error. Please refer to http://jb. gg/ide/critical-startup-errors的问题及解决办法

今天打算把原本的2018的idea升个级，安一个2020 的idea试试各种新插件，但遇到了很多问题，比如安装后打不开，好不容易打开了然后报错internal ... [阅读全文]
Spring boot整合mybatis实现过程图解

导入mybatis jar包右键pom.xml模拟springboot底层实现类1.定义接口@mapperpublic interface goodsdao {... [阅读全文]
Spring boot GC实现过程原理解析

内存中不可达对象（没有引用指向此对象）会被标记为垃圾对象手动将对象变为垃圾对象：将指向对象的变量置为null如何gc：查找，标记，清除，整理控制台查看是否启动g... [阅读全文]
SpringMvc自定义拦截器（注解）代码实例

拦截器自定义拦截器实现handlerinterceptor接口的三个方法。public class myinterceptor implements handl... [阅读全文]
SpringMvc静态资源访问实现方法代码实例

原因springmvc中配置前端控制器dispatcherservlet 设为‘/'后，所有的资源请求都要被前端控制器捕捉，springmvc会把他们作为普通的... [阅读全文]
最开始-我的第一篇博客

我的一些想法欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题，有助于目录的生成如何改变文本的样式插... [阅读全文]
【react-router】Redirect组件

import React from "react";import { BrowserRouter as Rou... [阅读全文]

网友评论


验证码：

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

2019年07月22日 | 移动技术网IT编程 | 我要评论

您可能感兴趣的文章:

相关文章:

网友评论