java实现udp通讯的代码
作者:rising1234 发布时间:2022-07-18 13:28:52
标签:java,udp,通讯
需求:应用A(通常有多个)和应用B(1个)进行 socket通讯,应用A必须知道应用B的ip地址(在应用A的配置文件中写死的),这个时候就必须把应用B的ip设成固定ip(但是某些时候如更换路由后要重新设置网络,但是操作人员不知道这个规则),就有可能造成应用A和应用B无法进行正常通讯,所以要改成应用A动态获取应用B的ip地址。
经过讨论决定采用udp协议实现,upd是一种无连接的传输层协议。应用A在不知道应用B的 ip情况下 可以使用广播地址255.255.255.255,将消息发送到在同一广播网络上的B。从而获取B的ip。
实现代码:
B应用为服务端:将udp监听放到一个线程中,当有客户端请求时就会进行响应
/**
* udp连接,用于动态ip, pos向255.255.255.255:5060发送请求即可
* **/
public class UdpServer extends Thread implements Runnable {
private final int MAX_LENGTH = 1024;
private final int PORT = 5060;
private DatagramSocket datagramSocket;
public void run() {
try {
init();
while(true){
try {
byte[] buffer = new byte[MAX_LENGTH];
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
receive(packet);
String receStr = new String(packet.getData(), 0 , packet.getLength());
System.out.println("接收数据包" + receStr);
byte[] bt = new byte[packet.getLength()];
System.arraycopy(packet.getData(), 0, bt, 0, packet.getLength());
System.out.println(packet.getAddress().getHostAddress() + ":" + packet.getPort() + ":" + Arrays.toString(bt));
packet.setData(bt);
response(packet);
} catch (Exception e) {
e.printStackTrace();
LoggerUtil.error("udp线程出现异常:" + e.toString());
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void receive(DatagramPacket packet) throws Exception {
datagramSocket.receive(packet);
}
public void response(DatagramPacket packet) throws Exception {
datagramSocket.send(packet);
}
/**
* 初始化连接
*/
public void init(){
try {
datagramSocket = new DatagramSocket(PORT);
System.out.println("udp服务端已经启动!");
} catch (Exception e) {
datagramSocket = null;
System.out.println("udp服务端启动失败!");
e.printStackTrace();
}
}
}
客户端:本来客户端是使用pb来实现的,但是这里使用java来模拟
/***
* UDP Client端
***/
public class UdpClient {
private String sendStr = "hello";
private String netAddress = "255.255.255.255";
private final int PORT = 5060;
private DatagramSocket datagramSocket;
private DatagramPacket datagramPacket;
public UdpClient(){
try {
datagramSocket = new DatagramSocket();
byte[] buf = sendStr.getBytes();
InetAddress address = InetAddress.getByName(netAddress);
datagramPacket = new DatagramPacket(buf, buf.length, address, PORT);
datagramSocket.send(datagramPacket);
byte[] receBuf = new byte[1024];
DatagramPacket recePacket = new DatagramPacket(receBuf, receBuf.length);
datagramSocket.receive(recePacket);
String receStr = new String(recePacket.getData(), 0 , recePacket.getLength());
//获取服务端ip
String serverIp = recePacket.getAdress();
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
// 关闭socket
if(datagramSocket != null){
datagramSocket.close();
}
}
}
public static void main(String[] args) {
for (int i = 0; i < 100; i++) {
new Thread(new Runnable() {
@Override
public void run() {
UdpClient udpClient = new UdpClient();
}
}).start();
}
}
}
来源:https://www.cnblogs.com/coderising/p/9689619.html
0
投稿
猜你喜欢
- 本文实例讲述了Java链表(Linked List)基本原理与实现方法。分享给大家供大家参考,具体如下:在分析链表之前,我们先来对之前的动态
- 这篇文章主要介绍了JAVA基于SnakeYAML实现解析与序列化YAML,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考
- 先扯再说最近一直在研究某个国产开源的MySQL数据库中间件,拉下其最新版的代码到eclipse后,启动起来,然后做各种测试和代码追踪;用完想
- 基于SMTP发送一个简单的邮件首先,需要一个认证器:package No001_基于SMTP的文本邮件;import javax.mail.
- Android中的异步消息机制分为四个部分:Message、Handler、MessageQueue和Looper。其中,Message是线
- ELK是三款软件的简称,分别是Elasticsearch、Logstash、Kibana组成,在发展的过程中,又有新成员Beats的加入,所
- 何为原子性原子性:一条线程在执行一系列程序指令操作时,该线程不可中断。一旦出现中断,那么就可能会导致程序执行前后的结果不一致。与数据库中的原
- 由于jdk 1.8 之后sun.misc 包下的 BASE64Decode的依赖 被移除我们需要在自己的项目中引入EncodeUtils 工
- 本文介绍了spring cloud Feign使用中遇到的问题总结,分享给大家,具体如下:问题一:在前面的示例中,我们讲过@RequestM
- package com.abc.dao;import java.sql.Connection;import java.sql.DriverM
- 前言在一些日常业务中,会遇到一些琐碎文件需要统一打包到一个压缩包中上传,业务方在后台接收到压缩包后自行解压,然后解析相应文件。而且可能涉及安
- EasyTouch摇杆插件使用,先给大家展示下效果图:Demo展示双指缩放在电脑端无法掩饰,竖屏将就看看吧;插件名叫EasyTouch,有需
- C#获取远程图片,需要Form用户名和密码的Authorization认证using System;using System.Collect
- 本文实例为大家分享了C# GDI+实现时钟表盘的具体代码,供大家参考,具体内容如下一、设计如下图界面按键“打开时钟&am
- 一、面向对象的描述面向对象是一种现在最为流行的程序设计方法,几乎现在的所有应用都以面向对象为主了,最早的面向对象的概念实际上是由IBM提出的
- 加载资源文件比较常用的有两种:一、用ClassLoader,说到这里就不得不提一下ClassLoader的分类,java内置的ClassLo
- Spring Security登录表单配置1.引入pom依赖创建一个Spring Boot工程,引入Web和Spring Security依
- InputStreamReader和OutputStreamWriter源码分析1. InputStreamReader 源码(基于jdk1
- MyBatis在SQL语句中获取list大小需求:使用MyBatis进行开发时,在一个SQL语句中需要拼接list的大小。大家都知道,当我们
- spring 多文件配置:1、properties文件2、YAML文件一、properties文件在 Spring Boot 中, 多环境配