java通过ServerSocket与Socket实现通信
首先说一下ServerSocket与Socket. 1.ServerSocketServerSocket是用来监听客户端Socket连接的类,如果没有连接会一直处于等待状态. (1)ServerSocket(int port); 这个使用指定的端口去创建ServerSocket,IP地址使用默认的本地IP地址. (2)ServetSocket(int port,int backlog); 除了端口外,还有一个用来改变队列长度参数的backlog,指定当服务器繁忙时,可以与之保持连接请求的客户端数量,默认为50. (3)ServetSocket(int port,int backlog,InetAddress ip); 这个使用指定的端口,backlog,ip地址去创建ServerSocket. (这里简单提一下InetAddress,InetAddress没有构造方法,只有两个静态方法获取InetAddress对象,分别是 getByName(String hostName); getByAddress(byte[] address); ) 2.SocketSocket一般用来连接到服务器,程序通过Socket发出网络请求或应答网络请求. (1)Socket(InetAddress address,int port); 使用指定IP与指定端口构造Socket,对于本地地址,默认使用本地ip,对于本地端口则动态分配. (2)Socket(String address,int port); 与(1)一样,使用String表示远程ip. (3)Socket(InetAddress address,int port,InetAddress localAddr,int localPort); 创建指定了远程ip,远程端口,本地ip,本地端口的Socket. (4)Socket(String address,int localPort) 与(2)类似,使用String表示远程ip,用InetAddress表示本地ip. 了解了ServerSocket与Socket后可以编写实现简单的通信了. 3.服务器端import java.io.IOException; import java.io.PrintStream; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(12345);//这个端口自己随意,建议1024以上未使用的端口. while(true) { Socket socket = serverSocket.accept();//一直等待来自客户端的请求. PrintStream printStream = new PrintStream(socket.getOutputStream());//创建输出流 printStream.println("Server message."); printStream.close(); socket.close(); } } } 说一下ServetSocket的accept()方法: Socket accept(); 没有参数,返回一个Socket,如果接收到客户端的一个Socket,则返回,否则一直处于等待状态,线程也被阻塞. 4.客户端import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.InetAddress; import java.net.Socket; public class Client { public static void main(String[] args) throws IOException { Socket socket = new Socket("127.0.0.1",12345); BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream())); System.out.println("This message comes from server:"+bufferedReader.readLine()); bufferedReader.close(); socket.close(); } } Socket socket = new Socket("127.0.0.1",12345); 表示创建一个本地地址,端口为12345的Socket,创建好了后服务器的.accept()方法就会接收到这个Socket,并创建输出流输出相应信息,然后客户端从Socket获取输入流进行读取,读取到了来自服务器的信息. 5.运行结果(由于作者的漂亮终端不知道什么原因坏了....只能让用VScode的默认终端了....) 服务器端这边因为accept()方法会一直阻塞直到客户端发送请求. 客户端这边一运行就收到了来自服务器端的信息. 6.Socket设置超时可以为Socket设置超时设置,当Socket超过这个时间没有连接上时系统会认为连接失败. Socket socket = new Socket("127.0.0.1",12345); socket.setToTimeout(10000);//单位:ms,在这里是10s 但是未连接上之前无法创建Socket对象,并且Socket没有提供指定超时的构造方法,因此常见的做法是先创建一个无连接的Socket,再调用connect()方法连接. Socket socket = new Socket(); socket.connect(new InetSocketAddress("127.0.0.1",12345),12345); connect()方法其实有两个重载方法,分别是 void connect(SocketAddress endpoint); void connect(SocketAddress endpoint,int timeout); 对于第一个connect()官方文档没有提及超时之类的,就是直接连接. 7.最后这是作者的CSDN地址 参考链接 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |