socket 网络通信基础

两台计算机网络通信的基础：
1、唯一的身份标识IP地址；
2、相同的语言即网络协议（TCP/IP）；
3、相同的端口号。（0-65535）（系统保留0-1023）
网络通信总共五层
物理——数据链路——网络——传输——应用
TCP-Transmission Control Protocol:传输控制协议；
I-Internet Protocol：互联网协议（传输层）
HTTP协议：超文本传输协议 端口开头 80
FTP协议：文件传输协议 端口开头 21
SMTP协议：简单邮件传输协议
Telnet协议：远程登录协议 端口开头 23
Java中的网络支持-针对网络通信的不同层次，java提供的网络功能有4大类：
1、InetAddress：用于标识网络上的硬件资源；
2、URL：统一资源定位符，通过URL可以直接读取或写入网络上的资源；
3、Sockets：使用TCP协议实现网络通信的Socket相关的类；
4、Datagram：使用UDP协议，将数据保存在数据报中，通过网络进行通信

InetAddress基础使用

// 获取本机的InetAddress实例
InetAddress address = InetAddress.getLocalHost();
System.out.println("计算机名：" + address.getHostName());
System.out.println("主机的IP地址：" + address.getHostAddress());
byte[] bytes= address.getAddress(); // 获取字节数组形式的IP地址
System.out.println("字节数组形式的IP地址：" + Arrays.toString(bytes));
System.out.println(address); // 直接输出InetAddress对象
// 根据机器名获取InetAddress实例
//InetAddress address2 = InetAddress.getByName("PC201512092128");
//根据IP地址获取相应的实例信息
InetAddress address2 = InetAddress.getByName("192.168.1.101");
System.out.println("计算机名：" + address2.getHostName());
System.out.println("主机的IP地址：" + address2.getHostAddress());

URL:可以通过URL资源输入流获得网页的页面
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 imooc = new URL("http://www.baidu.com");
/*// ?后面表示参数，#后面表示锚点
URL url = new URL(imooc,"/index.html?username=tom#test");
System.out.println("协议："+url.getProtocol());
System.out.println("端口:"+url.getPort());
System.out.println("主机:"+url.getHost());
System.out.println("文件路径:"+url.getPath());
System.out.println("文件名："+url.getFile());
System.out.println("文件相对路径:"+url.getRef());
System.out.println("查询字符串:"+url.getQuery());*/
//创建url资源的输入流
InputStream is = imooc.openStream();
//将字节输入流转换为字符输入流
InputStreamReader isr = new InputStreamReader(is,"utf-8");
//为字符输入流添加缓冲
BufferedReader br = new BufferedReader(isr);
//读取数据
String data = br.readLine();
while(data!=null){
System.out.println(data);//输出数据
data = br.readLine();//读取下一行
}
br.close();
isr.close();
is.close();
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

socket基础使用
Socket通信实现步骤
1.创建ServerSocket和Socket
2.打开链接到Socket的输入/输出流
3.按照协议对Socket进行读/写操作
4.关闭输入输出流、关闭Socket

***服务端代码
package socket;

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
public static void main(String[] args) {
try {
//创建一个serverSocket指定端口，并监听此端口
ServerSocket serverSocket = new ServerSocket(8888);
System.out.println("***服务器即将开启，等待客户端连接***");
Socket socket = null;
int count = 0;
while(true){
//调用accept方法开始监听，等待客户端连接
socket = serverSocket.accept();
//创建一个新的线程
ServerThread serverThread = new ServerThread(socket);
//启动线程
serverThread.start();
count++;
System.out.println("总共连接过的客户端数量:"+count);

InetAddress address = socket.getInetAddress();
System.out.println("客户端的IP:"+address.getHostAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

***客户端代码
package socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

/**
* @param args
*/
public static void main(String[] args) {
try {
//创建客户端socket，指定服务器地址和端口
Socket socket = new Socket("192.168.48.77",8888);
//获取输出流,向服务器发送信息
OutputStream os = socket.getOutputStream();
//将输出流转换为打印流
PrintWriter pw = new PrintWriter(os);
pw.write("用户名:tom;密码:456");
pw.flush();
//关闭输出流
socket.shutdownOutput();
//获取输入流，并读取客户端的响应信息
InputStream is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String info = null;
while((info=br.readLine()) != null){
System.out.println("我是客户端，服务器说："+info);
}
socket.shutdownInput();
//关闭资源
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

}

***线程类代码
package socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

/*
* 服务器线程处理类
*/
public class ServerThread extends Thread {
Socket socket = null;

public ServerThread(Socket socket) {
this.socket = socket;
}

// 线程操作相应的socket
public void run() {
// 获取字节输入流，并读取客户端信息
InputStream is = null;
// 转换为字符输入流
InputStreamReader isr = null;
// 为字符输入流添加缓冲
BufferedReader br = null;
// 获取输出流，响应客户端请求
OutputStream os = null;
PrintWriter pw = null;
try {
is = socket.getInputStream();
isr = new InputStreamReader(is);
br = new BufferedReader(isr);
String info = null;
// 循环读取客户端信息
while ((info = br.readLine()) != null) {
System.out.println("我是服务器，客户端说：" + info);
}
socket.shutdownInput();// 关闭输入流

os = socket.getOutputStream();
pw = new PrintWriter(os);
pw.write("欢迎您");
pw.flush();

socket.shutdownOutput();//关闭输出流
} catch (IOException e) {
e.printStackTrace();
}finally{
// 关闭对应资源
try {
pw.close();
os.close();
br.close();
isr.close();
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}

}
}