尚硅谷java基础源码.doc

IO:package com.atguigu.javase.lesson10;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.FileReader;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.Reader;import org.junit.Test;public class IOTest /* * 利用字符输入输出流, 完成 hello.txt 文件的复制. * 把该文件复制为 hello2.txt * throws IOException */* * 利用字节输入输出流, 完成 hello.txt 文件的复制. * 把该文件复制为 hello2.txt * throws IOException */Testpublic void testCopyFile() throws IOException/1. 创建定位到 hello.txt 的文件的输入流InputStream in = new FileInputStream(枚举类.avi);/2. 创建定位到 hello2.txt 的文件输出流OutputStream out = new FileOutputStream(枚举类2.avi);/3. 创建一个 byte 数组, 用于读写文件 byte buffer = new byte1024 * 10;int len = 0;/4. 读写文件:/in.read(buffer); out.write(buffer, 0, len);while(len = in.read(buffer) != -1)out.write(buffer);/5. 关闭流资源. out.close();in.close();/* * 测试字节输出流 * throws IOException */Testpublic void testOutputStream() throws IOExceptionOutputStream out = new FileOutputStream(abcd.txt);String content = nHello Java!;/int len = 10;/byte contentBytes = content.getBytes();/for(int i = 0; i content.length() / 10; i+)/把 String 拆分成多个 buffer/out.write(contentBytes, i * 10, len);/if(content.length() % 10 != 0)/out.write(contentBytes, 10 * (content.length() / 10), /content.length() - (10 * (content.length() / 10);/out.write(content.getBytes();out.close();/* * 测试字符输入流. * throws IOException */Testpublic void testReader() throws IOException/利用字符输入流读取 hello.txt 文档的内容, 输出到控制台. Reader reader = new FileReader(hello.txt);char buffer = new char10;int len = 0;while(len = reader.read(buffer) != -1)for(int i = 0; i len; i+)System.out.print(bufferi);reader.close();/* * 测试字节输入流 * throws IOException */Testpublic void testInputStream() throws IOException/1. 创建了一个字节输入流.InputStream in = new FileInputStream(hello.txt);/2. 读取文件的内容/2.1 第一读取一个字节. 效率很低, 不建议这样读. -1 表示读取到文件的结尾处/int result = in.read();/while(result != -1)/System.out.print(char)result);/result = in.read();/2.2 一次读取一组: 一组字符. /返回一次实际读取的字节数, 若为 -1 表示读取到文件的结尾/byte buffer = new byte10;/int len = 0;/while(len = in.read(buffer) != -1)/for(int i = 0; i len; i+)/System.out.print(char)bufferi);/2.3 把内容读取到字节数组的部分连续的元素中.byte result = new byte1024 * 10;in.read(result, 10, in.available();/3. 关闭流资源in.close();/* * File: 代表物理的意义的文件或目录 * throws IOException */Testpublic void testFile() throws IOException/1. 创建 File 对象File file = new File(hello.txt);/2. 测试 File 对象的方法. /2.1 文件名相关的方法String fileName = file.getName();System.out.println(fileName); /2.2 访问文件的绝对路径String path = file.getAbsolutePath();System.out.println(path); /2.3 为文件重命名/file.renameTo(new File(d:hello.txt);/3. 文件检测相关的方法System.out.println(file.exists();File dir = new File(atguigu);System.out.println(dir.isFile(); /4. 获取文件的常规信息System.out.println(file.length(); /5. 文件操作相关.File file2 = new File(abcd.txt);file2.createNewFile();IO2:package com.atguigu.javase.lesson10;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.FileReader;import java.io.FileWriter;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.io.RandomAccessFile;import java.io.Reader;import java.io.Writer;import org.junit.Test;public class IOTest /* * 使用 RandomAccessFile. 向 hello.txt 文件中插入一行: I Love Gongfu. 插入到第二行. 原内容下移. * * throws IOException */Testpublic void testRandomAccessFile2() throws IOException RandomAccessFile access = new RandomAccessFile(hello.txt, rw);/ 先读一行.String line = access.readLine();/ 把第一行后面的内容先读取到一个 byte 数组中.byte buffer = new byte(int) (access.length() - line.length();access.read(buffer);/ 移动指针到第一行的后面access.seek(line.length();/ 写入要写的字符串access.writeBytes(nI Love Gongfu.n);/ 再写入先前的内容access.write(buffer);access.close();Testpublic void testRandomAccessFile() throws IOException / 1. 创建 RandomAccessFile 对象RandomAccessFile access = new RandomAccessFile(hello.txt, rw);/ 3. 对文件进行读写操作/ String str = null;/ while(str = access.readLine() != null)/ System.out.println(str);/ / 向文件结尾写入 / 设置指针的位置.access.seek(20);/ 向指定位置写入字符串: 把原有的文件内容覆盖了.access.writeBytes();/ 2. 关闭 RandomAccessFile 对象access.close();Testpublic void testInputObjectStream() throws IOException, Exception InputStream in = new FileInputStream(d:obj.txt);ObjectInputStream objectInputStream = new ObjectInputStream(in);Object obj = objectInputStream.readObject();System.out.println(obj);objectInputStream.close();in.close();Testpublic void testSerializable() throws IOException Person person = new Person(AA, 12);person.setAddress(new Address(BeiJing);/ 使用 ObjectOutputStream 把对象写到硬盘上OutputStream out = new FileOutputStream(d:obj.txt);ObjectOutputStream objectOutputStream = new ObjectOutputStream(out);objectOutputStream.writeObject(person);out.close();objectOutputStream.close();/* * 先创建两个字节输入输出流: 分别指向 hello.txt, hello5.txt 然后再转为字符输入输出流, 在转为带缓冲的字符输入输出流 * * 完成文件的复制. * * throws IOException */Testpublic void testOutputStreamWriter() throws IOException InputStream in = new FileInputStream(hello.txt);Reader reader = new InputStreamReader(in);BufferedReader bufferedReader = new BufferedReader(reader);OutputStream out = new FileOutputStream(hello5.txt);Writer writer = new OutputStreamWriter(out);BufferedWriter bufferedWriter = new BufferedWriter(writer);String str = null;int i = 0;while (str = bufferedReader.readLine() != null) if (i != 0) bufferedWriter.write(n);bufferedWriter.write(str);i+;in.close();reader.close();bufferedReader.close();bufferedWriter.close();writer.close();out.close();Testpublic void testInputStreamReader() throws IOException / 指向文档的字节流InputStream in = new FileInputStream(hello.txt);/ 把上面的流转为字符流Reader reader = new InputStreamReader(in);/ 把字符流转为带缓冲的字符流BufferedReader bufferedReader = new BufferedReader(reader);/ BufferedReader bufferedReader2 =/ new BufferedReader(new InputStreamReader(new/ FileInputStream(hello.txt);String str = null;while (str = bufferedReader.readLine() != null) System.out.println(str);/ 关闭:in.close();reader.close();bufferedReader.close();/* * 利用BufferedInputStream 和 BufferedOutputStream 完成 hello.txt 文件到 hello5.txt * 文件的复制. * * throws IOException * */Testpublic void testBufferedInputStreamAndBufferedOutputStream()throws IOException InputStream in = new FileInputStream(hello.txt);BufferedInputStream bufferedInputStream = new BufferedInputStream(in);OutputStream out = new FileOutputStream(hello5.txt);BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(out);byte buffer = new byte1024;int len = 0;while (len = bufferedInputStream.read(buffer) != -1) bufferedOutputStream.write(buffer, 0, len);bufferedInputStream.close();bufferedOutputStream.close();/* * 复制 hello.txt 为 hello4.txt * * throws IOException */Testpublic void testBufferedReaderAndBufferedWriter() throws IOException / 1. 创建 BufferedReader 和 BufferdWriterReader in = new FileReader(hello.txt);BufferedReader bufferedReader = new BufferedReader(in);Writer out = new FileWriter(hello4.txt);BufferedWriter bufferedWriter = new BufferedWriter(out);/ 2. 进行读写操作String str = null;int i = 0;while (str = bufferedReader.readLine() != null) if (i != 0) bufferedWriter.write(n);bufferedWriter.write(str);i+;/ 3. 关闭 IO 流: 直接关闭包装流, 内部会关闭节点流bufferedReader.close();bufferedWriter.close();/* * 利用字符输入输出流, 完成 hello.txt 文件的复制. 把该文件复制为 hello2.txt * * throws IOException * throws IOException */Testpublic void testCopyByReaderAndWriter() throws IOException / 1. 创建字符输入, 输出流Reader reader = new FileReader(hello.txt);Writer writer = new FileWriter(hello2.txt);/ 3. 创建一个字符数组.char buffer = new char10;/ 4. 利用循环读取源文件, 并向目标文件写入/ 5. 注意: 使用的写入的方法: write(char cbuf, int off, int len)/ 而不能直接使用 write(char cbuf)int len = 0;while (len = reader.read(buffer) != -1) writer.write(buffer, 0, len);/ System.out.println(len);/ 2. 关闭流资源reader.close();writer.close();网络编程：package com.atguigu.javase.lesson14;import java.io.BufferedReader;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.PrintWriter;import .InetAddress;import .ServerSocket;import .Socket;import .URL;import .URLConnection;import org.junit.Test;/* * 1. IP 和 端口的具体意义: * 1). IP 定位网络中的一台主机 * 2). 端口定位主机的一个网络程序. * * 2. InetAddress: 对象表示网络中的一个地址 * InetAddress address = InetAddress.getByName(); * * 3. TCP/IP 编程: * 1). 服务器/客户端: 客户端发送请求到服务器, 服务器接收请求, 给予响应到客户端. * 2). ServerSocket * 3). Socket * 具体参看 PPT 16 页的图. * */public class SocketTest Testpublic void testURL() throws IOExceptionURL url = new URL(:8080/examples/abcd.txt);System.out.println(url.getPath();System.out.println(url.getQuery(); URLConnection urlConnection = url.openConnection();System.out.println(urlConnection); InputStream in = urlConnection.getInputStream();OutputStream out = new FileOutputStream(test.txt);byte buffer = new byte1024;int len = 0;while(len = in.read(buffer) != -1)out.write(buffer, 0, len);in.close();out.close();Testpublic void testClientSocket2() throws IOExceptionInetAddress address = InetAddress.getByName();Socket socket = new Socket(address, 8686);InputStream in = socket.getInputStream();OutputStream out = new FileOutputStream(d:abcd.jpg);byte buffer = new byte1024;int len = 0;while(len = in.read(buffer) != -1)out.write(buffer, 0, len);in.close();out.close();socket.close();Testpublic void testServerSocket2() throws IOExceptionServerSocket serverSocket = new ServerSocket(8686);Socket socket = serverSocket.accept();InputStream in = new FileInputStream(abc.jpg);byte buffer = new byte1024;int len = 0;OutputStream out = socket.getOutputStream();while(len = in.read(buffer) != -1)out.write(buffer, 0, len);out.close();in.close();socket.close();serverSocket.close();Testpublic void testSocket() throws IOExceptionInetAddress address = InetAddress.getByName();/创建 Socket 对象: 同时也向服务端发出请求Socket socket = new Socket(address, 8989);/通过 输入输出流 和服务端进行交互InputStream in = socket.getInputStream();BufferedReader reader = new BufferedReader(new InputStreamReader(in);System.out.println(_: + reader.readLine();in.close();reader.close();/关闭 Socketsocket.close();Testpublic void testServerSocket() throws IOException/创建 ServerSocket 对象ServerSocket serverSocket = new ServerSocket(8989);/接受客户端的请求, 并得到 Socket 对象Socket socket = serverSocket.accept();/通过 输入输出流 和客户端进行交互OutputStream out = socket.getOutputStream();PrintWriter writer = new PrintWriter(out);writer.write(来自服务端的问候.);writer.close();out.close();/遍历 Socket 资源. socket.close();serverSocket.close();/* * InetAddress: 表示互联网(或局域网)的一台主机的地址 * throws IOException */Testpublic void testInetAddress() throws IOException /InetAddress address = InetAddress.getByName();//10/System.out.println(address); InetAddress address2 = InetAddress.getLocalHost();System.out.println(address2); 线程：package com.atgugu.javase.lesson13;public class YieldThreadTest extends Threadpublic static void main(String args) Thread t1 = new YieldThreadTest(线程-1);Thread t2 = new YieldThreadTest(线程-2);t1.start();t2.start();public YieldThreadTest(String name) super(name);Overridepublic void run() for(int i = 0; i 100; i+)System.out.println(getName() + : + i);if(i = 10)yield();package com.atgugu.javase.lesson13;public class TicketHouse implements Runnableprivate int fiveCount = 1, tenCount = 0, twentyCount = 0;public synchronized void buy()String name = Thread.currentThread().getName();/zf: 20 元if(zf.equals(name)if(fiveCount 3)try System.out.println(5 元面值: + fiveCount + , 张飞必须等待.);wait();System.out.println(5 元面值: + fiveCount + ,卖一张票给张飞, 找零 15); catch (InterruptedException e) e.printStackTrace();else if(gy.equals(name)fiveCount+;System.out.println(卖一张票给关羽. 钱正好. 5 元面值: + fiveCount);else if(lb.equals(name)fiveCount+;System.out.println(卖一张票给刘备. 钱正好. 5 元面值: + fiveCount);if(fiveCount = 3)notifyAll();Overridepublic void run() buy();public static void main(String args) Runnable runnable = new TicketHouse();Thread th1 = new Thread(runnable);th1.setName(zf);Thread th2 = new Thread(runnable);th2.setName(gy);Thread th3 = new Thread(runnable);th3.setName(lb);th1.start();th2.start();th3.start();package com.atgugu.javase.lesson13;/* * 关于线程: * 1. 在 Java 中, Thread 类代表一个线程. * * 2. 实现线程有 2 种方式: * 2.1 继承 Thread 类 * 2.2 实现 Runnable 接口. * * 3. 继承 Thread 类: * 3.1 必须重写 run() 方法: 里边放置的是实际的线程体。 * * 4. 启动线程: * 4.1 创建 Thread 对象 * 4.2 调用 Thread 对象的 start() 方法启动线程. 而不是 run() 方法. * * 5. 实现 Runnable 接口的方式: * 5.1 创建实现 Runnable 接口的实现类: 必须实现 run() 方法 * 5.2 创建 5.1 对应的 Runnable 接口的实现类对象 * 5.3 创建 Thread 对象, 利用 Thread(Runnable target) * 5.4 调用 Thread 类 start() 方法启动线程. * * 7. 线程安全的问题: * 7.1 理解并编写出线程不安全的示例代码: 多个线程访问一个共享的资源. * 7.2 使用 synchronized 代码块解决线程安全的问题: 需要在 synchronized 代码块中 * 参照共同的一个对象. * * 6. 线程生命周期相关的几个方法(了解): * 6.1 yeild(): 若当前线程调用该方法, 则由执行状态变为可运行状态. * 6.2 sleep(int mills): 使当前线程休眠一段时间. 以毫秒为单位 * 6.3 join: 在一个线程中调用另外的线程的 join() 方法, 将使当前线程阻塞, * 等待另一个线程执行完后再进入可执行状态. * 6.4 interrupt(): 将解除线程的阻塞状态. * 6.5 isAlive(): 可以判断当前线程是否处于可运行状态或运行状态. * * 8. 关于线程通信(了解): * 8.1 相关方法: wait(), notify(), notifyAll() * 8.2 这些方法在 同步方法中 调用. * */public class ThreadTest public static void main(String args) /1. 创建线程对象Thread thread = new FirstThread(FirstThread);/2. 调用线程对象的 start() 方法启动线程thread.start();String threadName = Thread.currentThread().getName();for(int i = 0; i 100; i+)System.out.println(threadName + : + i); class FirstThread extends Threadpublic FirstThread(String name) super(name);/* * 线程体在 run() 方法中 */Overridepublic void run() String threadName = Thread.currentThread().getName();for(int i = 0; i 100; i+)System.out.println(threadName + : + i); package com.atgugu.javase.lesson13;public class PriorityThreadTest extends Threadpublic static void main(String args) Thread th1 = new PriorityThreadTest(线程-1);Thread th2 = new PriorityThreadTest(线程-2);System.out.println(th1.getPriority();System.out.println(th2.getPriority(); System.out.println(Thread.currentThread().getPriority();th1.setPriority(MIN_PRIORITY);th2.setPriority(MAX_PRIORITY);th1.start();th2.start();for(int i = 0; i 100; i+)System.out.println(main: + i);public PriorityThreadTest(String name) super(name);Overridepublic void run() for(int i = 0; i 100; i+)System.out.println(getName() + : + i);package com.atgugu.javase.lesson13;public