Java之tcp简单应用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
	/** 
* @author: lucky66
* @date：2020年11月2日 下午3:19:38 
* @Description：服务器代码
*/
public class Server {
	//path：指令和文件一一对应；
	private static Map<String,String> path = new  HashMap<String, String>();
	public static void main(String[] args) throws Exception{
		ServerSocket server = new ServerSocket(8888);
		Socket client = server.accept();   	// 等待客户端接入
		Scanner reader = new Scanner(client.getInputStream()); 	// 服务器接收客户端输入
		PrintStream pt = new PrintStream(client.getOutputStream()); // 服务器发送给客户端
		boolean flag = true; 	// 是否断开连接
		init(); 	// 初始化变量path的值
		while(flag) {
			if(reader.hasNext()) { 
				String str = reader.next().trim();
				if("byebye".equalsIgnoreCase(str)) {
					pt.println("exit");
					flag = false;
				}
			else {
				if(path.containsKey(str)) {
						String text = readFile(getFile(path.get(str)));
						pt.println(text);   
					}
				else {
						pt.println("输入有误");
					}
				}
			}
		}
		reader.close();
		server.close();
	}
	
	public static void init() {
		path.put("1", "1.txt");
		path.put("2", "2.txt");
		path.put("3", "3.txt");
	}
	
	/*
	* getFile 返回目标文件对象
	*/
	public static File getFile(String num) throws Exception {
		File file = new File("D:\java-2019-09\project\JavaDemo3\src\homeworkdemo2_2\"+num);
		return file;
	}
	
	/*
	* readFile读取目标文件内容并返回
	*/
	public static String readFile(File file) throws Exception {
		FileInputStream input = new FileInputStream(file);
		Scanner scanner = new Scanner(new InputStreamReader(input)).useDelimiter("r");
		/*
		 * 	把 r 做文件读的分割符号，可以保留 n
		 * 	读完最后一行之后无数据可以读，跳出while循环
		 * 	此时的result是存在 n字符的，待客户端读取服务器发来的信息的时候就可以按照文本的内容换行输出了
		 */
		 
		String result = "";
		while(scanner.hasNext()) {
			result += scanner.next(); 
		}
		input.close();
		scanner.close();
		return result;
	}
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
/** 
* @author: lucky66
* @date：2020年11月2日 下午3:19:50
* @Description：客户端代码
*/
public class Client {
	// 首先定义一个接收键盘输入的字符流
	private static final BufferedReader KEYBOARD_INPUT = new BufferedReader(new InputStreamReader(System.in));
	public static String getString(String str) throws Exception {
		return KEYBOARD_INPUT.readLine();
	}
	// 	可选内容
	public static void menu() {
		System.out.println("1、-----打开1.txt文件-----");
		System.out.println("2、-----打开2.txt文件-----");
		System.out.println("3、-----打开3.txt文件-----");
}
	public static void main(String[] args) throws Exception{
		Socket client = new Socket("127.0.0.1", 8888);
		Scanner input = new Scanner(client.getInputStream()).useDelimiter("r");	// 接收服务器发来的信息，**用'r'做分割符号**
		boolean flag = true;
		PrintStream pt = new PrintStream(client.getOutputStream()); // 客户端发送给服务器的流
		String str = "";
		while(flag) {
			menu();
			str =  getString("请输入你的操作");
			pt.println(str.trim());
			if(input.hasNext()) {
				System.out.println(input.next());
			}
			if("exit".equalsIgnoreCase(str)) {
				pt.print("byebye");
				flag=false;
			}
		}
		input.close();
		client.close();
	}
}