Java网络编程(TCP_UDP)

2024-04-28 19:32
文章标签 java tcp udp 编程 网络

本文主要是介绍Java网络编程(TCP_UDP),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

端口号

两个字节,范围0~65535

1、在同一个协议下端口号不能重复
2、1024以下的端口号不要使用

URL

统一资源定位符

URI 统一资源

数据的传输

1、协议 TCP/UDP
1) TCP(transfer control protocol) 面向连接 安全可靠,效率低下

2) UDP(userDatagram Protocol) 非面向连接 效率高 数据可能丢失

2、数据
先封装/后拆分


1、InetAddress InetSockAddress
2、URL
3、TCP:serverSocker Socket
4、UDP:DatagramSocket DatagramPacket

InetAddress 表示互联网的IP地址

getHostAddress()返回IP地址
getHostName() 返回域名/本机为计算机名
InetAddress.getLocalHost()返回本机地址
InetAddress.getByName(“192.168.1.1”); ip/域名

    // InetAddresspublic static void main (String [] args) throws UnknownHostException{InetAddress inet = InetAddress.getLocalHost();System.out.println(inet.getHostName());System.out.println(inet.getHostAddress());inet = InetAddress.getByName("twilight.net.cn");System.out.println(inet.getHostName());System.out.println(inet.getHostAddress());inet = InetAddress.getByName("151.101.16.133");System.out.println(inet.getHostName());System.out.println(inet.getHostAddress());}

InetSocketAddress 套接字(ip + 端口号)

SocketAddress是一个抽象类,类中没有方法

1、创建对象

InetSocketAddress(InetAddress addr,int port)
根据主机名和端口号创建套接字地址。
InetSocketAddress(InetAddress addr, int port)
根据 IP 地址和端口号创建套接字地址。
InetSocketAddress(int port)
创建套接字地址,其中 IP 地址为通配符地址,端口号为指定值。

2、方法

getAddress() 获取InetAddress
getHostName() 计算机名
getHostAddress() 返回地址
getPort() 获得端口号

    //InetSocketAddresspublic static void main(String[] args) throws UnknownHostException {InetSocketAddress net = new InetSocketAddress("127.0.0.1", 2000);System.out.println(net.getPort());System.out.println(net.getHostName());System.out.println(net.getAddress().getHostAddress());}
URL

组成: 协议+存放资源的主机域名+端口+资源名

创建:
URL(String apec) 绝对路径构建
URL (URL context,String s) 相对路径构建
URL(String protocol, String host, int port, String file) 根据指定 协议、主机号、端口号、和文件创建 URL 对象。

getProtocol() 获取协议
getHost() 获取主机名
getPort() 获取端口
getFile() 获取文件名
getPath() 获取
getRef() 锚点锚点
getQuery() 获取查询部分(参数存在锚点返回null,不存在返回正确)

    public static void main (String [] args) throws MalformedURLException{URL address = new URL("http://www.baidu.com:80/index.html#abc");System.out.println("协议" + address.getProtocol());System.out.println("文件名"+address.getFile());System.out.println("主机"+address.getHost());System.out.println("端口"+address.getPort());System.out.println("路径"+address.getPath());System.out.println("锚点"+address.getRef());}

运行结果:
协议 http
文件名 /index.html
主机 www.baidu.com
端口 80
路径 /index.html
锚点 abc

获取资源:
主页/默认资源
InputStream openStream() 获取网络流

    public static void main (String [] args) throws IOException{URL address = new URL("https://www.baidu.com/index.html");BufferedReader input = new BufferedReader(new InputStreamReader(address.openStream(),"utf-8"));BufferedWriter output = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("url_1.html"),"utf-8"));int len = 0;byte [] data = new byte[100];String s = null;while(null != (s = input.readLine())){output.append(s);output.newLine();output.flush();}input.close();output.close();}

对于乱码,目前两种解决方法:
1:用InputStreamReader转换流 InputStreamReader( inputstream s ,charset )

例: BufferedReader input = new BufferedReader(new InputStreamReader(address.openStream(),”utf-8”));

2:用String的构造函数String(byte[] ,charset )将字符数组转化成对应的编码

例:System.out.println(new String (data,”utf-8”));


UDP

UDP以数据为中心,不安全,数据可能丢失,效率高

DatagramSocket DatagramPacket
1 客户端

1>创建DatagramSocket类 + 指定端口
2>数据 字节数组
3>打包 DatagramPacket 服务器地址端口
4>发送
5>释放资源

2 服务器端

