java TCP/UDP、Socket、URL网络编程详解
文章目录
- 网络通信协议
- 通信双方地址
- 端口号
- IP地址
- InetAddress类
- Socket 网路编程
- Socket类的常用构造器
- Socket类的常用方法
- UDP协议
- 什么是UDP协议
- UDP网络编程
- DatagramSocket 构造方法
- DatagramSocket 常用方法
- DatagramPacket常用方法
- 实现步骤
- 单向数据发收的UDP程序
- 双向数据发收的UDP程序
- TCP协议
- 什么是TCP协议
- 三次握手
- 四次挥手
- 客户端Socket
- 服务器Socket
- 示例:服务端为中转站,做聊天通讯demo
- URL
- 什么是URL
- URL类
- URL的构造方法
- URL类常用方法
- 针对HTTP协议的URLConnection类
- URL下载图片
网络通信协议
网络协议为计算机网络中进行数据交换而建立的规则、标准或约定的集合
如何实现网络中的主机互相通信,有一定的规则(即:网络通信协议。有两套参考模型)
OSI七层参考模型:开放式系统互联参考模型,模型过于理想化,未能在因特网上进行广泛推广
- 应用层、表示层、会话层;传输层、网络层、数据链路层、物理层。
TCP/IP五层参考模型(或TCP/IP协议簇):事实上的国际标准。有人将其分为四层,有人分为五层。
-
4层:应用层、传输层、网络层、网络接口层
-
5层:应用层、传输层、网络层、数据链路层、物理层
任何和互联网有关的操作都离不开TCP/IP协议
传输层协议中有两个非常重要的协议:
-
传输控制协议TCP(Transmission Control Protocol)
-
用户数据报协议UDP(User Datagram Protocol)
通信双方地址
端口号
端口号(port ID):本质是由16位二进制组成,范围:0 - 65535,0作为保留端口,所以端口号的取值范围为1 - 65535。1 - 1023是知名端口号。
端口号的作用:区分和标识不同的应用,标识正在计算机上运行的进程(程序)。不同的进程有不同的端口号。
端口分类:
-
公认端口:0~1023。被预先定义的服务通信占用(如:HTTP占用端口80,FTP占用端口21,Telnet占用端口23,443 端口分配给HTTPS服务)
-
注册端口:1024~49151。分配给用户进程或应用程序。(如:Tomcat占用端口8080,MySQL占用端口3306,Oracle占用端口1521等)
-
动态/私有端口:49152~65535
⼀般情况下,如果⼀个程序需要使⽤知名端⼝的需要有root权限
Windows查看端口CMD命令:⽤“netstat”查看端⼝状态
IP地址
IP地址是指互联网协议地址(英语:Internet Protocol Address,又译为网际协议地址),是IP Address的缩写。IP地址是IP协议提供的一种统一的地址格式,它为互联网上的每一个网络和每一台主机分配一个逻辑地址,以此来屏蔽物理地址的差异。
IP地址的作⽤:
⽤来在⽹络中标记⼀台电脑的⼀串数字,⽐如114. 114. 114. 114;在网络中的惟⼀性
IP地址的分类:
按照版本分类:早期的IP地址主要指的是IPv4,随着网络的发展IPv4的数量已经不能满足日新月异的网络发展,所以现在IP地址分为两大类:IPv4、IPv6
-
IPV4:4个字节组成,4个0-255。大概42亿,30亿都在北美,亚洲4亿。2011年初已 经用尽。以点分十进制表示,如192.168.0.1
-
IPV6:128位(16个字节),写成8个无符号整数,每个整数用四个十六进制位表示, 数之间用冒号(:)分开,如:3ffe:3201:1401:1280:c8ff:fe4d:db39:1984
按照使用范围:
IP地址分类方式2:公网地址(万维网使用)和私有地址(局域网使用)。192.168. 开头的就是私有址址,范围即为192.168.0.0–192.168.255.255,专门为组织机构内部使用。
国际规定有⼀部分IP地址是⽤于我们的局域⽹使⽤,也就是属于私⽹IP,不在公⽹中使⽤的,它们的范围是:
10.0.0.0~10.255.255.255
172.16.0.0~172.31.255.255
192.168.0.0~192.168.255.255
InetAddress类
Internet上的主机有两种方式表示地址:
域名(hostName):www.baidu.com
IP 地址(hostAddress):127.0.0.1
InetAddress类主要表示IP地址,两个子类:Inet4Address、Inet6Address。
InetAddress 类 对 象 含 有 一 个 Internet 主 机 地 址 的 域 名 和 IP 地 址 :www.baidu.com 和127.0.0.1
InetAddress类没有提供公共的构造器,而是提供了如下几个静态方法来获取 InetAddress实例
public static InetAddress getLocalHost()
public static InetAddress getByName(String host)
InetAddress提供了如下几个常用的方法
public String getHostAddress()//返回 IP 地址字符串(以文本表现形式)public String getHostName()//获取此 IP 地址的主机名public boolean isReachable(int timeout)//测试是否可以达到该地址
demo
public class InetAddressDemo {public static void main(String[] args) throws Exception{InetAddress inet1 = InetAddress.getByName("192.168.0.14");System.out.println(inet1); // /192.168.10.14InetAddress inet2 = InetAddress.getByName("www.baidu.com");System.out.println(inet2); // www.baidu.com/180.101.50.188InetAddress inet3 = InetAddress.getByName("127.0.0.1");System.out.println(inet3); // /127.0.0.1InetAddress localHost = InetAddress.getLocalHost();//查询本机IP地址System.out.println(localHost);// LAPTOP-TLQ4KBTA/192.168.83.1System.out.println(localHost.getHostName());// LAPTOP-TLQ4KBTASystem.out.println(localHost.getAddress());InetAddress address = InetAddress.getByName("www.baidu.com"); // 创建一个给定的主机的实例
// address = InetAddress.getLocalHost(); // 获取本地主机的实例System.out.println(address.getHostAddress()); // 180.101.50.188System.out.println(address.getHostName()); // www.baidu.comSystem.out.println(address.isReachable(4000)); // true}
}
Socket 网路编程
利用套接字(Socket)开发网络应用程序早已被广泛的采用,以至于成为事实上的标准。
网络上具有唯一标识的IP地址和端口号组合在一起才能构成唯一能识别的标识符套接字。
通信的两端都要有Socket,是两台机器间通信的端点。
网络通信其实就是Socket间的通信。
Socket允许程序把网络连接当成一个流,数据在两个Socket间通过IO传输。
一般主动发起通信的应用程序属客户端,等待通信请求的为服务端。
Socket分类
-
流套接字(stream socket):使用TCP提供可依赖的字节流服务
-
数据报套接字(datagram socket):使用UDP提供“尽力而为”的数据报服务
Socket类的常用构造器
public Socket(InetAddress address,int port)创建一个流套接字并将其连接到指定 IP 地址的指定端口号。public Socket(String host,int port)创建一个流套接字并将其连接到指定主机上的指定端口号。
Socket类的常用方法
public InputStream getInputStream() 返回此套接字的输入流。可以用于接收网络消息public OutputStream getOutputStream() 返回此套接字的输出流。可以用于发送网络消息public InetAddress getInetAddress() 此套接字连接到的远程 IP 地址;如果套接字是未连接的,则返回 null。public InetAddress getLocalAddress() 获取套接字绑定的本地地址。 即本端的IP地址public int getPort() 此套接字连接到的远程端口号;如果尚未连接套接字,则返回 0。public int getLocalPort() 返回此套接字绑定到的本地端口。 如果尚未绑定套接字,则返回 -1。即本端的端口号。public void close() 关闭此套接字。套接字被关闭后,便不可在以后的网络连接中使用(即无法重新连接或重新绑定)。需要创建新的套接字对象。 关闭此套接字也将会关闭该套接字的 InputStream 和 OutputStream。public void shutdownInput() 如果在套接字上调用 shutdownInput() 后从套接字输入流读取内容,则流将返回 EOF(文件结束符)。 即不能在从此套接字的输入流中接收任何数据。public void shutdownOutput() 禁用此套接字的输出流。对于 TCP 套接字,任何以前写入的数据都将被发送,并且后跟 TCP 的正常连接终止序列。 如果在套接字上调用 shutdownOutput() 后写入套接字输出流, 则该流将抛出 IOException。 即不能通过此套接字的输出流发送任何数据。
UDP协议
什么是UDP协议
UDP (用户数据报协议,User Datagram Protocol),是OSI参考模型中传输层的协议
每次传输数据的一部分,不会考虑对方是否接收的到
特点:
-
无连接:将数据、源、目的封装成数据包,不需要建立连接,不安全
-
每个数据报的大小限制在64K内
-
不可靠:发送不管对方是否准备好,接收方收到也不确认,故是不可靠的
-
可以广播发送
-
发送数据结束时无需释放资源,开销小,速度快,追求速度的网络协议
适用场景:对数据的完整性要求不高的场景,UDP⼀般⽤于多点通信和实时的数据业务
- 语⾳⼴播
- 视频
- QQ(消息,文件的上传下载使用的TCP)
- TFTP(简单⽂件传送)
- SNMP(简单⽹络管理协议)
- RIP(路由信息协议,如报告股票市场,航空信息)
- DNS(域名解释)
UDP网络编程
类 DatagramSocket 和 DatagramPacket 实现了基于 UDP 协议网络程序
UDP数据报通过数据报套接字 DatagramSocket 发送和接收,系统不保证 UDP数据报一定能够安全送到目的地,也不能确定什么时候可以抵达。
DatagramPacket 对象封装了UDP数据报,在数据报中包含了发送端的IP 地址和端口号以及接收端的IP地址和端口号。
UDP协议中每个数据报都给出了完整的地址信息,因此无须建立发送方和 接收方的连接。如同发快递包裹一样。我只管发出去,不管收不收。
DatagramSocket 构造方法
public DatagramSocket(int port)
创建数据报套接字并将其绑定到本地主机上的指定端口。套接字将被 绑定到通配符地址,IP 地址由内核来选择。public DatagramSocket(int port,InetAddress laddr)
创建数据报套接字,将其绑定到指定的本地地址。 本地端口必须在 0 到 65535 之间(包括两者)。如果 IP 地址为 0.0.0.0,套接字将被绑定到通配符地 址,IP 地址由内核选择。
DatagramSocket 常用方法
public void close()
关闭此数据报套接字。public void send(DatagramPacket p)
从此套接字发送数据报包。DatagramPacket 包含的信息指示:将 要发送的数据、其长度、远程主机的 IP 地址和远程主机的端口号。public void receive(DatagramPacket p):从此套接字接收数据报包。当此方法返回时,DatagramPacket 的缓冲区填充了接收的数据。数据报包也包含发送方的 IP 地址和发送方机器上的端口号。 此方法在接收到数据报前一直阻塞。数据报包对象的 length 字段包含所接收信息的长度。如果信息比包的长度长,该信息将被截短。public InetAddress getLocalAddress()
获取套接字绑定的本地地址。public int getLocalPort()
返回此套接字绑定的本地主机上的端口号。public InetAddress getInetAddress()
返回此套接字连接的地址。如果套接字未连接,则返回 null。public int getPort()
返回此套接字的端口。如果套接字未连接,则返回 -1。
DatagramPacket常用方法
public DatagramPacket(byte[] buf,int length)
构造 DatagramPacket,用来接收长度为 length 的数据包。 length 参数必须小于等于 buf.length。public DatagramPacket(byte[] buf,int length,InetAddress address,int port)
构造数据报包,用来将长度为 length 的包发送到指定主机上的指定端口号。length 参数必须小于等于 buf.length。public InetAddress getAddress()
返回某台机器的 IP 地址,此数据报将要发往该 机器或者是从该机器接收到的。public int getPort()
返回某台远程主机的端口号,此数据报将要发往该主机或 者是从该主机接收到的。public byte[] getData()
返回数据缓冲区。接收到的或将要发送的数据从缓冲区 中的偏移量 offset 处开始,持续 length 长度。public int getLength()
返回将要发送或接收到的数据的长度。
实现步骤
1. 导入DatagramSocket与DatagramPacket包2. 建立发送端,接收端3. 建立数据包4. 调用数据报套接字的发送、接收方法5. 关闭数据报套接字
注意:发送端与接收端是两个独立的运行程序,也可以使用多线程同时实现收发
单向数据发收的UDP程序
发送方
public class UdpServer {public static void main(String[] args) {try {while (true) {Scanner scan = new Scanner(System.in);System.out.println("请输入你要发送的消息:");String msg = scan.nextLine();byte[] bytes = msg.getBytes();DatagramPacket datagramPacket = new DatagramPacket(bytes, 0, bytes.length, InetAddress.getByName("127.0.0.1"), 8000);DatagramSocket datagramSocket = new DatagramSocket(9000);datagramSocket.send(datagramPacket);datagramSocket.close();}} catch (UnknownHostException e) {throw new RuntimeException(e);} catch (SocketException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}
}
接收方
public class UdpClient {public static void main(String[] args) {byte[] bytes = new byte[1024];DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);try {DatagramSocket datagramSocket = new DatagramSocket(8000);while (true) {System.out.println("正在接收数据");datagramSocket.receive(datagramPacket);String s = new String(datagramPacket.getData(), 0, datagramPacket.getLength());System.out.println(s);}} catch (SocketException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}
}
双向数据发收的UDP程序
主机1:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;public class UdpServer1 {public static final String DES_IP = "127.0.0.1";public static final Integer DES_POST = 8888;private static DatagramSocket udpSocket = null;public static void main(String[] args) {try {udpSocket = new DatagramSocket(8080);} catch (SocketException e) {e.printStackTrace();}// 发送数据的线程Thread threadSend = new Thread(new Runnable() {@Overridepublic void run() {Scanner scan = new Scanner(System.in);while (true) {System.out.println("请输入消息:");String msg = scan.nextLine();byte[] bytes = msg.getBytes();DatagramPacket data = new DatagramPacket(bytes, 0, bytes.length,new InetSocketAddress(DES_IP, DES_POST));try {udpSocket.send(data);} catch (IOException e) {e.printStackTrace();}}}});// 接收数据的线程Thread threadReceive = new Thread(new Runnable() {@Overridepublic void run() {while (true) {byte[] bytes = new byte[1024];DatagramPacket receiveData = new DatagramPacket(bytes, 0, bytes.length);try {udpSocket.receive(receiveData);} catch (IOException e) {e.printStackTrace();}String data = new String(receiveData.getData(),0,receiveData.getLength());System.out.println("接收到来自:" + receiveData.getAddress().getHostAddress()+ ":" + receiveData.getPort() + ",消息为:" + data);}}});threadSend.start();threadReceive.start();}
}
主机2:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;public class UdpServer2 {public static final String DES_IP = "127.0.0.1";public static final Integer DES_POST = 8080;private static DatagramSocket udpSocket = null;public static void main(String[] args) {try {udpSocket = new DatagramSocket(8888);} catch (SocketException e) {e.printStackTrace();}// 发送数据的线程Thread threadSend = new Thread(new Runnable() {@Overridepublic void run() {Scanner scan = new Scanner(System.in);while (true) {System.out.println("请输入消息:");String msg = scan.nextLine();byte[] bytes = msg.getBytes();DatagramPacket data = new DatagramPacket(bytes, 0, bytes.length,new InetSocketAddress(DES_IP, DES_POST));try {udpSocket.send(data);} catch (IOException e) {e.printStackTrace();}}}});// 接收数据的线程Thread threadReceive = new Thread(new Runnable() {@Overridepublic void run() {while (true) {byte[] bytes = new byte[1024];DatagramPacket receiveData = new DatagramPacket(bytes, 0, bytes.length);try {udpSocket.receive(receiveData);} catch (IOException e) {e.printStackTrace();}String data = new String(receiveData.getData(),0,receiveData.getLength());System.out.println("接收到来自:" + receiveData.getAddress().getHostAddress()+ ":" + receiveData.getPort() + ",消息为:" + data);}}});threadSend.start();threadReceive.start();}
}
TCP协议
什么是TCP协议
TCP协议,传输控制协议(Transmission Control Protocol)
TCP通信模型中,在通信开始之前,⼀定要先建⽴相关的连接,才能发送数据,类似于⽣活中,“打电话”。
特点:
-
面向连接:使用TCP协议前,须先建立TCP连接,形成传输数据通道
-
传输前,采用“三次握手”方式,点对点通信,是可靠的
-
TCP协议进行通信的两个应用进程:客户端、服务端。
-
在连接中可进行大数据量的传输,有流控机制
-
传输完毕,需释放已建立的连接,效率低
TCP和UDP的使用场景:
- TCP更适合应用在对效率要求不高,但对准确性要求较高的场景;
- UDP更适合在对效率要求较高,但对准确性要求较低的场景。
三次握手
三次握手机制是TCP协议在传输数据前建立连接的机制
三次挥手的过程:
-
客户端:syn请求报文,SYN = 1,发送序号seq = x(随机的),
-
服务器:ack应答报文 + syn请求报文:ACK = 1,SYN = 1,应答序号acknumber = x+1,发送序号seq = y(随机值);
-
客户端:ack应答报文,ACK = 1,seq = x+1,acknumber = y+1。
经典面试题:三次握手为什么是三次,不能是两次或者四次吗?
四次挥手
四次挥手机制是TCP协议在传输数据结束断开连接的机制
四次挥手的过程:
-
客户端A:发送fin结束报文,FIN = 1,seq = u(带数据量的);
-
服务器B:发送ack应答报文,ACK = 1,acknumber = u + 1,此时A指向B的连接就断开了。因为此时B可能还有数据要发,所以B给A发的FIN数据包没有和ACK包一起发。
-
服务器B:当B的数据发完以后,B给A发第三个数据包:FIN = 1,seq = w;
-
客户端A:发送ack应答报文,ACK = 1,seq = u + 1,acknumber = w + 1,此时B指向A的连接就断开了。
至此四次挥手就结束了。注:过程中的序号是包含数据量的。
客户端Socket
客户端Socket的工作过程包含以下四个基本的步骤:
-
创建 Socket:根据指定服务端的 IP 地址或端口号构造 Socket 类对象。若服务器端响应,则建立客户端到服务器的通信线路。若连接失败,会出现异常。
-
打开连接到 Socket 的输入/出流: 使用 getInputStream()方法获得输入流,使用getOutputStream()方法获得输出流,进行数据传输
-
按照一定的协议对 Socket 进行读/写操作:通过输入流读取服务器放入线路的信息(但不能读取自己放入线路的信息),通过输出流将信息写入线程。
-
关闭 Socket:断开客户端到服务器的连接,释放线路
客户端程序可以使用Socket类创建对象,创建的同时会自动向服务器方发起连接。
Socket的构造器:
Socket(String host,int port)throws UnknownHostException,IOException
向服务器(域名是 host。端口号为port)发起TCP连接,若成功,则创建Socket对象,否则抛出异常。Socket(InetAddress address,int port)throws IOException
根据InetAddress对象所表示的IP地址以及端口号port发起连接。
示例:
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;public class SocketClient {public static void main(String[] args) throws IOException {Socket s = new Socket("127.0.0.1",6666);OutputStream out = s.getOutputStream();out.write("你好,荷逸".getBytes());s.close();}
}
服务器Socket
服务器程序的工作过程包含以下四个基本的步骤:
-
调用 ServerSocket(int port) :创建一个服务器端套接字,并绑定到指定端口上。用于监听客户端的请求。
-
调用 accept():监听连接请求,如果客户端请求连接,则接受连接,返回通信套接字对象。
-
调用该Socket类对象的 getOutputStream() 和 getInputStream ():获取输出流和输入流,开始网络数据的发送和接收。
-
关闭ServerSocket和Socket对象:客户端访问结束,关闭通信套接字。
ServerSocket 对象负责等待客户端请求建立套接字连接,类似邮局某个窗口中的业务员。也就是说,服务器必须事先建立一个等待客户请求建立套接字连接的ServerSocket对象。
所谓“接收”客户的套接字请求,就是accept()方法会返回一个 Socket 对象
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class SocketAtServer {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(6666);Socket s = ss.accept();InputStream in = s.getInputStream();byte[] buf = new byte[1024];int num = in.read(buf);String str = new String(buf, 0, num);System.out.println(s.getInetAddress().toString() + ":" + str);s.close();ss.close();}
}
示例:服务端为中转站,做聊天通讯demo
定义消息模型:
import java.io.Serializable;public class Message implements Serializable {private String to;private String from;private int type;private String info;public Message(String to, String from, int type, String info) {this.to = to;this.from = from;this.type = type;this.info = info;}public Message() {}public int getType() {return type;}public void setType(int type) {this.type = type;}public String getTo() {return to;}public void setTo(String to) {this.to = to;}public String getFrom() {return from;}public void setFrom(String from) {this.from = from;}public String getInfo() {return info;}public void setInfo(String info) {this.info = info;}@Overridepublic String toString() {return "Message{" +"to='" + to + '\'' +", from='" + from + '\'' +", type=" + type +", info='" + info + '\'' +'}';}
}
消息类型:
public class MessageType {public final static int MESSAGE_LOGIN = 0x1;public final static int MESSAGE_SEND = 0x2;
}
客户端:
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Client {public static void main(String[] args) {Scanner scanner = new Scanner(System.in);ExecutorService e = Executors.newFixedThreadPool(5);try {Socket socket = new Socket("127.0.0.1", 6666);System.out.println("服务器链接成功");System.out.println("请输入名称:");String name = scanner.nextLine();System.out.println("姓名" + name);ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());Message message = new Message(null, name, MessageType.MESSAGE_LOGIN, null);objectOutputStream.writeObject(message);Message m = (Message) objectInputStream.readObject();System.out.println(m.getFrom() + m.getInfo());ReadInfoThread readInfoThread = new ReadInfoThread(objectInputStream);e.execute(readInfoThread);boolean flag = true;while (flag) {Message msg = new Message();System.out.println("请输入要接收的人:");msg.setTo(scanner.nextLine());System.out.println("请输入要发送的消息");msg.setInfo(scanner.nextLine());msg.setFrom(name);msg.setType(MessageType.MESSAGE_SEND);objectOutputStream.writeObject(msg);}} catch (IOException exception) {throw new RuntimeException(exception);} catch (ClassNotFoundException ex) {throw new RuntimeException(ex);}}}class ReadInfoThread implements Runnable {private ObjectInputStream objectInputStream;private boolean flag = true;public ReadInfoThread(ObjectInputStream objectInputStream) {this.objectInputStream = objectInputStream;}public void setFlag(boolean flag) {this.flag = true;}@Overridepublic void run() {try {while (flag) {Message message = (Message) objectInputStream.readObject();System.out.println("【" + message.getFrom() + "】:" + message.getInfo());}if (objectInputStream != null) {objectInputStream.close();}} catch (IOException | ClassNotFoundException e) {throw new RuntimeException(e);}}
}
服务端:
public class Server {public static void main(String[] args) {Hashtable<String, UserThread> hashtable = new Hashtable<>();ExecutorService executorService = Executors.newFixedThreadPool(5);try {ServerSocket serverSocket = new ServerSocket(6666);System.out.println("服务器已启动等待链接");while (true) {Socket socket = serverSocket.accept();UserThread userThread = new UserThread(socket, hashtable);executorService.execute(userThread);}} catch (IOException e) {throw new RuntimeException(e);}}
}class UserThread implements Runnable {private String name = "";private Socket socket;private Hashtable<String, UserThread> hashtable;private ObjectInputStream ois;private ObjectOutputStream oos;private boolean flag = true;public UserThread(Socket socket, Hashtable<String, UserThread> hashtable) {this.socket = socket;this.hashtable = hashtable;this.flag = true;}@Overridepublic void run() {System.out.println("客户端地址 " + socket.getInetAddress().getHostAddress());try {oos = new ObjectOutputStream(socket.getOutputStream());ois = new ObjectInputStream(socket.getInputStream());while (flag) {Message message = (Message) ois.readObject();int type = message.getType();switch (type) {case MessageType.MESSAGE_SEND:UserThread userThread = hashtable.get(message.getTo());System.out.println(userThread);if (userThread == null) {oos.writeObject(message.getTo() + "不在线");}if (userThread == this) {oos.writeObject("不能给自己发消息");}userThread.oos.writeObject(message);break;case MessageType.MESSAGE_LOGIN:name = message.getFrom();hashtable.put(name, this);message.setInfo("登录成功");oos.writeObject(message);break;}}ois.close();oos.close();} catch (IOException | ClassNotFoundException e) {System.out.println(e.getMessage());throw new RuntimeException(e);}}
}
URL
什么是URL
URL(Uniform Resource Locator):统一资源定位符,它表示 Internet 上某一资源的地址。
它是一种具体的URI,即URL可以用来标识一个资源,而且还指明了如何locate 这个资源。
通过 URL 我们可以访问 Internet 上的各种网络资源,比如最常见的 www,ftp 站点。浏览器通过解析给定的 URL 可以在网络上查找相应的文件或其他资源。
URL的基本结构由5部分组成:
<传输协议>://<主机名>:<端口号>/<文件名>#片段名?参数列表
例如: http://192.168.1.100:8080/helloworld/index.jsp#a?username=shkstart&password=123
参数列表格式:参数名=参数值&参数名=参数值…
URL类
URL的构造方法
为了表示URL,java.net 中实现了类 URL。我们可以通过下面的构造器来初始化一个 URL 对象:
- public URL (String spec); 通过一个表示URL地址的字符串可以构造一个URL对象。
URL url = new URL ("http://www.baidu.com/");
- public URL(URL context, String spec); 通过基 URL 和相对 URL 构造一个 URL 对象。
URL downloadUrl = new URL(url, "download.html");
- public URL(String protocol, String host, String file);
new URL("http", "www.baidu.com", "download. html");
- public URL(String protocol, String host, int port, String file);
URL gamelan = new URL("http", "www.baidu.com", 80, "download.html");
URL类的构造器都声明抛出非运行时异常,必须要对这一异常进行处理,通常是用 try-catch 语句进行捕获
URL类常用方法
一个URL对象生成后,其属性是不能被改变的,但可以通过它给定的方法来获取这些属性。
public String getProtocol( ) 获取该URL的协议名public String getHost( ) 获取该URL的主机名public String getPort( ) 获取该URL的端口号public String getPath( ) 获取该URL的文件路径public String getFile( ) 获取该URL的文件名public String getQuery( ) 获取该URL的查询名
URL url = new URL("https://pics1.baidu.com/feed/7acb0a46f21fbe09c16218d19b0eb1388644adb6.png@f_auto?token=fac0558642f57b4d98725dfd0f30f14a");
//public String getProtocol( ) 获取该URL的协议名
System.out.println(url.getProtocol());
//public String getHost( ) 获取该URL的主机名
System.out.println(url.getHost());
//public String getPort( ) 获取该URL的端口号
System.out.println(url.getPort());
//public String getPath( ) 获取该URL的文件路径
System.out.println(url.getPath());
//public String getFile( ) 获取该URL的文件名
System.out.println(url.getFile());
//public String getQuery( ) 获取该URL的查询名
System.out.println(url.getQuery());
针对HTTP协议的URLConnection类
URL的方法 openStream():能从网络上读取数据
若希望输出数据,例如向服务器端的 CGI (公共网关接口-Common Gateway Interface-的简称,是用户浏览器和服务器端的应用程序进行连接的接口)程序发送一些数据,则必须先与URL建立连接,然后才能对其进行读写,此时需要使用URLConnection。
URLConnection:表示到URL所引用的远程对象的连接。当与一个URL建立连接时,首先要在一个 URL 对象上通过方法 openConnection() 生成对应的 URLConnection 对象。如果连接过程失败,将产生IOException。
URL netchinaren = new URL ("http://www.atguigu.com/index.shtml");URLConnectonn u = netchinaren.openConnection( );
通过URLConnection对象获取的输入流和输出流,即可以与现有的CGI 程序进行交互。
public Object getContent( ) throws IOExceptionpublic int getContentLength( )public String getContentType( )public long getDate( )public long getLastModified( )public InputStream getInputStream( )throws IOExceptionpublic OutputSteram getOutputStream( )throws IOException
URL下载图片
//下载图片
public class UrlDemo {public static void main(String[] args) {try {URL url = new URL("https://pics1.baidu.com/feed/7acb0a46f21fbe09c16218d19b0eb1388644adb6.png@f_auto?token=fac0558642f57b4d98725dfd0f30f14a");HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();BufferedInputStream in = new BufferedInputStream(urlConnection.getInputStream());BufferedOutputStream bs = new BufferedOutputStream(new FileOutputStream("F:\\1.png"));byte[] bytes = new byte[1024];int len = -1;while ((len = in.read(bytes)) != -1) {bs.write(bytes, 0, len);bs.flush();}in.close();bs.close();urlConnection.disconnect();System.out.println("下载成功");} catch (MalformedURLException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}
}
相关文章:

java TCP/UDP、Socket、URL网络编程详解
文章目录网络通信协议通信双方地址端口号IP地址InetAddress类Socket 网路编程Socket类的常用构造器Socket类的常用方法UDP协议什么是UDP协议UDP网络编程DatagramSocket 构造方法DatagramSocket 常用方法DatagramPacket常用方法实现步骤单向数据发收的UDP程序双向数据发收的UDP程…...

【C语言】宏
🚀write in front🚀 📜所属专栏:> c语言学习 🛰️博客主页:睿睿的博客主页 🛰️代码仓库:🎉VS2022_C语言仓库 🎡您的点赞、关注、收藏、评论,是…...

【测试面试】自我分析+功能+接口自动化+性能测试面试题(大全),知己知彼百战百胜......
目录:导读前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结(尾部小惊喜)前言 分析自己和面试企业…...

ASE4N65SE-ASEMI高压MOS管ASE4N65SE
编辑-Z ASE4N65SE在TO-220F封装里的静态漏极源导通电阻(RDS(ON))为2.5Ω,是一款N沟道高压MOS管。ASE4N65SE的最大脉冲正向电流ISM为16A,零栅极电压漏极电流(IDSS)为10uA,其工作时耐温度范围为-55~150摄氏度。ASE4N65S…...

MyBatis概述环境搭建(一)
🚗MyBatis学习起始站~ 🚩本文已收录至专栏:数据库学习之旅 👍希望您能有所收获 一.什么是MyBatis (1) 引言 MyBatis 是一款优秀的持久层框架,它支持自定义 SQL、存储过程以及高级映射。MyBatis 免除了几乎所有的 JDB…...
3.8国际妇女节即将到来,跨境卖家如何做好选品和营销?
不知不觉,时间已来到了2月末,一年一度的三八国际妇女节也即将来临。三八节又称女神节,这不仅是庆祝女性伟大贡献的日子,也是跨境卖家们促销的大好时机。 有数据显示,女性是跨境消费的主力人群,占比超七成&…...

Glue Connector 和 Connection 的关系与区别
AWS Glue作为一种无服务器产品,其运行环境是“不可预知”的,也就是“一个黑盒”,所以如何能连接一些自有数据源是Glue必须考虑并给予满足的,为此,Glue给出的解决方案就是Connector和Connection,一个connect…...

如何使用ngxin的 upstream
1.引言: 1.1反向代理: 反向代理是充当Web服务器网关的代理服务器。当您将请求发送到使用反向代理的Web服务器时,他们将先转到反向代理,由该代理将确定是将其路由到Web服务器还是将其阻止。 这意味着有了反向代理,您…...

Java数组,超详细整理,适合新手入门
目录 一、什么是Java中的数组? 二、数组有哪些常见的操作? 三、数组的五种赋值方法和使用方法 声明数组 声明数组并且分配空间 声明数组同时赋值(1) 声明数组同时赋值(2) 从控制台输入向数组赋值 四、求总和平均 五、求数组中最大值最小值 六…...
1.3数据传输控制方式:IO数据传输控制方式、程序控制(查询)方式、程序中断方式、DMA方式、通道方式、I/O处理机
1.3数据传输控制方式:IO数据传输控制方式、程序控制(查询)方式、程序中断方式、DMA方式、通道方式、I/O处理机程序控制(查询)方式程序中断方式DMA方式通道方式、I/O处理机I/O数据传输方式,由软件到硬件发展…...
Linux 设置语言
文章目录1. 临时设置环境变量2. 默认语言设置3. 语言包4. 安装浏览器 chromium1. 临时设置环境变量 通过设置环境变量,可以使单个命令使用另一种语言LANG $ LANGfr_FR.utf8 date mar. mai 24 12:16:51 CDT 2022后续命令将恢复为使用系统的默认语言进行输出。该loc…...
Python基础-数据类型之集合
一、集合的定义 集合:是一个无序的没有重复元素的序列,因此不能通过索引来进行操作 1:使用set()创建集合 set(object) # 参数为一个序列,整型不能作为参数 set_a set("abcb") print(set_a) # {b, a, c} 2&…...

[Css]Grid属性简单陈列(适合开发时有基础的快速过一眼)
[css进阶]Grid属性简介 文章目录[css进阶]Grid属性简介典型需求网格容器的属性displaygrid-template-columns和grid-template-rowsgrid-template-areasgrid-templategrid-column-gap grid-row-gapgrid-gapjustify-itemsalign-itemsjustify-contentalign-contentgrid-auto-colum…...

100种思维模型之启发式偏差思维模型-017
曾国藩在给儿子的一封家书中曾写道:余于凡事皆用困知勉行工夫,尔不可求名太骤,求效太捷也。熬过此关,便可少进。再进再困,再熬再奋,自有亨通精进之日。 不急躁不求捷径,小火慢炖,将事…...
微服务 feign远程调用时 显示服务不可用 timed-out and no fallback
目录 第一种: failed and no fallback available 1 服务挂掉了 2 服务没有开启 3 注册中心没注册进去 -> ps: 直接调用的接口 通过网关转发失败 会报503 4 高并发下的服务熔断了 第二种: timed-out and no fallback 2.1 业务场景: A服务一切正常 但是B服务显示timeo…...

第一个Java程序(初识Java)
个人主页:平行线也会相交 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 平行线也会相交 原创 收录于专栏【JavaSE_primary】 文章目录1.Java概述1.1什么是Java1.2Java之父2.0第一个Java程序编译运行.class3.0程序如何跑起来的?3.1J…...

vulnhub LordOfTheRoot_1.0.1
总结:端口敲门,CVE-2015-8660提权, 目录 下载地址 漏洞分析 信息收集 端口敲门 网站分析 方法一 ssh登录提权 方法二 下载地址 LordOfTheRoot_1.0.1.ova (Size: 1.6 GB)Download: http://www.mediafire.com/download/m5tbx0dua05szjm…...
MutationObserver与IntersectionObserver
MutationObserver 出现原因:当我们需要监听元素发生变化时,不借助使元素发生变化的业务动作的情况下,使用无污染方式监听非常困难,为了解决这个问题,MutationObserver诞生! 概述 可以用来监听DOM的任何变化…...
【ESP 保姆级教程】玩转巴法云篇② ——MQTT设备云,MQTT协议下的数据通信
忘记过去,超越自己 ❤️ 博客主页 单片机菜鸟哥,一个野生非专业硬件IOT爱好者 ❤️❤️ 本篇创建记录 2023-02-21 ❤️❤️ 本篇更新记录 2023-02-21 ❤️🎉 欢迎关注 🔎点赞 👍收藏 ⭐️留言📝🙏 此博客均由博主单独编写,不存在任何商业团队运营,如发现错误,请…...

植物大战 仿函数——C++
容器适配器 容器适配器不支持迭代器。栈这个东西,让你随便去遍历,是不好的。他是遵循后进先出的。所以他提供了一个街头top取得栈顶数据。 仿函数 仿函数(functor)是C中一种重载了函数调用运算符(operator()&#x…...

【C语言】浮点型数据在内存中的存储
🚀🚀🚀 如果文章对你有帮助不要忘记点赞关注收藏哦🚀🚀🚀 文章目录⭐浮点数在内存中的存储1.1 🤓举个例子:1.2浮点数存储规则🌈:对于M与E有一些特别规定1.3解释前面题目&…...
impala中的刷新元数据和刷新表
impala是Cloudera公司主导开发的新型查询系统,它提供SQL语义,能查询存储在Hadoop的HDFS和HBase中的PB级大数据。 虽然Hive系统也提供了SQL语义,但由于Hive底层执行使用的是MapReduce引擎,仍然是一个批处理过程,难以满…...

Vscode创建vue项目的详细步骤
目录 一、概述 操作的前提 二、操作步骤 一、概述 后端人员想在IDEA里面创建一个Vue的项目,但是这非常麻烦,用vscode这个前端专用软件创建就会非常快速。 操作的前提 1.安装vscode软件的步骤:vscode下载和安装教程和配置中文插件&#…...

如何在面试中介绍自己的项目,才能让软件测试面试官无可挑剔,
四、项目 4.1 简单介绍下最近做过的项目 根据自己的项目整理完成,要点: 1)项目背景、业务、需求、核心业务的流程 2)项目架构,B/S还是C/5,数据库用的什么? 中间件用的什么?后台什么语言开发…...

虹科方案|从 uCPE 到成熟的边缘计算平台
基于开放硬件平台,通用客户端设备 (uCPE) 支持快速添加、集成或删除任意数量的集中管理虚拟功能。 为了增加收入并保持竞争优势,托管服务提供商 (MSP) 和企业正在部署 uCPE 以增强业务敏捷性、加速新服务的引入并提高运营效率。最初,uCPE被部…...

计算机是怎么读懂C语言的?
文章目录前言程序环境翻译环境翻译环境分类编译预处理预处理符号预定义符号#define#undef命令行定义条件编译文件包含头文件包含查找规则嵌套文件包含其他预处理指令编译阶段汇编链接🎉welcome🎉 ✒️博主介绍:博主大一智能制造在读ÿ…...

hadoop入门介绍及各组件功能运行关系
文章目录Hadoop 组成部分1.HDFS2.MapReduce 架构概述3. yarn 架构概述4.HDFS、YARN、MapReduce三者关系Hadoop 组成部分 1.HDFS Hadoop Distributed File System,简称 HDFS,是一个分布式文件系统。 HDFS 架构概述 主要分为 NameNode (mn):存储文件的元…...

(HP)新手引导使用react-shepherd
1,官方参数文档:https://shepherdjs.dev/docs/tutorial-02-usage.html 2,基本代码 import { ShepherdTour } from react-shepherd; import ./index.less; // 自己的样式文件,用来修改样式 import ./shepherd.less; // 将shephe…...

数据结构:栈和队列(Leetcode20. 有效的括号+225. 用队列实现栈+232. 用栈实现队列)
目录 一.数据结构--栈 1.栈的基本介绍 2.栈的实现 二.数据结构--队列 1.队列的基本介绍 2.队列的实现 三.栈的运用(Leetcode20. 有效的括号225) 1.问题描述 2.问题分析 题解代码: 四.用两个队列实现栈(225. 用队列实现栈 - 力扣(Leetcode&a…...
22.2.19周赛双周赛(贪心、记忆化搜索...)
文章目录双周赛98[6359. 替换一个数字后的最大差值](https://leetcode.cn/problems/maximum-difference-by-remapping-a-digit/)[6361. 修改两个元素的最小分数](https://leetcode.cn/problems/minimum-score-by-changing-two-elements/)贪心排序[6360. 最小无法得到的或值](ht…...