Java中的网络通信是通过Socket实现的,Socket分为ServetSocket和Socket两大类,ServetSocket用于服务端,可以通过accept的方法监听请求,监听到请求后返回Socket,Socket用于具体完成数据传输,客户端直接使用Socket发起请求并传输数据。
ServerSocket的使用可以分为三步:
1)创建ServerSocket。ServerSocket的构造方法一共有5个,用起来最方便的是ServerSocket(int port),只需要一个port(端口号)就可以了。
2)调用创建出来的ServerSocket的accept方法进行监听。accept方法是阻塞方法,也就是说调用accept方法后程序会停下来等待连接请求,在接收到请求之前程序将不会往下走,当接收到请求后accept方法会返回一个Socket。
3)使用accept方法返回的Socket与客户端进行通信。
服务端使用实例:
public class Server { /** * ServerSocket用于服务端,可以通过accept方法监听请求,监听到请求后返回Socket, * Socket用于具体完成数据传输,客户端直接使用Socket发起请求并传输数据。 * @param args */ public static void main(String[] args) { try { //创建一个ServerSocket监听8080端口 ServerSocket server = new ServerSocket(8080); //等待请求 Socket socket = server.accept(); //接收到请求后使用socket进行通信,创建BufferedReader用于读取数据 BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream())); String line = is.readLine(); System.out.println("received from client:"+line); //创建PrintWriter,用于发送数据 PrintWriter pw = new PrintWriter(socket.getOutputStream()); pw.println("received data:"+line); pw.flush(); pw.close(); is.close(); socket.close(); server.close(); } catch (IOException e) { e.printStackTrace(); } } }
客户端使用实例:
public class Client { /** * 启动后自动将msg发送给服务端,然后再接受服务端返回的而数据并打印到控制台,最后释放资源关闭连接 * @param args */ public static void main(String[] args) { try { String msg = "Client data"; //创建一个socket,跟本机的8080端口连接 Socket socket = new Socket("127.0.0.1",8080); //使用Socket创建PrintWriter和BufferedReader进行读写数据 PrintWriter pw = new PrintWriter(socket.getOutputStream()); BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream())); //发送数据 pw.println(msg); pw.flush(); //接收数据 String line = is.readLine(); System.out.println("reveived from server:"+line); //关闭资源 pw.close(); is.close(); socket.close(); } catch (Exception e) { e.printStackTrace(); } } }
nio(new IO)提供ServerSocketChannel和SocketChannel,它们分别对应原来的ServerSocket和Socket。
Buffer:所要送的货物;
Channel:送货员(或者开往某个区域的配货车);
Selector:中转站的分拣员;
NioSocket使用中首先要创建ServerSocketChannel,然后注册Selector,接下来就可以用Selector接收请求并处理了。
ServerSocketChannel可以使用自己的静态工厂方法open创建。每个ServerSocketChannel对应一个ServerSocket,可以调用其socket方法来获取,不过如果直接使用获取到ServerSocket来监听请求,那还是原来的处理模式,一般使用获取到的ServerSocket来绑定端口。ServerSocketChannel可以通过configureBlocking方法来设置是否采用阻塞模式,如果要采用非阻塞模式可以用configureBlocking(false)来设置,设置了非阻塞模式之后就可以调用register方法注册Selector来使用了(阻塞模式不可以使用Selector)。
原文:https://www.cnblogs.com/nachdenken/p/11285555.html