java经过ServerSocket与Socket实现通讯

首先说一下ServerSocket与Socket.

1.ServerSocket

ServerSocket是用来监听客户端Socket链接的类,若是没有链接会一直处于等待状态. ServetSocket有三个构造方法:

(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.Socket

Socket通常用来链接到服务器,程序经过Socket发出网络请求或应答网络请求. 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 port,InetAddress localAddr,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()官方文档没有说起超时之类的,就是直接链接. 对于第二个connect,timeout指定的超时时间,单位为ms,设置为0则为无限期等待.

7.最后

这是做者的CSDN地址.

这是做者的微信公众号,里面有更多精彩文章等待你发现.欢迎关注.

参考连接

1.socket