网络编程金典echo案例

一、服务端

package com.server;import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;/*** &＃64;Auther: chenzhou* &＃64;Date: 2019/2/25* &＃64;Description: 网络编程服务端* &＃64;version: 1.0*/
public class Server{public static void main(String[] args) throws Exception {ServerSocket serverSocket &＃61; new ServerSocket(9999);//设置端口号System.out.println("等待客户端连接");Socket accept &＃61; serverSocket.accept();//首先接收客户端发来的消息&＃xff0c;然后进行数据处理后发送回客户端Scanner scanner &＃61; new Scanner(accept.getInputStream());//得到客户端发送的数据PrintStream stream &＃61; new PrintStream(accept.getOutputStream());//向客户端发送数据Boolean flag &＃61; true;while (flag){if(scanner.hasNext()){String next &＃61; scanner.next().trim();if("bye".equals(next)){stream.println("ByeBye!!!");flag &＃61; false;}else{stream.println("[Echo]"&＃43;next);}}}//关闭流stream.close();scanner.close();serverSocket.close();}
}

二、客户端

package com.client;import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;/*** &＃64;Auther: chenzhou* &＃64;Date: 2019/2/25* &＃64;Description: 网络编程客户端* &＃64;version: 1.0*/
public class Client {private static final BufferedReader BUFFERED_READER&＃61; new BufferedReader(new InputStreamReader(System.in));public static void main(String[] args) throws Exception{Socket socket &＃61; new Socket("localhost",9999);Scanner scanner &＃61; new Scanner(socket.getInputStream());//服务端发来的信息PrintStream stream &＃61; new PrintStream(socket.getOutputStream());//向服务端发送信息Boolean flag &＃61; true;while(flag){String input &＃61; getString("请输入要发送的内容");stream.println(input);if(scanner.hasNext()){String next &＃61; scanner.next();System.out.println(next);}if("bye".equalsIgnoreCase(input)){flag &＃61; false;}}stream.close();scanner.close();socket.close();}public static String getString(String Prompt) throws Exception{System.out.println(Prompt);String s &＃61; BUFFERED_READER.readLine();return s;}
}


输出结果&＃xff1a;

三、多线程实现服务端&＃xff08;多个客户端连接一个服务端&＃xff09;

package com.server;import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;/*** &＃64;Auther: chenzhou* &＃64;Date: 2019/2/25* &＃64;Description: 多线程实现服务端&＃xff0c;让每个线程去处理客户端的请求* &＃64;version: 1.0*/
public class ServerForMore implements Runnable{Socket socket &＃61; null;Scanner scanner &＃61; null;PrintStream stream&＃61; null;Boolean flag &＃61; true;//构造器初始化参数public ServerForMore(Socket client) throws Exception {this.socket &＃61; client;scanner &＃61; new Scanner(client.getInputStream());//得到客户端发送的数据stream &＃61; new PrintStream(client.getOutputStream());//向客户端发送消息}&＃64;Overridepublic void run() {while (this.flag){if(this.scanner.hasNext()){String next &＃61; scanner.next().trim();if("bye".equals(next)){stream.println("ByeBye!!!");flag &＃61; false;}else{stream.println("[Echo]"&＃43;next);}}}//关闭流stream.close();scanner.close();try {socket.close();} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws Exception {ServerSocket serverSocket &＃61; new ServerSocket(9999);System.out.println("等待客户端连接。。。。");Boolean flag &＃61; true;while(flag){Socket client &＃61; serverSocket.accept();new Thread(new ServerForMore(client)).start();}serverSocket.close();}
}