1>创建服务端 DatagramSocket
2>准备接受容器,字节数组,封装DatagramPacket
3>包接受数据
4>分析
5>释放


DatagramSocket构造函数:
此类表示用来发送和接收数据报包的套接字。

DatagramSocket()
构造数据报套接字并将其绑定到本地主机上任何可用的端口。
DatagramSocket(int port)
创建数据报套接字并将其绑定到本地主机上的指定端口。
DatagramSocket(int port, InetAddress laddr)
创建数据报套接字,将其绑定到指定的本地地址。
DatagramSocket(SocketAddress bindaddr)
创建数据报套接字,将其绑定到指定的本地套接字地址。

DatagramPacket 构造函数:
此类表示数据报包。

接收:
DatagramPacket(byte[] buf, int length)
构造 DatagramPacket,用来接收长度为 length 的数据包。

发送:
DatagramPacket(byte[] buf, int length, InetAddress address, int port)
构造数据报包,用来将长度为 length 的包发送到指定主机上的指定端口号。
DatagramPacket(byte[] buf, int length, SocketAddress address)
构造数据报包,用来将长度为 length 的包发送到指定主机上的指定端口号

// 客户端ublic class testUDPclient {public static void main(String[] args) throws IOException {DatagramSocket output = new DatagramSocket(1234);byte [] data = "UDP数据".getBytes();DatagramPacket packet = new DatagramPacket(data,data.length,new InetSocketAddress("localhost",2000));output.send(packet);output.close();}
}
    // 服务器端public class testUDPserver {public static void main (String [] args) throws IOException{DatagramSocket input = new DatagramSocket(2000);byte [] data =  new byte[1024];DatagramPacket packet = new DatagramPacket(data,data.length);input.receive(packet);byte [] info = new byte [1024] ;info = packet.getData();int len = packet.getLength();System.out.println("已收到:"+new String (info,0,len));input.close();}
}

发送double类型的数据:

//服务器端,将接受的流转换为double型private static double convert (byte [] data) throws IOException{DataInputStream input = new DataInputStream( new ByteArrayInputStream(data));double s = input.readDouble();return s;}
//客户端,将带发送的double型转换为byte数组private static byte [] convert(double num ) throws IOException{byte [] data = new byte[1024];ByteArrayOutputStream a = new ByteArrayOutputStream();DataOutputStream b = new DataOutputStream(a);b.writeDouble(num);data = a.toByteArray();return data;}

ByteArrayInputStream 和 ByteArrayOutputStream 将一个字节数组当作流输入、输出的来源



ByteArrayInputStream 将字节数组转换为流 byte[]—>流
—-read() 将字节数组读取到流中

ByteArrayOutputStream 将将流转换为字节数组 流—> byte[]
—-toByteArray() 返回数组
—-write(byte [],int off,int len ) 将数组中的数据写入到流中

DataOutputStream 将double类型写入到流中。 double—> 流
—-writeXXX()

DataInputStream 从流中读取数据,并转换为相应的类型 流—>double
—-readXXX()

Socket通讯 (基于TCP)
面向连接,安全可靠,效率低

1、面向连接: 请求-相应 request-response
2、Socket编程

1>服务器端
创建服务器 指定端口 ServerSocket(int port)
接受客户连接 accept() 返回Socket类型
传递数据

2>客户端
创建客户端 指定服务器端+端口 Socket(String s ,int port )
传递数据

发送信息:
Socket.getOutputStream();
write()
flush()

接受数据:
client.getInputStream();
read()

