socket 通讯简图
服务端
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.time.LocalTime;
public class MySocketServer {
public static void main(String[] args){
try {
//创建socket服务端
ServerSocket serverSocket = new ServerSocket(8888);
while(true){
//等待接收客户端连接
Socket socket = serverSocket.accept();
//从socket中获取输入流
InputStream inputStream = socket.getInputStream();
byte[] bytes = new byte[1024];
//读取输入流中的信息
inputStream.read(bytes);
System.out.println("接受到的信息是:"+ new String(bytes));
//从socket中获取输出流
OutputStream outputStream = socket.getOutputStream();
//写入信息到输出流
outputStream.write(("收到:" + LocalTime.now().toString()).getBytes());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
客户端
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class MyScoketClent {
public static void main(String[] args){
try {
//建立与服务端的连接
Socket socket = new Socket("127.0.0.1",8888);
//从socket对象中获取输出流对象
OutputStream outputStream = socket.getOutputStream();
Scanner sc = new Scanner(System.in);
System.out.print("请输入信息:");
String next = sc.nextLine();
//将输入的信息写入输出流中
outputStream.write(next.getBytes());
//从socket对象中获取输入流对象
InputStream inputStream = socket.getInputStream();
byte[] bytes = new byte[1024];
//从输入流读取信息
inputStream.read(bytes);
System.out.println("返回的信息是:"+new String(bytes));
}catch(Exception e) {
e.printStackTrace();
}
}
}
运行main方法执行结果见截图:
代码简单,生产环境如果直接这样写,那就离被辞退不远了。
主要为说明socket 通讯中的 核心相关类。仅供记录。