1.普通Socket的用法

2017-09-20  本文已影响0人  miss晴天

Java中网络通信是通过Socket实现的。
Socket分为ServerSocket和Socket两大类。
ServerSocket用于服务端,通过accept方法监听请求,监听到请求后返回Socket,Socket用于具体完成数据传输;客户端通过Socket直接发起请求并传输数据。

ServerSocket的使用方法:
  1. 创建ServerSocket。ServerSocket有5个构造方法,其中ServerSocket(int port)用起来最方便,只需一个端口号就可以了。
  2. 调用accept方法进行监听。accept方法是阻塞方法,即调用accept方法后程序会停下来等待请求,在接收到请求之前,程序不会往下走,当接收到请求后accept方法会返回一个Socket.
  3. 使用accept返回的Socket进行通信。
ServerSocket的简单示例:
package Ex;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class TestServer {
  public static void main(String[] args) {
    try {
        // 1.创建一个ServerSocket监听8080端口
        ServerSocket server = new ServerSocket(8080);
        // 2.等待请求
        Socket socket = server.accept();
        // 3.接收到请求后使用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 (Exception e) {
        // TODO: handle exception
        e.printStackTrace();
    }
  }
}

在上面的TestServer中,先创建ServerSocket,然后调用accpet等待请求,当接收到请求后,用返回的Socket创建BufferedReader和PrintWriter进行接收和发送数据,Reader接收到的数据保存到line中,在控制台打印,Writer发送数据给客户端。数据传输完成后,关闭连接;

Socket的简单示例:
package Ex;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class TestClient {
  public static void main(String[] args) {
    String msg = "Client Data.";
    try {
        //创建一个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("received from server :"+line);
        //关闭资源
        is.close();
        pw.close();
        socket.close();
        
        
    } catch (Exception e) {
        // TODO: handle exception
    }
  }
}

首先创建一个Socket,采用Socket(String host,int port)构造方法,把主机地址和端口号传入进去,Socket就会跟服务端建立连接,创建完Socket,再创建Reader和Writer进行数据传输,数据传输完成后,关闭连接释放资源即可。
  先启动TestServer,然后再启动TestClient就可以完成一次通信。Server端控制台输出:received from client:Client Date;Client端控制台输出:received from server:received data:Client data;

上一篇 下一篇

猜你喜欢

热点阅读