Socket 简单连接
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 通讯中的 核心相关类。仅供记录。