通信socket实现"/>
java通信socket实现
解决思路
- 创建服务端ServerSocket,绑定端口侦听网络请求,阻塞循环接收,使用PrintStream流返回响应。
- 创建客户端Socket,创建一个流套接字并将其连接到指定 IP 地址的指定端口号,使用socket.getInputStream()方法获取服务器端的响应流。
具体步骤
创建ServerSocket绑定端口:
ServerSocket serverSocket = new ServerSocket(30000);
此类实现服务器套接字。服务器套接字等待请求通过网络传入。它基于该请求执行某些操作,然后可能向请求者返回结果。
在无限循环中accept()方法阻塞接收请求。
Socket socket = serverSocket.accept();
- 使用PrintStream包装服务器端的响应流
PrintStream printStream = new PrintStream(socket.getOutputStream());
- 客户端:构造Socket套接字连接到指定地址的指定端口
Socket socket = new Socket("127.0.0.1", 30000);
- 使用BufferedReader包装套接字接受到的输入流
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
效果图
这里Server为循环,Client只是执行一次,连接后得到Server响应并输出就结束了
放码
- 服务器端
import java.io.IOException;
import java.io.PrintStream;
import java.ServerSocket;
import java.Socket;public class Server {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(30000);while (true) {Socket socket = serverSocket.accept();PrintStream printStream = new PrintStream(socket.getOutputStream());printStream.print("我是墓地");printStream.close();printStream.flush();}}
}
- 客户端
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.Socket;public class Client {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1", 30000);BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line = bufferedReader.readLine();System.out.println("来自对方的回答:" + line);bufferedReader.close();socket.close();}
}
更多推荐
java通信socket实现
发布评论