add fastdfs

Author: kimmking

.gitignore

@@ -24,6 +24,7 @@ hs_err_pid*
 *.iml
 *.idea/
 
+out/
 classes/
 target/
 build/

01jvm/java11/src/test/java/com/example/demo/DemoApplicationTests.java

@@ -1,13 +1,13 @@
-package com.example.demo;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-class DemoApplicationTests {
-
-    @Test
-    void contextLoads() {
-    }
-
-}
+//package com.example.demo;
+//
+//import org.junit.jupiter.api.Test;
+//import org.springframework.boot.test.context.SpringBootTest;
+//
+//@SpringBootTest
+//class DemoApplicationTests {
+//
+//    @Test
+//    void contextLoads() {
+//    }
+//
+//}

01jvm/out/production/01jvm/README.md

@@ -6,7 +6,7 @@
 ## 作业内容
 
 
-> Week01 作业题目（周四）：
+> Week01 作业题目：
 
 1.（选做）自己写一个简单的 Hello.java，里面需要涉及基本类型，四则运行，if 和 for，然后自己分析一下对应的字节码，有问题群里讨论。
 
@@ -18,24 +18,102 @@
 
 注意：如果没有线上系统，可以自己 run 一个 web/java 项目。
 
-> Week01 作业题目（周六）：
+5.（选做）本机使用 G1 GC 启动一个程序，仿照课上案例分析一下 JVM 情况。
 
-1.（选做）本机使用 G1 GC 启动一个程序，仿照课上案例分析一下 JVM 情况。
 
 
 ## 操作步骤
 
 
-### 作业2
+### 作业1（选做）
+
+1. 编写代码, 根据自己的意愿随意编写, 可参考: [Hello.java](./Hello.java)
+2. 编译代码, 执行命令： `javac -g Hello.java`
+3. 查看反编译的代码。
+  - 3.1 可以安装并使用idea的jclasslib插件, 选中 [Hello.java](./Hello.java) 文件, 选择 `View --> Show Bytecode With jclasslib` 即可。
+  - 3.2 或者直接通过命令行工具 javap, 执行命令: `javap -v Hello.class`
+4. 分析相关的字节码。【此步骤需要各位同学自己进行分析】
+
+
+### 作业2（必做）
 
 1. 打开 Spring 官网: https://spring.io/
 2. 找到 Projects --> Spring Initializr:  https://start.spring.io/
 3. 填写项目信息, 生成 maven 项目; 下载并解压。
 4. Idea或者Eclipse从已有的Source导入Maven项目。
-5. 增加课程资源 Hello.xlass 文件到 src/main/resources 目录。
-6. 编写代码，实现 findClass 方法，解码方法
+5. 从课件资料中找到资源 Hello.xlass 文件并复制到 src/main/resources 目录。
+6. 编写代码，实现 findClass 方法，以及对应的解码方法
 7. 编写main方法，调用 loadClass 方法；
 8. 创建实例，以及调用方法
 9. 执行.
 
