Java UDP实现聊天功能代码【转】
感谢大佬大佬!!!:https://www.cnblogs.com/woshijpf/p/3735684.html
我以前经常写的是基于TCP的网络编程,由于TCP建立连接鼻血要经过三次握手连接,服务器端需要阻塞式等待客户端的连接。而UDP则是可以直接向目的地址的目的端口上发送数据包,由于它只负责发送出去就好,不管对方是否正确接受到与否,所以当网络性能不好时它容易出现丢包的问题。(注意:UDP是基于数据报为单位进行传输的,而TCP是一种基于流进行传输的)
但是UDP很好的模拟了我们呢平时聊天的方式,可以很好的实现连续多次发送和接受,也就是简单的QQ聊天的功能。
现在来简要介绍Java中有关UDP编程相关的类:
一个是DatagramPacket,主要用来将数据字节填充到UDP数据报中,用来解包接受数据的,用来收和发UDP数据报。一个是DatagramSocket主要用来是建立客户端和服务器端,用来接受和发送数据报数据的。
(1)DatagramPacket类
UDP首部向IP首部添加了8个字节,包含了源端口和目标端口,IP首部以后内容的长度和校验和,最多有65507个字节数。UDP所使用的端口和TCP使用的端口不一样的,是一个final类。
对于接受数据,将接受到的数据存储到DatagramPacket,然后从该对象中读取数据。
对于发送数据,将发送的数据先存到DatagramPacket中,然后将该对象发送。
以下是我写的简单的一个聊天程序:
Send_Thread.java
package Chat_UDP;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.util.Scanner;
public class Send_Thread extends Thread{
//发送的socket端
private DatagramSocket sender = null;
//待发送的目标地址
private InetSocketAddress address = null;
//从键盘输入
Scanner scan = new Scanner(System.in);
public Send_Thread(DatagramSocket sender,InetSocketAddress address)
{
this.sender = sender;
this.address = address;
}
@Override
public void run() {
// TODO Auto-generated method stub
try
{
while(true)
{
//输入待发送的内容
String input = scan.nextLine();
if(input.equals("exit"))
break;
byte[] data = null;
data = input.getBytes("UTF-8");
//创建UDP数据报
DatagramPacket pack = new DatagramPacket(data, data.length,address);
sender.send(pack);
}
System.out.println("Exit!");
}catch(IOException e)
{
System.out.println("IOException");
}
}
}
Receive_Thread.java
package Chat_UDP;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Receive_Thread extends Thread {
private static final int MAX_RECEIVE_BUFFER = 1024;
private DatagramSocket server;
private DatagramPacket packet;
byte[] buffer = new byte[MAX_RECEIVE_BUFFER];
public Receive_Thread(DatagramSocket server)
{
this.server = server;
packet = new DatagramPacket(buffer, buffer.length);
}
@Override
public void run() {
// TODO Auto-generated method stub
try
{
while(true)
{
//接收数据包
server.receive(packet);
String s = new String(packet.getData(),packet.getOffset(),packet.getLength(),"UTF-8");
System.out.println(packet.getAddress()+" at port "+packet.getPort()+" Says :"+s);
packet.setLength(buffer.length);
}
}
catch(IOException e)
{
System.out.println("IOException");
}
}
}
Chat_Client.java
package Chat_UDP;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
public class Chat_Client {
private static final int DEST_PORT = 9000;
private static final int SEND_PORT = 10000;
private static final int RECE_PORT = 8888;
private static final String IP = "127.0.0.1";
public static void main(String[] args)
{
try{
Send_Thread send_thread = null;
Receive_Thread rece_thread = null;
InetSocketAddress address = null;
//创建待接受数据包的目的机的端口号和IP地址
address = new InetSocketAddress(IP, DEST_PORT);
//创建发送的Socket端
DatagramSocket sendsocket = new DatagramSocket(SEND_PORT);
//创建接受的Socket端
DatagramSocket recesocket = new DatagramSocket(RECE_PORT);
//发送线程建立
send_thread = new Send_Thread(sendsocket, address);
//接受线程的建立
rece_thread = new Receive_Thread(recesocket);
send_thread.start();
rece_thread.start();
}catch(Exception e)
{
System.out.println("Exception!");
}
}
}
补充:
https://baike.baidu.com/item/UDP/571511?fr=aladdin
https://baike.baidu.com/item/TCP/IP协议
https://www.jianshu.com/p/fb03d7af30bb
https://jingyan.baidu.com/article/76a7e409fb5873fc3a6e1577.html
最新文章
- memcache的内存管理探微
- #ifndef _LED_H #endif啥意思?
- 熟练掌握HDFS的Shell访问
- ubuntu 安装软件(apt源)
- C# - 类型
- Ubuntu 12.04 Server OpenStack Havana多节点(OVS+GRE)安装
- 基于Java图片数据库Neo4j 3.0.0发布 全新的内部架构
- The type javax.servlet.http.HttpServletRequest cannot be resolved.
- 重定向输入输出流--freopen
- 拿出来分享了!VIP珍藏!!!全网最齐全的 DEDECMS模板 全盘下载地址列表!没有你找不到的!
- Android自定义属性,format详解
- 以往CSDN博文目录
- hihoCoder1498-Diligent Robots
- (NO.00002)iOS游戏精灵战争雏形(十二)
- 震惊!Vector两行代码求逆序对,六行代码过普通平衡树
- 【转载】路径双反斜杠!!!Python IDLE或Python shell中切换路径 切换目录os.chdir(";C:\\python37\\2019pythonshel37\\diedai";)
- spyder 快捷键
- HDU 1075 字符串映射(map)
- 湾区求职分享:三个月刷题拿到 Google offer,欢迎踊跃提问
- JAVA的Spring注入机制事例详解
热门文章
- matplotlib 进阶之origin and extent in imshow
- 基于Spring MVC + Spring + MyBatis的【网上购物系统】
- SpringCloud创建Config Client通过Eureka访问Config
- Microsoft HoloLens 开发(3): 全息图交互方式 - Gaze
- sqlsugar freesql hisql 三个ORM框架性能测试对比
- git clone 失败 ,提示 fatal: unable to access 'https://github.com/xxx.git/': OpenSSL SSL_read: Connection was reset, errno 10054
- antd-vue中的form表单label标签for导致点击文字触发输入框解决方案
- Centos 6.8安装配置KVM
- C语言 运算符优先级和结合方向
- PowerPoint2010实现折线图动态展示