// 客户端
public class testTCPclient {public static void main(String[] args) throws UnknownHostException, IOException {Socket socket = new Socket("localhost",2000);String data = "TCP信息";
//      OutputStream output = socket.getOutputStream();DataOutputStream output =  new DataOutputStream(socket.getOutputStream());output.writeUTF(data);}
}
//服务器端public static void main(String[] args) throws IOException {ServerSocket socket = new ServerSocket(2000);try {Socket server = socket.accept();System.out.println("已连接");
//          InputStream input = server.getInputStream();DataInputStream input = new DataInputStream(server.getInputStream());String s = input.readUTF();System.out.println(s);} catch (IOException e) {// TODO Auto-generated catch blockSystem.out.println("连接失败");}}

不同的协议之间端口号可以重复,同一个协议中端口号不能重复

这篇关于Java网络编程(TCP_UDP)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/944074

相关文章

无废话7小时学会使用Spring Cloud Alibaba(1)概述

一 业务场景 用户下订单->扣库存数量->减账户余额   二 数据库设计   t_user表脚本: CREATE TABLE `t_user` (  `id` varchar(32) NOT NULL,  `name` varchar(32) DEFAULT NULL,  `money` int(11) DEFAULT NULL,  `createTime` datet

Java虚拟机常见面试问题

最近有朋友去过阿里面试,说掉坑里面了,总之是面试前准备工作不够,聊到关于jvm这块的一些理论知识,记录如下: 1.jvm垃圾回收 虚拟机中划分为年轻代,年老代和持久代。 年轻代:所有新生对象首先都是放在年轻代,年轻代主要收集那些生命周期短的对象。年轻代又分为三个区,一个Eden区,两个Survivor区,大部分对象在Eden区生成,当Eden区满时,还存活的对象复制到Survivor区的其中

TCP/IP、Http、Socket的关系区别理解

TPC/IP协议是传输层协议,主要解决数据如何在网络中传输,而HTTP是应用层协议,主要解决如何包装数据。        关于TCP/IP和HTTP协议的关系,网络有一段比较容易理解的介绍:“我们在传输数据时,可以只使用(传输层)TCP/IP协议,但是那样的话,如果没有应用层,便无法识别数据内容,如果想要使传输的数据有意义,则必须使用到应用层协议,应用层协议有很多,比如HTTP、FTP、TEL

Java 垃圾回收机制

GC 是什么      GC是垃圾回收(Garbage Collection)的缩写,是Java当中自动回收内存中不再使用的对象的机制。是一种自动的内存管理方式,可以减轻程序员的内存管理负担。     在Java程序执行过程中,创建的对象会存储在堆内存中。但是,当一个对象不再被引用或者没有任何引用指向它时,它就成为了垃圾。如果不对这些垃圾进行处理,就会造成内存泄漏,最终导致内存溢出。

javax.servlet.ServletException: java.lang.NoSuchMethodError 解决方法解决办法

最近在给客户做一个项目,由于修改了一个字段的类型,本地测试都没有问题,但是服务器上一部分是正确的,一部分不正确,同样的一个实体类的一个字段。报错信息入下:   解决办法:  1、进入你tomcat安装目录:我的是D:\Tomcat7.0\lib,找到el-api.jar包; 2、找到你安装使用的JDK版本目录,我的是在C:\Program Files\Java\jdk1.8.0_131

Java 字符串、数值与16进制相互转化

字符串、数值与16进制相互转化 首先创建一个工具类: package c;public class DataUtils {/** 字节数组转16进制字符串*/public static String bytesToHexString(byte[] bArr) {if (bArr == null) {return null;}StringBuffer sb = new StringBuffer(

java springboot 实现定时器任务

这两天在做一个物联网的项目,设备是智能断漏器,使用场景,固定时间关闭,固定时间打开。也就是固定时间开电,固定时间关电。设置了一个一张表用于存储需要执行的任务。界面如下: 根据上边提供的时间,如果时间到了,就执行调用设备对应的远程控制指令。但是,需要有一个定时器实时监测。 如下便是关于 springboot 的@Scheduled 定时器 import java.text.ParseE

苍穹外卖-day01(SpringBoot+SSM的企业级Java项目实战)

苍穹外卖-day01 课程内容 软件开发整体介绍 苍穹外卖项目介绍 开发环境搭建 导入接口文档 Swagger 项目整体效果展示: 管理端-外卖商家使用 用户端-点餐用户使用 当我们完成该项目的学习,可以培养以下能力: 1. 软件开发整体介绍 作为一名软件开发工程师,我们需要了解在软件开发过程中的开发流程, 以及软件开发过程中涉及到的岗位角色,角色的分工

Springboot开发 -- @RequestBody 接收参数的实例

Spring MVC @RequestBody 实现前后端数据交互 以下是一个使用 jQuery 的 $.ajax 方法发送 POST 请求到后端,后端使用 Spring MVC 的 @RequestBody 注解接收 JSON 参数的示例。 一、前端代码实现 // 假设你已经有了要发送的密码数据 var passwordData = { oldPwd: 'oldPassword',

面试加分项:精通Java高并发下的锁优化策略

1. 问题背景与挑战 1.1 并发编程中的挑战 在现代软件开发中,高并发已成为衡量系统质量的一项关键因素,特别是对于那些需要同时处理数以万计甚至百万级用户请求的服务。并发编程的挑战在于如何有效地同步多个线程,确保数据的一致性和系统的稳定性。当多个线程试图同时访问和修改共享资源时,如果没有适当的同步机制,就会导致数据的不一致性甚至系统崩溃。 1.2 高并发场景对加锁机制的要求 在高并发场景下