Java基础-26（02）总结网络编程

时间:2022-05-04
本文章向大家介绍Java基础-26（02）总结网络编程，主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。
c:客户端键盘录入服务器控制台输出
package cn.itcast_08;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
/*
 * 客户端键盘录入，服务器输出到控制台
 */
public class ClientDemo {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 22222);
 // 键盘录入数据
 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
 // 把通道内的流给包装一下
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 // 键盘录入数据要自定义结束标记
 if ("886".equals(line)) {
 break;
 }
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // 释放资源
 // bw.close();
 // br.close();
 s.close();
 }
}
package cn.itcast_08;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
 public static void main(String[] args) throws IOException {
 // 创建服务器Socket对象
 ServerSocket ss = new ServerSocket(22222);
 // 监听客户端连接
 Socket s = ss.accept();
 // 包装通道内容的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 System.out.println(line);
 }
 // br.close();
 s.close();
 // ss.close();
 }
}

d:客户端键盘录入服务器写到文本文件

package cn.itcast_09;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
/*
 * 客户端键盘录入，服务器输出文本文件
 */
public class ClientDemo {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 23456);
 // 封装键盘录入
 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
 // 封装通道内的数据
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 if ("over".equals(line)) {
 break;
 }
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // bw.close();
 // br.close();
 s.close();
 }
}
package cn.itcast_09;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
 public static void main(String[] args) throws IOException {
 // 创建服务器Socket对象
 ServerSocket ss = new ServerSocket(23456);
 // 监听客户端连接
 Socket s = ss.accept();
 // 封装通道内的数据
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 // 封装文本文件
 BufferedWriter bw = new BufferedWriter(new FileWriter("a.txt"));
 String line = null;
 while ((line = br.readLine()) != null) {
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 bw.close();
 // br.close();
 s.close();
 // ss.close();
 }
}

e:客户端读取文本文件服务器控制台输出

package cn.itcast_10;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.Socket;
/*
 * 客户端文本文件，服务器输出到控制台
 */
public class ClientDemo {
 public static void main(String[] args) throws IOException {
 // 创建Socket对象
 Socket s = new Socket("192.168.12.92", 34567);
 // 封装文本文件
 BufferedReader br = new BufferedReader(new FileReader(
 "InetAddressDemo.java"));
 // 封装通道内的流
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 br.close();
 s.close();
 }
}
package cn.itcast_10;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
 public static void main(String[] args) throws IOException {
 // 创建服务器Socket对象
 ServerSocket ss = new ServerSocket(34567);
 // 监听客户端连接
 Socket s = ss.accept();
 // 封装通道内的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 System.out.println(line);
 }
 s.close();
 }
}

f:客户端读取文本文件服务器写到文本文件

package cn.itcast_11;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class UploadClient {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 11111);
 // 封装文本文件
 BufferedReader br = new BufferedReader(new FileReader(
 "InetAddressDemo.java"));
 // 封装通道内流
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) {
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // 释放资源
 br.close();
 s.close();
 }
}
package cn.itcast_11;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
 public static void main(String[] args) throws IOException {
 // 创建服务器端的Socket对象
 ServerSocket ss = new ServerSocket(11111);
 // 监听客户端连接
 Socket s = ss.accept();
 // 封装通道内的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 // 封装文本文件
 BufferedWriter bw = new BufferedWriter(new FileWriter("Copy.java"));
 String line = null;
 while ((line = br.readLine()) != null) {
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 bw.close();
 s.close();
 }
}

g:客户端读取文本文件服务器写到文本文件并给出反馈

package cn.itcast_12;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
/*
 * 按照我们正常的思路加入反馈信息，结果却没反应。为什么呢?
 * 读取文本文件是可以以null作为结束信息的，但是呢，通道内是不能这样结束信息的。
 * 所以，服务器根本就不知道你结束了。而你还想服务器给你反馈。所以，就相互等待了。
 * 
 * 如何解决呢?
 * A:在多写一条数据，告诉服务器，读取到这条数据说明我就结束，你也结束吧。
 *  这样做可以解决问题，但是不好。
 * B:Socket对象提供了一种解决方案
 *  public void shutdownOutput()
 */
public class UploadClient {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 11111);
 // 封装文本文件
 BufferedReader br = new BufferedReader(new FileReader(
 "InetAddressDemo.java"));
 // 封装通道内流
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 //自定义一个结束标记
// bw.write("over");
// bw.newLine();
// bw.flush();
 //Socket提供了一个终止，它会通知服务器你别等了，我没有数据过来了
 s.shutdownOutput();
 // 接收反馈
 BufferedReader brClient = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 String client = brClient.readLine(); // 阻塞
 System.out.println(client);
 // 释放资源
 br.close();
 s.close();
 }
}
package cn.itcast_12;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
 public static void main(String[] args) throws IOException {
 // 创建服务器端的Socket对象
 ServerSocket ss = new ServerSocket(11111);
 // 监听客户端连接
 Socket s = ss.accept();// 阻塞
 // 封装通道内的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 // 封装文本文件
 BufferedWriter bw = new BufferedWriter(new FileWriter("Copy.java"));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 // if("over".equals(line)){
 // break;
 // }
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // 给出反馈
 BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 bwServer.write("文件上传成功");
 bwServer.newLine();
 bwServer.flush();
 // 释放资源
 bw.close();
 s.close();
 }
}

