Java中网络通信是通过Socket实现的。
Socket分为ServerSocket和Socket两大类。
ServerSocket用于服务端,通过accept方法监听请求,监听到请求后返回Socket,Socket用于具体完成数据传输;客户端通过Socket直接发起请求并传输数据。
ServerSocket的使用方法:
- 创建ServerSocket。ServerSocket有5个构造方法,其中ServerSocket(int port)用起来最方便,只需一个端口号就可以了。
- 调用accept方法进行监听。accept方法是阻塞方法,即调用accept方法后程序会停下来等待请求,在接收到请求之前,程序不会往下走,当接收到请求后accept方法会返回一个Socket.
- 使用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;
网友评论