黑马程序员--javaSE--网络编程基础总结

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
74
75
package cn.itcast.udp;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/*
 * 客户端：
 * 通过键盘录入数据。"886"表示停止。
 */
public class SendClient {
public static void main(String[] args) throws IOException {
	// 创建UDP发送端的服务
	DatagramSocket ds = new DatagramSocket();
	// 把键盘录入数据用高效缓冲流封装
	BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

	String line = null;
	while ((line = br.readLine()) != null) {
		if ("886".equals(line)) {
			break;
		}
		byte[] bys = line.getBytes();
		// 数据包
		DatagramPacket dp = new DatagramPacket(bys, bys.length,
				InetAddress.getByName("liuyi"), 11111);
		// 发送数据
		ds.send(dp);
	}

	// 关闭资源
	ds.close();
	}

}

package cn.itcast.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

/*
 * 服务端：
 * 接受端一直开启服务。
 */
public class ReceiveServer {
	public static void main(String[] args) throws IOException {
		// 创建UDP接收端Socket对象
		DatagramSocket ds = new DatagramSocket(11111);

		// 为了循环多次接受
		while (true) {
			// 创建字节数组作为数据包的缓冲区
			byte[] bys = new byte[1024];
			DatagramPacket dp = new DatagramPacket(bys, bys.length);
			// 读取数据包数据
			ds.receive(dp);

			// 解析数据包
			String ip = dp.getAddress().getHostAddress();
			int port = dp.getPort();

			String text = new String(dp.getData(), 0, dp.getLength());
			System.out.println(ip + "***" + port + "***" + text);
		}

		// 关闭资源
		// ds.close();
	}

}

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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
//服务器端的线程
package cn.itcast.tcp;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class UploadThraad implements Runnable {
	//线程要共享的变量
	private Socket s;
	public UploadThraad(Socket s) {
		this.s = s;
	}
	//将服务器端要执行的代码放到run方法内
	@Override
	public void run() {
		// 获取IP
		String ip = s.getInetAddress().getHostAddress();
		System.out.println(ip + "连接上了");
		try {

			File file = new File("d:\java");
			if (!file.exists()) {
				file.mkdir();
			}

			long time = System.currentTimeMillis();

			File fileDir = new File(file, ip +"-"+time + ".txt");

			// 从客户端获取输入写入到文件中，将文件流信息用包装流更高效
			BufferedReader br = new BufferedReader(new InputStreamReader(
					s.getInputStream()));

			PrintWriter pw = new PrintWriter(new FileWriter(fileDir), true);

			String line = null;
			while ((line = br.readLine()) != null) {
				pw.println(line);
			}

			// 给客户端一个反馈
			PrintWriter pwClient = new PrintWriter(s.getOutputStream(), true);
			pwClient.println("上传成功了");

			pw.close();
			s.close();
			// ss.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

//客户端的代码
package cn.itcast.tcp;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/*
 * 上传文件
 */
public class UploadClient {
	public static void main(String[] args) throws IOException {
		Socket s = new Socket("192.168.1.100", 12021);

		// 把一个文本文件上传到服务器
		BufferedReader br = new BufferedReader(new FileReader("hello.txt"));
		PrintWriter pw = new PrintWriter(s.getOutputStream(), true);

		String line = null;
		while ((line = br.readLine()) != null) {
			pw.println(line);
		}
		//上传完毕后，就将流关闭，因为方法readLine是阻塞式的，否则会报错
		s.shutdownOutput();
		

		// 如果服务器接收到所有的数据后，给我一个反馈
		BufferedReader serverBr = new BufferedReader(new InputStreamReader(
				s.getInputStream()));
		String text = serverBr.readLine();
		System.out.println("server:" + text);

		br.close();
		s.close();

	}

}

//测试类
package cn.itcast.tcp;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class UploadThreadTest {

	public static void main(String[] args) throws IOException {
		ServerSocket ss = new ServerSocket(12021);

		while (true) {
			Socket s = ss.accept();
			new Thread(new UploadThraad(s)).start();
		}
	}

}