h:TCP协议上上传图片并给出反馈

package cn.itcast_13;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
public class UploadClient {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 19191);
 // 封装图片文件
 BufferedInputStream bis = new BufferedInputStream(new FileInputStream(
 "林青霞.jpg"));
 // 封装通道内的流
 BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());
 byte[] bys = new byte[1024];
 int len = 0;
 while ((len = bis.read(bys)) != -1) {
 bos.write(bys, 0, len);
 bos.flush();
 }
 s.shutdownOutput();
 // 读取反馈
 InputStream is = s.getInputStream();
 byte[] bys2 = new byte[1024];
 int len2 = is.read(bys2);
 String client = new String(bys2, 0, len2);
 System.out.println(client);
 // 释放资源
 bis.close();
 s.close();
 }
}
package cn.itcast_13;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
 public static void main(String[] args) throws IOException {
 // 创建服务器Socket对象
 ServerSocket ss = new ServerSocket(19191);
 // 监听客户端连接
 Socket s = ss.accept();
 // 封装通道内流
 BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
 // 封装图片文件
 BufferedOutputStream bos = new BufferedOutputStream(
 new FileOutputStream("mn.jpg"));
 byte[] bys = new byte[1024];
 int len = 0;
 while ((len = bis.read(bys)) != -1) {
 bos.write(bys, 0, len);
 bos.flush();
 }
 // 给一个反馈
 OutputStream os = s.getOutputStream();
 os.write("图片上传成功".getBytes());
 bos.close();
 s.close();
 }
}

i:多个客户端上传一个服务器思考

package cn.itcast_14;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class UploadClient {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 11111);
 // 封装文本文件
 BufferedReader br = new BufferedReader(new FileReader(
 "InetAddressDemo.java"));
 // 封装通道内流
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // Socket提供了一个终止，它会通知服务器你别等了，我没有数据过来了
 s.shutdownOutput();
 // 接收反馈
 BufferedReader brClient = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 String client = brClient.readLine(); // 阻塞
 System.out.println(client);
 // 释放资源
 br.close();
 s.close();
 }
}
package cn.itcast_14;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
/*
 * 通过while循环可以改进一个服务器接收多个客户端。
 * 但是这个是有问题的。
 * 如果是这种情况，假设我还有张三，李四，王五这三个人分别执行客户端
 * 张三：好好学习.avi(100M) 256k
 * 李四：天天向上.mp3(3M) 1M
 * 王五：ILoveJava.txt(1k) 100M
 */
public class UploadServer {
 public static void main(String[] args) throws IOException {
 // 创建服务器端的Socket对象
 ServerSocket ss = new ServerSocket(11111);
 while (true) {
 // 监听客户端连接
 Socket s = ss.accept();// 阻塞
 // 封装通道内的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 // 封装文本文件
 BufferedWriter bw = new BufferedWriter(new FileWriter("Copy.java"));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // 给出反馈
 BufferedWriter bwServer = new BufferedWriter(
 new OutputStreamWriter(s.getOutputStream()));
 bwServer.write("文件上传成功");
 bwServer.newLine();
 bwServer.flush();
 // 释放资源
 bw.close();
 s.close();
 }
 }
}

j:多线程改进上传文件

package cn.itcast_15;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class UserThread implements Runnable {
 private Socket s;
 public UserThread(Socket s) {
 this.s = s;
 }
 @Override
 public void run() {
 try {
 // 封装通道内的流
 BufferedReader br = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 // 封装文本文件
 // BufferedWriter bw = new BufferedWriter(new
 // FileWriter("Copy.java"));
 // 为了防止名称冲突
 String newName = System.currentTimeMillis() + ".java";
 BufferedWriter bw = new BufferedWriter(new FileWriter(newName));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // 给出反馈
 BufferedWriter bwServer = new BufferedWriter(
 new OutputStreamWriter(s.getOutputStream()));
 bwServer.write("文件上传成功");
 bwServer.newLine();
 bwServer.flush();
 // 释放资源
 bw.close();
 s.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
}
package cn.itcast_15;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class UploadClient {
 public static void main(String[] args) throws IOException {
 // 创建客户端Socket对象
 Socket s = new Socket("192.168.12.92", 11111);
 // 封装文本文件
 // BufferedReader br = new BufferedReader(new FileReader(
 // "InetAddressDemo.java"));
 BufferedReader br = new BufferedReader(new FileReader(
 "ReceiveDemo.java"));
 // 封装通道内流
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 s.getOutputStream()));
 String line = null;
 while ((line = br.readLine()) != null) { // 阻塞
 bw.write(line);
 bw.newLine();
 bw.flush();
 }
 // Socket提供了一个终止，它会通知服务器你别等了，我没有数据过来了
 s.shutdownOutput();
 // 接收反馈
 BufferedReader brClient = new BufferedReader(new InputStreamReader(
 s.getInputStream()));
 String client = brClient.readLine(); // 阻塞
 System.out.println(client);
 // 释放资源
 br.close();
 s.close();
 }
}
package cn.itcast_15;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
 public static void main(String[] args) throws IOException {
 // 创建服务器Socket对象
 ServerSocket ss = new ServerSocket(11111);
 while (true) {
 Socket s = ss.accept();
 new Thread(new UserThread(s)).start();
 }
 }
}

随机文章
java知识点必读
最近更新