笔记:(本题可能需要的)
TCP协议:
TCP协议进行通信的两个应用进程:客户端、服务端。
使用TCP协议前,须先建立TCP连接,形成基于字节流的传输数据通道
传输前,采用“三次握手”方式,点对点通信,是可靠的
传输完毕,需释放已建立的连接,效率低
在发送数据的准备阶段,客户端与服务器之间的三次交互,以保证连接的可靠。
在发送数据结束后,释放连接时需要经过四次挥手。
Socket类
网络上具有唯一标识的IP地址和端口号组合在一起构成唯一能识别的标识符套接字(Socket)。
Socket相关类API
ServerSocket类
ServerSocket类的构造方法:
ServerSocket(int port) :创建绑定到特定端口的服务器套接字。
ServerSocket类的常用方法:
Socket accept():侦听并接受到此套接字的连接。
Socket类
Socket类的常用构造方法:
public Socket(InetAddress address,int port):创建一个流套接字并将其连接到指定 IP 地址的指定端口号。
public Socket(String host,int port):创建一个流套接字并将其连接到指定主机上的指定端口号。
Socket类的常用方法:
public InputStream getInputStream():返回此套接字的输入流,可以用于接收消息
public OutputStream getOutputStream():返回此套接字的输出流,可以用于发送消息
public void close():关闭此套接字。套接字被关闭后,便不可在以后的网络连接中使用(即无法重新连接或重新绑定)。需要创建新的套接字对象。 关闭此套接字也将会关闭该套接字的 InputStream 和 OutputStream。
例题1:客户端发送内容给服务端,服务端将内容打印到控制台上。 注意点:先启动服务端,在启动客户端 这里的IP地址和端口号使用自己电脑的 查询IP地址:在运行框输入ipconfig 查询端口号:在运行框输入netstas -ano
客户端创建步骤:
》1创建一个Socket
创建一个IP地址,创建一个端口号;Socket是由IP地址和端口号组合在一起组合在一起的;----------IP地址和端口号都是服务端的
将IP地址和端口号传入Socket构造器中,创建Socket对象(即创建一个流套接字)
》发送数据
通过Socket对象调用getOutputStream()方法------返回此套接字的输出流
通过输出流对象调用write()方法--------书写要发送的信息
》关闭资源(在关闭前都要判断该对象是否创建成功)
关闭流资源
关闭流套接字资源
@Test// 客户端
public void client() throws IOException {
Socket socket = null;
OutputStream os = null;
try {
//创建一个Socket
InetAddress inetAddress = InetAddress.getByName("192.168.242.33");//声明对方的IP地址
int port=10620;//声明对方的端口号
socket = new Socket(inetAddress, port);
//发送数据
os = socket.getOutputStream();
os.write("你好,我是客户端,请多多关照".getBytes());
} catch (IOException e) {
e.printStackTrace();
} finally {
//关闭Socket
try {
if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
if(os!=null)
os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
服务端创建步骤
》创建一个ServerSocket(即创建绑定到特定端口的服务器套接字)
》调用accept(),接受客户端的Socket
通过前面ServerSocket的对象调用accept()方法(阻塞式方法)-----------侦听并接受到此套接字的连接。
调用accept()方法返回的是一个Socket类的对象--------表示连接成功,接受客户端的Socket
》接收数据
通过前面得到的Socket的对象来调用getInputStream()------------得到流对象
通过流的对象来读取数据
》关闭资源(在关闭前都要判断该对象是否创建成功)
关闭ServerSocket资源
关闭Socket资源
关闭流资源
@Test//服务端
public void server() throws IOException {
ServerSocket serverSocket = null;
Socket socket = null;//阻塞式的方法
InputStream is = null;
try {
//创建一个ServerSocket
int port=10620;
serverSocket = new ServerSocket(port);
//调用accept(),接受客户端的Socket
socket = serverSocket.accept();
//接收数据
is = socket.getInputStream();
byte[] buffer=new byte[1024];
int len;
ByteArrayOutputStream baos = new ByteArrayOutputStream();//内部维护了一个byte数组
while ((len=is.read(buffer))!=-1){
//错误的
// String str = new String(buffer, 0, len);
// System.out.println(str);
//正确的
baos.write(buffer,0,len);
}
System.out.println(baos.toString());
System.out.println("数据接收完毕");
} catch (IOException e) {
e.printStackTrace();
} finally {
//关闭Socket,ServerSocket,流
try {
if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
if(serverSocket!=null)
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
if(is!=null)
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}