网络编程
InetAdress
描述IP地址的类
没有构造函数
static InetAddress getLocalHost() 返回本地主机
static InetAddress getByName(String host) 在给定主机名的情况下确定主机的 IP 地址。
String getHostName() 获取此 IP 地址的主机名。
String getHostAddress() 返回 IP 地址字符串（以文本表现形式）。
InetAddress byName = null;
try {
byName = InetAddress.getByName("www.baidu.com");
} catch (UnknownHostException e) {
e.printStackTrace();
}
String hostName = byName.getHostName();
String hostAddress = byName.getHostAddress();
System.out.println(hostName+"--------------"+hostAddress);
//www.baidu.com--------------180.97.33.107
static InetAddress[] getAllByName(String host) 在给定主机名的情况下，根据系统上配置的名称服务返回其 IP 地址所组成的数组。
InetAddress[] allByName = InetAddress.getAllByName("www.baidu.com");
for (InetAddress inetAddress : allByName) {
System.out.println(inetAddress.getHostName()+"---------"+inetAddress.getHostAddress());
}
//www.baidu.com---------180.97.33.108
//www.baidu.com---------180.97.33.107
UDP连接
- 将数据极其源和目的封装为数据包，不需要建立连接
- 每个数据包大小限制在64K内
- 因为无连接，所以不可靠(会出出现数据丢失)
- 因为不需要建立连接，所以速度快
- udp协议是不分客户端与服务端的，只分发送端与接收端。
DatagramSocket
用来发送和接收数据报包的套接字。
构造方法
DatagramSocket()
构造数据报套接字并将其绑定到本地主机上任何可用的端口。
protected DatagramSocket(DatagramSocketImpl impl)
创建带有指定 DatagramSocketImpl 的未绑定数据报套接字。
DatagramSocket(int port)
创建数据报套接字并将其绑定到本地主机上的指定端口。
DatagramSocket(int port, InetAddress laddr)
创建数据报套接字，将其绑定到指定的本地地址。
DatagramSocket(SocketAddress bindaddr)
创建数据报套接字，将其绑定到指定的本地套接字地址。
一些方法
void receive(DatagramPacket p)
从此套接字接收数据报包。 当此方法返回时，DatagramPacket 的缓冲区填充了接收的数据。数据报包也包含发送方的 IP 地址和发送方机器上的端口号。
void send(DatagramPacket p)
从此套接字发送数据报包。
void close()
关闭此数据报套接字。
DatagramPacket
此类表示数据报包。
DatagramPacket(byte[] buf, int length)
构造 DatagramPacket，用来接收长度为 length 的数据包。
DatagramPacket(byte[] buf, int length, InetAddress address, int port)
构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。
DatagramPacket(byte[] buf, int offset, int length)
构造 DatagramPacket，用来接收长度为 length 的包，在缓冲区中指定了偏移量。
DatagramPacket(byte[] buf, int offset, int length, InetAddress address, int port)
构造数据报包，用来将长度为 length 偏移量为 offset 的包发送到指定主机上的指定端口号。
DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)
构造数据报包，用来将长度为 length 偏移量为 offset 的包发送到指定主机上的指定端口号。
DatagramPacket(byte[] buf, int length, SocketAddress address)
构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。
UDP连接实例
public class SendDome {
public static void main(String[] args) throws IOException {
//创建UDP服务对象
DatagramSocket ds = new DatagramSocket();
Scanner sc = new Scanner(System.in);
String str = null;
do {
//准备数据
str = sc.next();
//创建发送数据包
DatagramPacket p = new DatagramPacket(str.getBytes(), str.getBytes().length,InetAddress.getByName("127.0.0.1"),9999);
//发送
ds.send(p);
//创建接收缓存
byte[] buf=new byte[1024];
//创建接收数据包
DatagramPacket packet=new DatagramPacket(buf, buf.length);
//接收
ds.receive(packet);
System.out.println(new String(buf));
}while(!"exit".equals(str));
//释放资源
ds.close();
}
}
public class ReceiveDome {
public static void main(String[] args) throws IOException {
DatagramSocket ds = new DatagramSocket(9999);
Scanner sc = new Scanner(System.in);
String str = null;
do {
byte[] buf=new byte[1024];
DatagramPacket packet=new DatagramPacket(buf, buf.length);
ds.receive(packet);
System.out.println(new String(buf));
str = sc.next();
//根据receive接收的包得到发送方的地址和端口
DatagramPacket p = new DatagramPacket(str.getBytes(), str.getBytes().length,packet.getAddress(),packet.getPort());
ds.send(p);
}while(!"exit".equals(str));
ds.close();
}
}
TCP
tcp的特点：
tcp协议通讯是面向连接的，tcp的客户端一旦建立，马上要与服务端建立连接。
tcp协议在连接中传输大数据量,tcp是基于IO流进行数据传输。
通过三次握手机制连接，可靠协议(保证数据传输的完整性)
因为tcp是面向连接的，所以效率稍低.
-
tcp协议是分客户端与服务端
比如：QQ文件传输、 飞Q文件传输
tcp协议下的Socket：
Socket(客户端类)
ServerSocket(服务端)
Socket
此类实现客户端套接字（也可以就叫“套接字”）。套接字是两台机器间通信的端点。
Socket()
通过系统默认类型的 SocketImpl 创建未连接套接字
Socket(InetAddress address, int port)
创建一个流套接字并将其连接到指定 IP 地址的指定端口号。
Socket(String host, int port)
创建一个流套接字并将其连接到指定主机上的指定端口号。
void close()
关闭此套接字。
InetAddress getInetAddress()
返回套接字连接的地址。
InputStream getInputStream()
返回此套接字的输入流。
OutputStream getOutputStream()
返回此套接字的输出流。
ServerSocket
此类实现服务器套接字。服务器套接字等待请求通过网络传入。它基于该请求执行某些操作，然后可能向请求者返回结果。
ServerSocket(int port)
创建绑定到特定端口的服务器套接字。
Socket accept()
侦听并接受到此套接字的连接。
多线程下载
/**
* 服务端
* @author leex
*
*/
public class MyService {
public static void main(String[] args) {
ServerSocket ss = null;
Socket accept = null;
while(true) {
try {
//获取服务端套接字
ss = new ServerSocket(10112);
//三次握手
accept = ss.accept();
//开启一条下载线程，将客户端信息传入
new Thread(new getFile(accept)).start();;
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
//释放资源
ss.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
/**
* 多线程下载类
* @author leex
*
*/
public class getFile implements Runnable{
Socket accept;
/**
* 构造接收客户端信息
* @param accept
*/
public getFile(Socket accept) {
this.accept = accept;
}
@Override
public void run() {
//声明
OutputStream out = null;
FileInputStream in = null;
try {
//获取TCP输出流
out = accept.getOutputStream();
//创建文件输入流
in = new FileInputStream("C:\\Users\\Administrator\\Desktop\\JDK_API_1.6_zh_中文.CHM");
//循环读入写出
System.out.println(Thread.currentThread().getName()+"下载开始");
byte[] b = new byte[1024];
int len = 0;
while((len = in.read(b)) != -1) {
out.write(b,0,len);
}
//打印线程名
System.out.println(Thread.currentThread().getName()+"下载结束");
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
//释放资源
in.close();
out.flush();
out.close();
accept.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
/**
* 客户端 模拟下载
* @author leex
*
*/
public class MyCliect {
/**
* 循环十次模拟多线程
* @param args
*/
public static void main(String[] args) {
for (int i = 0; i < 10; i++) {
getFile();
}
}
private static void getFile() {
FileOutputStream out = null;
Socket s = null;
FileInputStream in = null;
try {
//文件输出流。随机名字
out = new FileOutputStream(UUID.randomUUID().toString()+".CHM");
//获取套接字
s = new Socket("127.0.0.2", 10112);
//TCP输入流
in = (FileInputStream) s.getInputStream();
//循环下载，写出
byte[] b = new byte[1024];
int len = 0;
while((len = in.read(b)) != -1) {
out.write(b,0,len);
}
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
//释放资源
out.flush();
out.close();
in.close();
s.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