-具体的参见: [https://github.com/renfufei/JAVA-000/blob/main/Week_01/homework01/src/main/java/com/renfufei/homework01/XlassLoader.java](XlassLoader.java)
+具体代码可参考: [XlassLoader.java](./XlassLoader.java)
+
+
+### 作业3（必做）
+
+对应的图片需要各位同学自己绘制，可以部分参考PPT课件。
+
+提示:
+
+- Xms 设置堆内存的初始值
+- Xmx 设置堆内存的最大值
+- Xmn 设置堆内存中的年轻代的最大值
+- Meta 区不属于堆内存, 归属为非堆
+- DirectMemory 直接内存, 属于 JVM 内存中开辟出来的本地内存空间。
+- Xss设置的是单个线程栈的最大空间;
+
+JVM进程空间中的内存一般来说包括以下这些部分:
+
+- 堆内存(Xms ~ Xmx) = 年轻代(~Xmn) + 老年代
+- 非堆 = Meta + CodeCache + ...
+- Native内存 = 直接内存 + Native + ...
+- 栈内存 = n * Xss
+
+另外，注意区分规范与实现的区别, 需要根据具体实现以及版本, 才能确定。 一般来说，我们的目的是为了排查故障和诊断问题，大致弄清楚这些参数和空间的关系即可。 具体设置时还需要留一些冗余量。
+
+
+### 4.（选做）
+
+这个是具体案例分析, 请各位同学自己分析。
+
+比如我们一个生产系统应用的启动参数为:
+
+```
+JAVA_OPTS=-Xmx200g -Xms200g -XX:+UnlockExperimentalVMOptions -XX:+UseZGC -XX:ZCollectionInterval=30 -XX:ZAllocationSpikeTolerance=5 -XX:ReservedCodeCacheSize=2g -XX:InitialCodeCacheSize=2g -XX:ConcGCThreads=8 -XX:ParallelGCThreads=16
+```
+
+另一个系统的启动参数为:
+
+```
+JAVA_OPTS=-Xmx4g -Xms4g -XX:+UseG1GC -XX:MaxGCPauseMillis=50
+```
+
+具体如何设置, 需要考虑的因素包括:
+
+- 系统容量: 业务规模, 并发, 成本预算; 需要兼顾性能与成本;
+- 延迟要求: 最坏情况下能接受多少时间的延迟尖刺。
+- 吞吐量:  根据业务特征来确定, 比如, 网关, 大数据底层平台, 批处理作业系统, 在线实时应用, 他们最重要的需求不一样。
+- 系统架构: 比如拆分为小内存更多节点, 还是大内存少量节点。
+- 其他...
+
+
+### 5.（选做）
+
+例如使用以下命令:
+
+```
+# 编译
+javac -g GCLogAnalysis.java
+# JDK8 启动程序
+java -Xmx2g -Xms2g -XX:+UseG1GC -verbose:gc -XX:+PrintGCDateStamps -XX:+PrintGCDetails -Xloggc:gc.log  GCLogAnalysis
+```
+
+尝试使用课程中介绍的各种工具JDK命令行和图形工具来进行分析。
+
+其中 [GCLogAnalysis.java](./GCLogAnalysis.java) 文件也可以从课件资料zip中找到.
+
+## 更多资料
+
+更多中英文的技术文章和参考资料: <https://github.com/cncounter/translation>
+

02nio/nio01/pom.xml

@@ -59,6 +59,16 @@
             <artifactId>netty-all</artifactId>
             <version>4.1.51.Final</version>
         </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>3.12.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.5</version>
+        </dependency>
     </dependencies>
 
 

02nio/nio01/src/main/java/java0/nio01/HttpClientDemo.java

@@ -0,0 +1,51 @@
+package java0.nio01;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.protocol.HTTP;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+
+public class HttpClientDemo {
+
+    public static void main(String[] args) throws IOException {
+
+        byte[] bytes = getBody1( "http://localhost:8801");
+        System.out.println(new String(bytes));
+
+    }
+
+    private static byte[] getBody1(String url){
+        HttpGet httpGet = new HttpGet(url);
+        httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            response = httpClient.execute(httpGet);
+            HttpEntity entity = response.getEntity();
+            // System.out.println(EntityUtils.toString(entity));
+            return EntityUtils.toByteArray(entity);
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                // 释放资源
+                if (response != null) {
+                    response.close();
+                }
+                if (httpClient != null) {
+                    httpClient.close();
+                }
+                httpGet.releaseConnection();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
+}

02nio/nio01/src/main/java/java0/nio01/HttpServer01.java

@@ -28,6 +28,7 @@ private static void service(Socket socket) {
             printWriter.println("Content-Length:" + body.getBytes().length);
             printWriter.println();
             printWriter.write(body);
+            printWriter.flush();
             printWriter.close();
             socket.close();
         } catch (Exception e) {

02nio/nio01/src/main/java/java0/nio01/OKHttpClientDemo.java

@@ -0,0 +1,35 @@
+package java0.nio01;
+
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+
+import java.io.IOException;
+
+public class OKHttpClientDemo {
+
+    private static OkHttpClient client = new OkHttpClient();
+    public static void main(String[] args) throws IOException {
+
+        getBody1(client, "http://localhost:8801");
+        client = null;
+    }
+
+    private static void getBody1(OkHttpClient client, String url){
+
+        Request request = new Request.Builder()
+                .get()
+                .url(url)
+                .build();
+        //String body = "test";
+        try {
+            Response response = client.newCall(request).execute();
+            String responseData = response.body().string();
+            System.out.println(responseData);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }finally {
+            client = null;
+        }
+    }
+}

04fx/spring01/src/main/java/io/kimmking/DemoMethodIncepter.java

@@ -0,0 +1,17 @@
+package io.kimmking;
+
+import org.aopalliance.intercept.MethodInterceptor;
+import org.aopalliance.intercept.MethodInvocation;
+
+public class DemoMethodIncepter implements MethodInterceptor {
+
+    public Object invoke(MethodInvocation invocation) throws Throwable {
+
+        long s =  System.currentTimeMillis();
+        System.out.println("   *****====> " + s + " " + invocation.getMethod().getName());
+        Object result = invocation.proceed();
+        System.out.println("   *****====> " + (System.currentTimeMillis() - s) + " ms");
+        return result;
+    }
+
+}

04fx/spring01/src/main/java/io/kimmking/anno/AnnoDemo.java

@@ -0,0 +1,9 @@
+package io.kimmking.anno;
+
+public class AnnoDemo {
+
+    public static void main(String[] args) {
+
+    }
+
+}

04fx/spring01/src/main/java/io/kimmking/anno/IA1.java

@@ -0,0 +1,8 @@
+package io.kimmking.anno;
+
+
+public interface IA1 {
+
+ void a1();
+
+}

04fx/spring01/src/main/java/io/kimmking/anno/IA2.java

@@ -0,0 +1,9 @@
+package io.kimmking.anno;
+
+
+@IAnnotation
+public interface IA2 extends IA1 {
+
+ void a2();
+
+}

04fx/spring01/src/main/java/io/kimmking/anno/IAnnotation.java

@@ -0,0 +1,12 @@
+package io.kimmking.anno;
+
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface IAnnotation {
+}