博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JAVA网络编程
阅读量:5137 次
发布时间:2019-06-13

本文共 12234 字,大约阅读时间需要 40 分钟。

1、计算机网络

计算机网络,是指将地理位置不同的具有独立功能的多台计算 机及其外部设备,通过通信线路连接起来,从而实现信息与资 源共享的计算机系统。 

2、网络七成结构

3、网络通信协议

网络通讯协议

计算机网络中的计算机可以相互间进行信息交流。而要进行交 流,就需要具有一定的规则,我们称之为通讯协议。可以认为, 协议就是一种规范。 

相关协议:

HTTPHyperText Transfer Protocol )超文本传输协议
IPInternet Protocol)互联网协议
TCPTransmission Control Protocol)传输控制协议
UDPUser Datagram Protocol)用户数据报协议
FTPFile Transfer Protocol)文件传输协议

 

4、TCP/IP协议经常放在一起使用。在TCP/IP协议下,网络通常也 分成如下四层的结构: 

5、TCPUDP

TCP协议是基于连接的协议,该协议提供点对点的通道,在 两台计算机设备间进行可靠的数据传输。 TCP协议保证一方 发送的数据可以准确的被另一方接收,并且接收数据的顺序 与发送的顺序一致。( HTTP, FTP
UDP协议是基于数据报的协议(不是基于连接的协议),该 协议发送独立的数据报(数据包),各个数据报之间不受影 响。 UDP协议不保证接收端一定会接收到发送端发送的数据 报,同时,也不保证接收数据报

的顺序与发送的顺序一致。 ( ping

6、IP地址

在计算机网络中,可能会存在多台计算机,我们使用IP地址来区分 每台计算机。可以认为, IP地址就是每台计算机在计算机网络中的 唯一标识。 IP地址使用32位数据来表示。我们习惯上将IP地址分为 4段,每段8位。( 0~255) 

7、端口号

端口号用来标识不同的程序。端口号使用16位数据来表示。 ( 0~65535)其中, 0~1023端口被常用的系统服务所占用。我 们使用的服务不应使用这些端口。 

说明:数据传输时,会携带IP地址与端口号信息。其中, IP地址用 来识别数据传输到哪台计算机,而端口号用来识别,传输到计算 机的哪个应用程序。 

8、URL

URLUniform Resource Locator)统一资源定位,为一个字符 串序列,引用网络上的一个资源地址,该地址可以是文件,目 录,数据库查询等。
URL分为两个部分:(二者使用://进行分隔)
协议标识符 使用哪种协议获取相关资源
资源名称 资源的详细地址

例如: http://www.somewebsite.com

资源名称的格式取决于所使用的协议,大部分协议的格式如下:

主机名称
文件名称(路径)
端口号
相关引用

 

例如: http://127.0.0.1:8080/index.html#bak

说明:通常主机名称与文件名称是必须的,而端口号与相关引 用是可选的。 

Java程序中,使用URL类可以创建一个URL

绝对URLURL url = new URL("http://www.google.com");
相对URLURL url1 = new URL(“http://www.my.com/loc/”);
URL url2 = new URL(url1, “file.zip”);
说明:
URL是非可变类。

 

package day19;import java.net.MalformedURLException;import java.net.URL;public class URLMethod {	public static void main(String[] args) {		try {			URL url = new URL("http://127.0.0.1:8800/abc/123.txt?a=1&b=2#bak");			// 返回url的协议。			System.out.println(url.getProtocol());			// 返回主机。			System.out.println(url.getHost());			// 返回端口号。			System.out.println(url.getPort());			// 返回协议默认的端口号。			System.out.println(url.getDefaultPort());			// 返回文件(路径)			System.out.println(url.getPath());			// 返回查询参数			System.out.println(url.getQuery());			// 返回文件路径(包含查询参数)			System.out.println(url.getFile());			// 返回引用			System.out.println(url.getRef());		} catch (MalformedURLException e) {			e.printStackTrace();		}	}}

 9、案例:通过URL下载文件与操作本地文件。

package day19;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.MalformedURLException;import java.net.URL;public class URLTest {	public static void main(String[] args) {		try {			URL url = new URL("http://www.baidu.com");			// 返回输入流,可以读取url所定位的资源。			InputStream in = url.openStream();			BufferedReader br = new BufferedReader(new InputStreamReader(in));			String s;			while ((s = br.readLine()) != null) {				System.out.println(s);			}		} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}
package day19;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.MalformedURLException;import java.net.URL;public class Download {	public static void main(String[] args) {		URL url = null;		try {			url = new URL("https://ss0.bdstatic.com/5aV1bjqh_Q23odCf/static/superman/img/logo/bd_logo1_31bdc765.png");		} catch (MalformedURLException e1) {			e1.printStackTrace();		}		try (InputStream in = url.openStream(); OutputStream out = new FileOutputStream("c:/copy.png");) {			int b;			while ((b = in.read()) != -1) {				out.write(b);			}		} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  

package day19;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.MalformedURLException;import java.net.URL;public class LocalFile {	public static void main(String[] args) {		OutputStream out = null;		try {			URL url = new URL("file:///c:/copy.png");			InputStream in = url.openStream();			out = new FileOutputStream("c:/copy2.png");			int b;			while ((b = in.read()) != -1) {				out.write(b);			}		} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		} finally {			if (out != null) {				try {					out.close();				} catch (IOException e) {					e.printStackTrace();				}			}		}	}}

 10、URLConnection

当创建URL对象后,就可以通过URL对象的openConnection方 法打开连接,该方法返回一个URLConnection对象。通过调用 URLConnection对象的connect方法与远程指定的资源建立通讯
连接。

说明:通常,我们不需要显式调用connect方法打开连接,当执

行特定的输入输出操作时(例如getInputStream ),连接会自
动打开。

URL中读取数据

通过URLConnection类的getInputStream方法可以获得指定URL
的输入流,该方法返回一个InputStream对象。
说明:也可以直接通过URL对象的openStream方法直接获得指
定资源的输入流。

 

URL中写入数据

通过URLConnection类的getOutputStream方法可以获得指定
URL的输出流,该方法返回一个OutputStream对象。通过输出
流对象,我们就可以向服务端写入数据。
说明:客户端的输入流就是服务端的输出流,客户端的输出流
就是服务端的输入流。

package day19;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.MalformedURLException;import java.net.URL;import java.net.URLConnection;public class URLConnectionTest {	public static void main(String[] args) {		try {			URL url = new URL("http://www.baidu.com");			// 获得URL连接的对象。获得连接对象不代表已经进行了			// 真正的连接。			URLConnection con = url.openConnection();			// 设置是否可以进行读取资源,默认为true。			con.setDoInput(true);			// 设置是否可以进行写入资源。默认为false。			// 如果我们需要想URL资源写入数据,则需要			// 设置为true。			con.setDoOutput(true);			// setDoInput与setDoOutput需要在连接之间			// 进行设置。(connect之前)			// con.connect();			// 连接URL指定(定位)的资源。当进行获取输入流,			// 输出流操作时,会自动进行连接(如果该连接尚未			// 打开)。			con.connect();			InputStream in = con.getInputStream();			// url.openStream();			// 后续的操作与之前相同			// 获取URL连接(URLConenction)的输出流。			OutputStream out = con.getOutputStream();		} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  

package day19;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.io.PrintWriter;import java.net.MalformedURLException;import java.net.URL;import java.net.URLConnection;import java.nio.charset.Charset;public class URLWrite {	public static void main(String[] args) {		try {			// 获得平台使用的编码			// System.out.println(System.getProperty("file.encoding"));			// System.out.println(Charset.defaultCharset());			URL url = new URL("http://127.0.0.1/req");			URLConnection con = url.openConnection();			con.setDoOutput(true);			// 使用转换流改变编码			PrintWriter pw = new PrintWriter(new OutputStreamWriter(con.getOutputStream(), "UTF-8"), true);			pw.println("客户端的请求");			// pw.println("client request");			BufferedReader br = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8"));			String rtn = br.readLine();			// System.out.println("服务端的回应:" + rtn);			System.out.println(rtn);		} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  11、Socket

网络上的两个程序建立双向的通讯连接,这个连接的一端称
为一个socket,每个socket会绑定一个特定的端口号。客户
端与服务端通过Socket进行数据读取与写入。
Java中,使用SocketServerSocket类来实现数据的读取
与写入。
说明:相对于URLSocket是更低层的操作。当连接web时,应
该优先使用URL相关类来实现。

案例:通过SocketServerSocket实现客户端与服务端的通讯

TCP)。

package day19;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.ServerSocket;import java.net.Socket;import java.util.Scanner;public class Server {	public static void main(String[] args) {		try {			// 监听指定的端口号			ServerSocket server = new ServerSocket(8888);			// 用来接收客户端的请求。该方法在客户端请求到来前			// 会处于阻塞状态。			Socket socket = server.accept();			new Read(socket).start();			new Write(socket).start();		} catch (IOException e) {			e.printStackTrace();		}	}}class Read extends Thread {	private Socket socket;	public Read(Socket socket) {		this.socket = socket;	}	@Override	public void run() {		try {			BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));			String s;			while ((s = br.readLine()) != null) {				System.out.println(s);			}		} catch (IOException e) {			e.printStackTrace();		}	}}class Write extends Thread {	private Socket socket;	public Write(Socket socket) {		this.socket = socket;	}	@Override	public void run() {		try {			PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);			Scanner scanner = new Scanner(System.in);			while (scanner.hasNextLine()) {				pw.println(scanner.nextLine());			}		} catch (IOException e) {			e.printStackTrace();		}	}}

  

package day19;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.Socket;import java.net.UnknownHostException;import java.util.Scanner;public class Client {	public static void main(String[] args) {		try {			Socket socket = new Socket("127.0.0.1", 8888);			new Read(socket).start();			new Write(socket).start();		} catch (UnknownHostException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  12、数据报

数据报是相互独立的信息,通过网络发送。对于接收端,是
否能接收,接收时间,接收的顺序都是不确定的。
Java中,使用DatagramSocket类来发送与接收数据报。使
DatagramPacket类表示数据报(数据报包)。

案例:通过DatagramSocketDatagramPacket实现客户端与服

务端的通讯。( UDP

package day19;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.SocketException;public class UServer {	public static void main(String[] args) {		try {			DatagramSocket ds = new DatagramSocket(8888);			byte[] data = new byte[100];			DatagramPacket dp = new DatagramPacket(data, data.length);			// 接收客户端发送的数据报(数据包)。			// 该方法在接受数据报之前会一直处于阻塞状态。			ds.receive(dp);			// 获得接受的数据			// dp.getData();			// 获得数据的长度。			// dp.getLength();			// 获得发送方的IP			// dp.getAddress();			// 获得发送方的端口号。			// dp.getPort();			System.out.println(new String(dp.getData(), 0, dp.getLength()));		} catch (SocketException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  

package day19;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;import java.net.SocketException;import java.net.UnknownHostException;public class UClient {	public static void main(String[] args) {		try {			DatagramSocket ds = new DatagramSocket();			byte[] b = "你好".getBytes();			InetAddress ip = InetAddress.getByName("127.0.0.1");			DatagramPacket dp = new DatagramPacket(b, b.length, ip, 8888);			// 发送数据报			ds.send(dp);		} catch (SocketException e) {			e.printStackTrace();		} catch (UnknownHostException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}	}}

  13、广播

使用MulticastSocket类实现广播功能。
案例:多客户端发送案例。

package day19;import java.io.IOException;import java.net.DatagramPacket;import java.net.InetAddress;import java.net.MulticastSocket;public class Receiver {	public static void main(String[] args) {		try {			MulticastSocket ms = new MulticastSocket(8888);			InetAddress ip = InetAddress.getByName("224.0.0.1");			// 加入到指定的波段,就可以接收这个波段的广播。			ms.joinGroup(ip);			while (true) {				byte[] data = new byte[100];				DatagramPacket dp = new DatagramPacket(data, data.length);				ms.receive(dp);				System.out.println(new String(dp.getData(), 0, dp.getLength()));			}			// 离开指定的广播组。			// ms.leaveGroup(ip);		} catch (IOException e) {			e.printStackTrace();		}	}}

  

package day19;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;import java.net.SocketException;import java.net.UnknownHostException;import java.util.Random;public class Sender {	public static void main(String[] args) {		try {			DatagramSocket ds = new DatagramSocket();			// 广播的波段,范围限制为224.0.0.0到239.255.255.255,			// 其中224.0.0.0被保留,不能使用。			InetAddress ip = InetAddress.getByName("224.0.0.1");			while (true) {				byte[] data = getData();				DatagramPacket dp = new DatagramPacket(data, data.length, ip, 8888);				ds.send(dp);				Thread.sleep(1000);			}		} catch (SocketException e) {			e.printStackTrace();		} catch (UnknownHostException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		} catch (InterruptedException e) {			e.printStackTrace();		}	}	public static byte[] getData() {		StringBuilder b = new StringBuilder();		Random r = new Random();		for (int i = 0; i < 10; i++) {			int x = 65 + r.nextInt(26);			b.append((char) x);		}		System.out.println(b);		return b.toString().getBytes();	}}

  

转载于:https://www.cnblogs.com/liuwei6/p/6582965.html

你可能感兴趣的文章
幸运转盘v1.0 【附视频】我的Android原创处女作,请支持!
查看>>
安装 Express
查看>>
存储(硬件方面的一些基本术语)
查看>>
观察者模式
查看>>
Weka中数据挖掘与机器学习系列之基本概念(三)
查看>>
leetcode-Sort List
查看>>
中文词频统计
查看>>
Java泛型的基本使用
查看>>
bzoj2038 [2009国家集训队]小Z的袜子(hose)
查看>>
Java反射机制及其Class类浅析
查看>>
Postman-----如何导入和导出
查看>>
移动设备显示尺寸大全 CSS3媒体查询
查看>>
图片等比例缩放及图片上下剧中
查看>>
background-clip,background-origin
查看>>
【Linux】ping命令详解
查看>>
浅谈项目需求变更管理
查看>>
ASP.NET MVC 拓展ViewResult实现word文档下载
查看>>
8、RDD持久化
查看>>
第二次团队冲刺--2
查看>>
Linux上架设boost的安装及配置过程
查看>>