Skip to content

Commit 64dc4d6

Browse files
王俊杰王俊杰
王俊杰
authored and
王俊杰
committed
unsafe
1 parent 18f5570 commit 64dc4d6

File tree

8 files changed

+365
-14
lines changed

8 files changed

+365
-14
lines changed

‎dubboProvider/src/test/java/com/wang/code/AppTest.java‎

Lines changed: 24 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,19 +2,39 @@
22

33
import static org.junit.Assert.assertTrue;
44

5+
import org.apache.curator.framework.CuratorFramework;
6+
import org.apache.curator.framework.CuratorFrameworkFactory;
7+
import org.apache.curator.framework.api.GetChildrenBuilder;
8+
import org.apache.curator.retry.ExponentialBackoffRetry;
9+
import org.apache.zookeeper.CreateMode;
10+
import org.apache.zookeeper.data.Stat;
511
import org.junit.Test;
612

13+
import java.util.List;
14+
715
/**
816
* Unit test for simple App.
917
*/
10-
public class AppTest
18+
public class AppTest
1119
{
20+
static CuratorFramework client = CuratorFrameworkFactory.builder().connectString("localhost:2181")
21+
.sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();
1222
/**
1323
* Rigorous Test :-)
1424
*/
1525
@Test
16-
public void shouldAnswerWithTrue()
17-
{
18-
assertTrue( true );
26+
public void shouldAnswerWithTrue() throws Exception {
27+
client.start();
28+
29+
GetChildrenBuilder children = client.getChildren();
30+
List<String> x = children.forPath("/");
31+
System.out.println(x);
32+
for (String name: x){
33+
client.delete().
34+
guaranteed().
35+
deletingChildrenIfNeeded().
36+
forPath("/" + name.trim());
37+
}
38+
1939
}
2040
}

‎javaDemo/pom.xml‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,16 @@
2525
<version>4.11</version>
2626
<scope>test</scope>
2727
</dependency>
28+
<dependency>
29+
<groupId>eu.bitwalker</groupId>
30+
<artifactId>UserAgentUtils</artifactId>
31+
<version>1.21</version>
32+
</dependency>
33+
<dependency>
34+
<groupId>javax.servlet</groupId>
35+
<artifactId>servlet-api</artifactId>
36+
<version>3.0-alpha-1</version>
37+
</dependency>
2838
</dependencies>
2939

3040
<build>

‎javaDemo/src/main/java/com/wang/code/DeadLockSample.java‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
package com.wang.code;
2+
3+
import sun.misc.Unsafe;
4+
5+
import java.lang.reflect.Field;
6+
import java.lang.reflect.Proxy;
7+
import java.util.concurrent.BrokenBarrierException;
8+
import java.util.concurrent.CyclicBarrier;
9+
import java.util.concurrent.atomic.AtomicInteger;
10+
11+
public class DeadLockSample extends Thread {
12+
private String first;
13+
private String second;
14+
public DeadLockSample(String name, String first, String second) {
15+
super(name);
16+
this.first = first;
17+
this.second = second;
18+
}
19+
20+
public void run() {
21+
synchronized (first) {
22+
System.out.println(this.getName() + " obtained: " + first);
23+
try {
24+
Thread.sleep(1000L);
25+
synchronized (second) {
26+
System.out.println(this.getName() + " obtained: " + second);
27+
}
28+
} catch (InterruptedException e) {
29+
// Do nothing
30+
}
31+
}
32+
}
33+
public static void main(String[] args) throws InterruptedException, NoSuchFieldException, IllegalAccessException {
34+
Field theUnsafe = Unsafe.class.getDeclaredField("theUnsafe");
35+
theUnsafe.setAccessible(true);
36+
Unsafe unsafe = (Unsafe) theUnsafe.get(null);
37+
38+
}
39+
}

‎javaDemo/src/main/java/com/wang/code/DeviceUtils.java‎

Lines changed: 147 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,147 @@
1+
package com.wang.code;
2+
3+
import javax.servlet.http.HttpServletRequest;
4+
5+
public class DeviceUtils {
6+
7+
/** 电脑上的IE或Firefox浏览器等的User-Agent关键词 */
8+
private static String[] pcHeaders = new String[] { "Windows 98", "Windows ME", "Windows 2000", "Windows XP",
9+
"Windows NT", "Ubuntu" };
10+
/** 手机浏览器的User-Agent里的关键词 */
11+
private static String[] mobileUserAgents = new String[] { "Nokia", // 诺基亚，有山寨机也写这个的，总还算是手机，Mozilla/5.0
12+
// (Nokia5800
13+
// XpressMusic)UC
14+
// AppleWebkit(like
15+
// Gecko)
16+
// Safari/530
17+
"SAMSUNG", // 三星手机
18+
// SAMSUNG-GT-B7722/1.0+SHP/VPP/R5+Dolfin/1.5+Nextreaming+SMM-MMS/1.2.0+profile/MIDP-2.1+configuration/CLDC-1.1
19+
"MIDP-2", // j2me2.0，Mozilla/5.0 (SymbianOS/9.3; U; Series60/3.2
20+
// NokiaE75-1 /110.48.125 Profile/MIDP-2.1
21+
// Configuration/CLDC-1.1 ) AppleWebKit/413 (KHTML like
22+
// Gecko) Safari/413
23+
"CLDC1.1", // M600/MIDP2.0/CLDC1.1/Screen-240X320
24+
"SymbianOS", // 塞班系统的，
25+
"MAUI", // MTK山寨机默认ua
26+
"UNTRUSTED/1.0", // 疑似山寨机的ua，基本可以确定还是手机
27+
"Windows CE", // Windows CE，Mozilla/4.0 (compatible; MSIE 6.0;
28+
// Windows CE; IEMobile 7.11)
29+
"iPhone", // iPhone是否也转wap？不管它，先区分出来再说。Mozilla/5.0 (iPhone; U; CPU
30+
// iPhone OS 4_1 like Mac OS X; zh-cn) AppleWebKit/532.9
31+
// (KHTML like Gecko) Mobile/8B117
32+
"iPad", // iPad的ua，Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X;
33+
// zh-cn) AppleWebKit/531.21.10 (KHTML like Gecko)
34+
// Version/4.0.4 Mobile/7B367 Safari/531.21.10
35+
"Android", // Android是否也转wap？Mozilla/5.0 (Linux; U; Android
36+
// 2.1-update1; zh-cn; XT800 Build/TITA_M2_16.22.7)
37+
// AppleWebKit/530.17 (KHTML like Gecko) Version/4.0
38+
// Mobile Safari/530.17
39+
"BlackBerry", // BlackBerry8310/2.7.0.106-4.5.0.182
40+
"UCWEB", // ucweb是否只给wap页面？ Nokia5800
41+
// XpressMusic/UCWEB7.5.0.66/50/999
42+
"ucweb", // 小写的ucweb貌似是uc的代理服务器Mozilla/6.0 (compatible; MSIE 6.0;)
43+
// Opera ucweb-squid
44+
"BREW", // 很奇怪的ua，例如：REW-Applet/0x20068888 (BREW/3.1.5.20; DeviceId:
45+
// 40105; Lang: zhcn) ucweb-squid
46+
"J2ME", // 很奇怪的ua，只有J2ME四个字母
47+
"YULONG", // 宇龙手机，YULONG-CoolpadN68/10.14 IPANEL/2.0 CTC/1.0
48+
"YuLong", // 还是宇龙
49+
"COOLPAD", // 宇龙酷派YL-COOLPADS100/08.10.S100 POLARIS/2.9 CTC/1.0
50+
"TIANYU", // 天语手机TIANYU-KTOUCH/V209/MIDP2.0/CLDC1.1/Screen-240X320
51+
"TY-", // 天语，TY-F6229/701116_6215_V0230 JUPITOR/2.2 CTC/1.0
52+
"K-Touch", // 还是天语K-Touch_N2200_CMCC/TBG110022_1223_V0801 MTK/6223
53+
// Release/30.07.2008 Browser/WAP2.0
54+
"Haier", // 海尔手机，Haier-HG-M217_CMCC/3.0 Release/12.1.2007
55+
// Browser/WAP2.0
56+
"DOPOD", // 多普达手机
57+
"Lenovo", // 联想手机，Lenovo-P650WG/S100 LMP/LML Release/2010.02.22
58+
// Profile/MIDP2.0 Configuration/CLDC1.1
59+
"LENOVO", // 联想手机，比如：LENOVO-P780/176A
60+
"HUAQIN", // 华勤手机
61+
"AIGO-", // 爱国者居然也出过手机，AIGO-800C/2.04 TMSS-BROWSER/1.0.0 CTC/1.0
62+
"CTC/1.0", // 含义不明
63+
"CTC/2.0", // 含义不明
64+
"CMCC", // 移动定制手机，K-Touch_N2200_CMCC/TBG110022_1223_V0801 MTK/6223
65+
// Release/30.07.2008 Browser/WAP2.0
66+
"DAXIAN", // 大显手机DAXIAN X180 UP.Browser/6.2.3.2(GUI) MMP/2.0
67+
"MOT-", // 摩托罗拉，MOT-MOTOROKRE6/1.0 LinuxOS/2.4.20 Release/8.4.2006
68+
// Browser/Opera8.00 Profile/MIDP2.0 Configuration/CLDC1.1
69+
// Software/R533_G_11.10.54R
70+
"SonyEricsson", // 索爱手机，SonyEricssonP990i/R100 Mozilla/4.0
71+
// (compatible; MSIE 6.0; Symbian OS; 405) Opera
72+
// 8.65 [zh-CN]
73+
"GIONEE", // 金立手机
74+
"HTC", // HTC手机
75+
"ZTE", // 中兴手机，ZTE-A211/P109A2V1.0.0/WAP2.0 Profile
76+
"HUAWEI", // 华为手机，
77+
"webOS", // palm手机，Mozilla/5.0 (webOS/1.4.5; U; zh-CN)
78+
// AppleWebKit/532.2 (KHTML like Gecko) Version/1.0
79+
// Safari/532.2 Pre/1.0
80+
"GoBrowser", // 3g GoBrowser.User-Agent=Nokia5230/GoBrowser/2.0.290
81+
// Safari
82+
"IEMobile", // Windows CE手机自带浏览器，
83+
"WAP2.0"// 支持wap 2.0的
84+
};
85+
86+
/**
87+
* 根据当前请求的特征，判断该请求是否来自手机终端，主要检测特殊的头信息，以及user-Agent这个header
88+
*
89+
* @param request
90+
* http请求
91+
* @return 如果命中手机特征规则，则返回对应的特征字符串
92+
*/
93+
public static boolean isMobileDevice(HttpServletRequest request) {
94+
boolean isMobile = false;
95+
boolean pcFlag = false;
96+
boolean mobileFlag = false;
97+
String userAgent = request.getHeader("user-agent");
98+
for (int i = 0; !mobileFlag && userAgent != null && !userAgent.trim().equals("")
99+
&& i < mobileUserAgents.length; i++) {
100+
if (userAgent.contains(mobileUserAgents[i])) {
101+
mobileFlag = true;
102+
break;
103+
}
104+
}
105+
for (int i = 0; userAgent != null && !userAgent.trim().equals("") && i < pcHeaders.length; i++) {
106+
if (userAgent.contains(pcHeaders[i])) {
107+
pcFlag = true;
108+
break;
109+
}
110+
}
111+
if (mobileFlag == true && pcFlag == false) {
112+
isMobile = true;
113+
}
114+
return isMobile;// false pc true mobile
115+
116+
}
117+
118+
/**
119+
* 判断是否为IOS系统访问
120+
*
121+
* @param request
122+
* @return
123+
*/
124+
public static boolean isIOSDevice(HttpServletRequest request) {
125+
boolean isMobile = false;
126+
final String[] ios_sys = { "iPhone", "iPad", "iPod" };
127+
String userAgent = request.getHeader("user-agent");
128+
for (int i = 0; !isMobile && userAgent != null && !userAgent.trim().equals("") && i < ios_sys.length; i++) {
129+
if (userAgent.contains(ios_sys[i])) {
130+
isMobile = true;
131+
break;
132+
}
133+
}
134+
return isMobile;//
135+
}
136+
137+
/**
138+
* 判断是否是微信访问
139+
*
140+
* @param request
141+
* @return
142+
*/
143+
public static boolean isWeChat(HttpServletRequest request) {
144+
String userAgent = request.getHeader("user-agent").toLowerCase();
145+
return userAgent == null || userAgent.indexOf("micromessenger") == -1 ? false : true;
146+
}
147+
}

‎javaDemo/src/main/java/com/wang/code/ProxyDemo.java‎

Lines changed: 22 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,12 +50,18 @@ public static void main(String[] args) {
5050
* 这种动态获取信息以及动态调用对象方法的功能称为java语言的反射机制。
5151
*/
5252

53-
// Class<String> stringClass = String.class;
54-
// stringClass.get***
55-
5653
/*
5754
* 动态代理
58-
* 动态代理是利用反射机制在运行时创建代理类
55+
* 动态代理是利用反射机制在运行时创建代理类, 说的这么玄乎，那么动态代理到底是什么概念？
56+
* 其实本质上就是在特定的时机去修改已经有的类型或者创建新的类型。
57+
*
58+
* 按照目前的理解，动态代理主要用到的技术包括：反射和类加载机制
59+
* 第一、类加载机制提供了我们可以通过二进制流通过ClassLoader的defineClass生成Class<?>，通过这一步实现了字节码到类加载的过程
60+
* protected final Class<?> defineClass(
61+
* String name, byte[] b, int off, int len,ProtectionDomain protectionDomain)
62+
* 其次、通过newInstance实例化可以传入Object...参数，从而实现类的增强
63+
* 我们在InvocationHandler中定义增强的语句，这样生成的代理对象就是有增强的功能的实例
64+
*
5965
*
6066
* JDK Proxy 的优势：
6167
* 最小化依赖关系，减少依赖意味着简化开发和维护，JDK 本身的支持，可能比 cglib 更加可靠。
@@ -81,8 +87,20 @@ public static void main(String[] args) {
8187
* 动态代理原理：
8288
* newProxyInstance ——> getProxyClass0获取到class对象 ——> ProxyClassFactor.apply() ——> generateProxyClass()
8389
* ——> 通过反射获取代理类的构造器 ——> cons.newInstance(new Object[]{h})生成代理类
90+
*
91+
* -newProxyInstance: 这个方法是整个动态代理的入口，通过这个方法可以获取到动态代理的对象，这里注意参数
92+
* ----Class<?> cl = getProxyClass0(loader, intfs) 通过这个逻辑实现了字节码 --> 类加载的过程
93+
* --------proxyClassCache.get(loader, interfaces) : 这里这个proxyClassCache是一个很关键的对象
94+
* ------------proxyClassCache = new WeakCache<>(new KeyFactory(), new ProxyClassFactory());
95+
* ProxyClassFactory 中的apply方法实现了通过接口调用classLoader生成class<>的逻辑
96+
* KeyFactory是缓存的key，可以看成是classLoader + intfs构成的key
97+
* ----------------byte[] proxyClassFile = ProxyGenerator.generateProxyClass(proxyName, interfaces, accessFlags);
98+
* ----------------return defineClass0(loader, proxyName,proxyClassFile, 0, proxyClassFile.length);
99+
* ----Constructor<?> cons = cl.getConstructor(constructorParams); 获取上面cl的构造器
100+
* ----cons.newInstance(new Object[]{h}) native方法，jvm层面实现了通过h作为参数完成实例化对象过程
84101
*/
85102

103+
86104
/*
87105
* 实现动态代理主要的方式： 基于接口的 JDK Proxy、ASM、CGlib(基于ASM)、Javassist
88106
*/

‎javaDemo/src/main/java/com/wang/code/Test.java‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎javaDemo/src/main/java/com/wang/code/ThreadLocalDemo.java‎

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
package com.wang.code;
2+
3+
import java.util.HashMap;
4+
import java.util.Map;
5+
import java.util.Objects;
6+
7+
public class ThreadLocalDemo {
8+
9+
static Map<Thread, ThreadLocal> map = new HashMap<>();
10+
11+
public static void main(String[] args) {
12+
new Thread(new Runnable() {
13+
@Override
14+
public void run() {
15+
for (int i = 0; i < 1000; i++) {
16+
TestClass t = new TestClass(i);
17+
t.printId();
18+
t.threadLocal = null;
19+
t = null;
20+
}
21+
}
22+
}).start();
23+
24+
}
25+
26+
static class TestClass {
27+
private int id;
28+
private int[] arr;
29+
public ThreadLocal<TestClass> threadLocal;
30+
31+
TestClass(int id) {
32+
this.id = id;
33+
arr = new int[1000000];
34+
threadLocal = new ThreadLocal<>();
35+
new InheritableThreadLocal<>();
36+
threadLocal.set(this);
37+
}
38+
39+
public void printId() {
40+
System.out.println(threadLocal.get().id);
41+
}
42+
}
43+
}

0 commit comments

Comments
 (0)