1.Socket编程
套接字使用TCP建立两台计算机之间的通信机制，客户端程序创建一个套接字尝试连接服务器的套接字。当建立连接时，服务器创建Socket对象，随后，客户端和服务器可以通过Socket对象的写入和读取来进行通信。Java.net.Socket类代表一个套接字，并且Java.net.ServerSocket类为服务器提供了一种来监听客户端bingyu2他们建立连接的机制
- 服务器实例化一个ServerSocket对象，表示通过服务器的端口进行通信
- ServerSocket类accept()方法监听，直到客户端连接服务器
- 服务器在等待过程中，一个客户端实例化一个Socket对象，指定服务器名称和端口号来请求连接
- Socket类的构造函数将客户端连接到指定的服务器和端口号。如果通信被建立，则在客户端创建一个Socket对象与服务器通信
- 服务器端，accept()方法返回服务器上一个socket引用，该socket连接到客户端的socket
连接建立后，通过I/O流通信，每一个Socket都有一个输入输出流，客户端的输出流连接到服务器端的输入流，客户端的输入流连接到服务器端的输出流；TCP是双向的传输控制协议，数据可以通过两个数据流在同一时间发送。
1.1Socket类构造方法及常用方法：
java.net.Socket类是服务器端和客户端用来沟通的套接字
- 客户端通过实例化获取Socket对象
- 服务器端通过ServerSocket的accept()方法的返回值来获取Socket对象
public Socket(String host, int port) //创建流套接字并连接到指定主机上的指定端口号
public Socket(InetAddress host, int port)//创建流套接字并连接到指定 IP 地址的指定端口号
public Socket()//通过系统默认类型的 SocketImpl 创建未连接套接字
//远程传递四个参数当Socket构造方法返回，会尝试连接到指定服务器和端口，因为客户端和服务器端Socket对象，可以调用socket方法：
public InetAddress getInetAddress()//返回套接字连接的地址
public InputStream getInputStream() //返回此套接字的输入流
public OutputStream getOutputStream()//返回此套接字的输出流
public SocketAddress getRemoteSocketAddress()//返回此套接字连接远程的端点的地址1.2 ServerSocket类的构造方法及常用方法
public ServerSocket()//创建非绑定服务器套接字
public ServerSocket(int port) //创建绑定到特定端口的服务器套接字
ublic ServerSocket(int port, int backlog)// 利用指定的 backlog监听创建服务器套接字并将其绑定到指定的本地端口号调用ServerSocket构造方法-应用程序已经成功绑定指定端口，侦听客户端请求
public Socket accept()//侦听并接受到此套接字的连接
public void bind(SocketAddress host, int backlog)// ServerSocket 绑定到特定地址(IP+端口)
public int getLocalPort()//返回此套接字在其上侦听的端口
1.3InetAddress类(互联网协议)IP地址的方法
String getHostName() //获取IP地址主机名
static InetAddress getByAddress(byte[] addr)//在给定原始 IP 地址的情况下，返回 InetAddress 对象
static InetAddress getByName(String host)//在给定主机名的情况下确定主机的 IP 地址
Socket连接服务器发送请求，等待响应
package com.day13;
import com.sun.security.ntlm.Server;
import java.io.*;
import java.net.Socket;
/**
* @author SFJ
* @date 2019/11/19
* @time 21:29
**/
public class Test1 {
public static void main(String[] args) {//args数组传递参数
String serverName = args[0];//第一个参数
int port = Integer.parseInt(args[1]);//转成整型数据
System.out.println("ServerName:"+serverName+" Port:"+port);
try {
Socket client = new Socket(serverName,port);
System.out.println("RemoteHostAddress:"+client.getRemoteSocketAddress());
OutputStream outputStreamToServer = client.getOutputStream();//返回此套接字输出流
DataOutputStream outputStream = new DataOutputStream(outputStreamToServer);
outputStream.writeUTF("hello comes from"+client.getLocalSocketAddress());
InputStream inputStreamFromServer = client.getInputStream();
DataInputStream inputStream = new DataInputStream(inputStreamFromServer);
System.out.println("Server response:"+inputStream.readUTF());
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
服务器应用程序-Socket监听指定端口
package com.day13;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @author SFJ
* @date 2019/11/19
* @time 21:55
**/
public class Test2 {
public static void main(String[] args) {
int port = Integer.parseInt(args[0]);
try {
Thread thread = new Server(port);
thread.run();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class Server extends Thread{
private ServerSocket serverSocket;
public Server(int port) throws IOException
{
serverSocket = new ServerSocket(port);
serverSocket.setSoTimeout(22222);
}
public void run()
{
for (;;)
{
System.out.println("Waiting for connection-Port:"+serverSocket.getLocalPort());
try {
Socket server = serverSocket.accept();
System.out.println("RemoteSocketAddress: "+server.getRemoteSocketAddress());
DataInputStream inputStream = new DataInputStream(server.getInputStream());
System.out.println(inputStream.readUTF());
DataOutputStream outputStream = new DataOutputStream(server.getOutputStream());
outputStream.writeUTF("Thanks for connecting me "+server.getLocalSocketAddress()+"\nbye");
server.close();
} catch (IOException e) {
e.printStackTrace();
System.out.println("timed out");
}
}
}
}