码迷,mamicode.com
首页 > 编程语言 > 详细

JAVA网络编程

时间:2017-03-20 00:34:53      阅读:271      评论:0      收藏:0      [点我收藏+]

标签:exce   状态   img   本地   connect   操作   local   应用程序   tin   

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();
	}
}

  

JAVA网络编程

标签:exce   状态   img   本地   connect   操作   local   应用程序   tin   

原文地址:http://www.cnblogs.com/liuwei6/p/6582965.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!