【Java】TCP网络编程：从可靠传输到Socket实战 - IT评测·应用市场-qidao123.com

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TcpEchoServer { // 读取用Scanner ，发送用PrintWriter
// 1.首先serverSocket调用系统API把连接拿过来，然后交给socket
// 我们就有了socket这个对象，这个时候我们就可以宣布这个客户端成功和我们服务器建立了联系并且我们拿到了
// 2.然后我们通过字节流把数据从socket抽象的文件里面读取到，用try包起来，用scanner从流里面读取
// 3. 我们拿到字符串进行响应
// 4. 把返回的字符串通过字节流（我们的字符串通过字符流转换成字节流）写回去
// 5. 把信息打印出来
private ServerSocket serverSocket = null;
public TcpEchoServer(int serverPort) throws IOException {
// 利用这个系统API从内核中取到已经建立好的连接
// 这个和客户端构造的socket完全不一样，客户端的那个是我们已经拿到的连接
serverSocket = new ServerSocket(serverPort); // 服务器自己分配端口号，
}
public void start() throws IOException {
System.out.println("服务器启动");
// 把队列里面建立好的连接拿过来
while(true){ // 要一直不断地从那个内核里面不断地拿我们已经建立好的连接！！！
Socket Clientsocket = serverSocket.accept();
/* //创建一个新的线程把这个请求进行响应
Thread t = new Thread(() ->{
possessCollection(Clientsocket);
});
t.start();*/
// 但是线程池是更好一点点的选择
ExecutorService service = Executors.newCachedThreadPool();
service.submit(() ->{
possessCollection(Clientsocket);
});
}
}
public void possessCollection(Socket Clientsocket){ //
System.out.printf("[%s,%d] 客户端上线\n" , Clientsocket.getInetAddress(),Clientsocket.getPort());
// 把端口号和IP拿到
try( InputStream inputStream = Clientsocket.getInputStream(); // 这里要用 " ; "
OutputStream outputStream = Clientsocket.getOutputStream()){
// 客户可能等会还会继续发送请求（我们循环处理）
Scanner scanner = new Scanner(inputStream);//每一次读一次缓冲区,缓冲区里面的东西就少一次，都被我读出来了嘛
while(true){
if(!scanner.hasNext()){// 用户不再输入的时候，就直接跳出循环！！！,一直等待用户输入
System.out.printf("[%s,%d] 客户端下线\n" , Clientsocket.getInetAddress(),Clientsocket.getPort());
break;
}
String request = scanner.next();
// 拿到字符串进行响应
String response = process(request);// 拿到响应
//4. 拿到字符串的响应，然后我们通过字符流转字节流传递出去
PrintWriter printWriter = new PrintWriter(outputStream);
printWriter.println(response);
// 此处的println不是写到控制台了，而是写到outputStream的流对象了，也就是写入到ClientSocket里面了
// 自然这个数据也是通过网卡发出去了
printWriter.flush();// 再刷新一下缓存，防止没有发出去，
// 总结：发送和接收数据都是通过socket文件的字节流输入输出来实现，用scanner读字节流，用printWriter写字符串
// 5.打印一下交互过程
System.out.printf("[%s,%d] req=%s resp=%s\n",Clientsocket.getInetAddress(),Clientsocket.getPort(),
request,response);
}
}catch(IOException e){
e.printStackTrace();
}finally{
try {
Clientsocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
private String process(String request) { // 回显服务器
return request;
}
public static void main(String[] args) throws IOException {
TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);
tcpEchoServer.start();
}
}

复制代码

import com.sun.xml.internal.ws.policy.privateutil.PolicyUtils;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class TcpEchoClient {
/**
* 1.随机分配一个端口的发出信息（我们要把服务器的IP地址和端口号给搞进去）
* 2.我们循环输入一个字符串，把这个字符串用字符流转换成字节流写到socket抽象的文件里面
* 3.然后我们接收响应（不像服务器，我们又不需要进行处理）
* 4.我们直接通过Scanner把字节流里面的内容读出来就好了
*/
private Socket socket = null;
public TcpEchoClient(String serverIP,int serverPort) throws IOException {
socket = new Socket(serverIP,serverPort);
}
public void start(){
System.out.println(" -> ");
Scanner scanner = new Scanner(System.in);
try(OutputStream outputStream = socket.getOutputStream();
InputStream inputStream = socket.getInputStream()){
while(true){
/* if(!scanner.hasNext()){ // 用户不想输入了，就直接退出了
break; 不需要这个
}*/
// * 2.我们循环输入一个字符串，把这个字符串用字符流转换成字节流写到socket抽象的文件里面
String request = scanner.next();
PrintWriter printWriter = new PrintWriter(outputStream); // 这些流尽量都放到try()里面
printWriter.println(request);
printWriter.flush();// 一定不要忘记刷新缓存区'
// * 4.我们直接通过Scanner把字节流里面的内容读出来就好了
Scanner scannerNetwork = new Scanner(inputStream); // 这个Scanner尽量也是放到try()里面
String response = scannerNetwork.next();
System.out.println(response);
}
}catch(IOException e){
e.printStackTrace();
}
}
public static void main(String[] args) throws IOException {
TcpEchoClient tcpEchoClient = new TcpEchoClient("127.0.0.1",9090);
tcpEchoClient.start();
}
}

复制代码