1.Scoket 667
1.1 基本介绍
1.套接字(Socket)开发网络应用程序被广泛采用,以至于成为事实上的标准。
2.通信的两端都要有Socket,是两台机器间通信的端点
3.网络通信其实就是Socket间的通信。
4. Socket允许程序把网络连接当成一个流,数据在两个Socket间通过I0传输。
5.一般主动发起通信的应用程序属客户端,等待通信请求的为服务端
1.2 示意图理解:
2. TCP 网络通信编程
2.1 基本介绍 667
1.基于客户端一 服务端的网络通信
2.底层使用的是TCP/IP协议
3.应用场景举例:客户端发送数据,服务端接受并显示控制台
4.基于Socket的TCP编程
2.2 应用案例 1(使用字节流) 668
1.编写一个服务器端,和一个客户端
2.服务器端在9999端口监听
3.客户端连接到服务器端,发送"hello, server",然后退出
4.服务器端接收到客户端发送的信息,输出,并退出
代码在com.stulzl.socket_.包中
服务端SocketTCP01Server
package com.stulzl.socket_;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
//1.编写一个服务器端,和一个客户端
//2.服务器端在9999端口监听
//3.客户端连接到服务器端,发送"hello, server",然后退出
//4.服务器端接收到客户端发送的信息,输出,并退出
//服务端 668
public class SocketTCP01Server {
public static void main(String[] args) throws IOException {
//思路
//1. 在本机 的9999端口监听, 等待连接
// 细节: 要求在本机没有其它服务在监听9999才行不然会失败报错
// 细节:这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]
ServerSocket serverSocket = new ServerSocket(9999);
System.out.println("服务端,在9999端口监听,等待连接..");
//2. 当没有客户端连接9999端口时,程序会 阻塞, 等待连接
// 如果有客户端连接,则会返回Socket对象,程序继续
Socket socket = serverSocket.accept();
System.out.println("服务端 socket =" + socket.getClass());
//3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示
InputStream inputStream = socket.getInputStream();
//4. IO读取
byte[] buf = new byte[1024];//作用是数据缓冲
int readLen = 0;
while((readLen = inputStream.read(buf)) !=-1){//循环读取
System.out.println(new String(buf,0,readLen));//根据读取到的实际长度,显示内容(数组->字符串)
}
//关闭流和socket
inputStream.close();
socket.close();
serverSocket.close();
}
}
客户端SocketTCP01Client
package com.stulzl.socket_;
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
//客户端 668
//发送 "hello, server" 给服务端
public class SocketTCP01Client {
public static void main(String[] args) throws IOException {
//思路
//1. 连接服务端 (ip , 端口)
//解读: 连接本机(InetAddress.getLocalHost()得到本机地址)的 9999端口,
// 如果连接成功,返回Socket对象
Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
System.out.println("客户端Socket返回="+socket.getClass());
//2. 连接上后,生成Socket, 通过socket.getOutputStream()
// 得到 和 socket对象关联的输出流对象
OutputStream outputStream = socket.getOutputStream();
//3. 通过输出流,写入数据到 数据通道 //getBytes()将字符串转成字节数组
outputStream.write("hello,server".getBytes());
//4. 关闭流对象和socket, 必须关闭
outputStream.close();
socket.close();
System.out.println("客户端退出……");
}
}
2.3 应用案例 2(使用字节流) 669
1.编写个服务端,和一个客户端
2.服务器端在9999端口监听
3.客户端连接到服务端,发送"hello, server”并接收服务器端回发的"hello,client",再退出
4.服务器端接收到客户端发送的信息,输出,并发送"hello, client", 再退出
代码在com.stulzl.socket_02.包中
服务端SocketTCP02Server
package com.stulzl.socket_02;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
//服务端 669
//1.编写个服务端,和一个客户端
//2.服务器端在9999端口监听
//3.客户端连接到服务端,发送"hello, server”并接收服务器端回发的"hello,client",再退出
//4.服务器端接收到客户端发送的信息,输出,并发送"hello, client", 再退出
public class SocketTCP02Server {
public static void main(String[] args) throws IOException {
//找到9999端口
ServerSocket serverSocket = new ServerSocket(9999);
//等待连接
Socket socket = serverSocket.accept();
//IO读取客户端发来的信息
InputStream inputStream = socket.getInputStream();
byte[] buf = new byte[1024];//缓冲数组
int readLen = 0;
while((readLen = inputStream.read(buf))!=-1){//循环读取
System.out.println(new String(buf,0,readLen));//输出读取到的信息
}
//给客户端回发信息"hello,client"
OutputStream outputStream = socket.getOutputStream();
outputStream.write("hello,client".getBytes());//发给客户端
//设置写入结束标记
socket.shutdownOutput();
System.out.println("服务端退出……");
//关闭
serverSocket.close();
socket.close();
inputStream.close();
outputStream.close();
}
}
客户端SocketTCP02Client
package com.stulzl.socket_02;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
//客户端 发送"hello, server” 669
public class SocketTCP02Client {
public static void main(String[] args) throws IOException {
//连接9999端口
Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
OutputStream outputStream = socket.getOutputStream();
outputStream.write("hello,server".getBytes());//发送给服务端
//设置写入结束标记
socket.shutdownOutput();
//接收服务端的返回信息
InputStream inputStream = socket.getInputStream();
byte[] buf = new byte[1024];
int readLen = 0;
while((readLen = inputStream.read(buf))!=-1){
System.out.println(new String(buf,0,readLen));//输出服务端发来的信息
}
System.out.println("客户端关闭……");
//关闭
socket.close();
outputStream.close();
inputStream.close();
}
}
2.3 应用案例 3(使用字符流) 670
1.编写一个服务端,和一个客户端
2.服务端在9999端口监听
3.客户端连接到服务端,发送"hello, server",并接收服务端回发的"hello,client",再退出
4.服务端接收到客户端发送的信息,输出,并发送"hello, client",再退出
代码在com.stulzl.socket_03.
服务端SocketTCP03Server
package com.stulzl.socket_03;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
//服务端 (使用字符流) 670
//1.编写一个服务端,和一个客户端
//2.服务端在9999端口监听
//3.客户端连接到服务端,发送"hello, server",并接收服务端回发的"hello,client",再退出
//4.服务端接收到客户端发送的信息,输出,并发送"hello, client",再退出
@SuppressWarnings("all")
public class SocketTCP03Server {
public static void main(String[] args) throws IOException {
//找到9999端口
ServerSocket serverSocket = new ServerSocket(9999);
//等待连接
Socket socket = serverSocket.accept();
//IO读取客户端发来的信息
InputStream inputStream = socket.getInputStream();
//使用字符流读取 InputStreamReader转换流将字节流转为字符流
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
String s = bufferedReader.readLine();
System.out.println(s);//输出
//给客户端回发信息"hello,client"
OutputStream outputStream = socket.getOutputStream();
//使用字符流的方式恢复信息
BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
bufferedWriter.write("hello,client 字符流");
bufferedWriter.newLine();//插入一个换行符表示写入内容结束
bufferedWriter.flush();//刷新
System.out.println("服务端退出……");
//关闭
serverSocket.close();
socket.close();
bufferedReader.close();
bufferedWriter.close();
}
}
客户端SocketTCP02Client
package com.stulzl.socket_03;
import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
//客户端 670
@SuppressWarnings("all")
public class SocketTCP03Client {
public static void main(String[] args) throws IOException {
//连接9999端口
Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
OutputStream outputStream = socket.getOutputStream();
//通过输出流,写入数据到 数据通道 使用字符流 OutputStreamWriter字节流转换为字符流
BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
bufferedWriter.write("hello,server 字符流");
bufferedWriter.newLine();//插入一个换行符表示写入内容结束,使用newLine()也要求对方使用readLine()来读
bufferedWriter.flush();//使用字符流必须手动刷新,否则数据不会写入数据通道
//接收服务端的返回信息
InputStream inputStream = socket.getInputStream();
//使用字符流读取数据
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
String s = bufferedReader.readLine();
System.out.println(s);
System.out.println("客户端关闭……");
//关闭
socket.close();
bufferedReader.close();
bufferedWriter.close();
}
}