如果您觉得本框架具有一定的参考价值和借鉴意义，请帮忙在页面右上角 [**Star**]
- 首席作者简介
+## 简介
+
+### 作者简介
- Nepxion开源社区创始人
- 2020年阿里巴巴中国云原生峰会出品人
- 2020年被Nacos和Spring Cloud Alibaba纳入相关开源项目
- 2021年阿里巴巴技术峰会上海站演讲嘉宾
- 2021年荣获陆奇博士主持的奇绩资本，进行风险投资的关注和调研
- 2021年入选Gitee最有价值开源项目
-- Nacos Group Member、Spring Cloud Alibaba Member
+- 阿里巴巴官方书籍《Nacos架构与原理》作者之一
+- Spring Cloud Alibaba Steering Committer、Nacos Group Member
- Spring Cloud Alibaba、Nacos、Sentinel、OpenTracing Committer & Contributor
- 商业化合作
-
+### 商业合作
① Discovery系列
| 框架名称 | 框架版本 | 支持Spring Cloud版本 | 使用许可 |
| --- | --- | --- | --- |
| Discovery | 1.x.x ~ 6.x.x | Camden ~ Hoxton | 开源，永久免费 |
-| DiscoveryX | 7.x.x | 202x | 闭源，商业许可 |
+| DiscoveryX | 7.x.x ~ 9.x.x | 2020 ~ 2022 | 闭源，商业许可 |
② Polaris系列
@@ -46,36 +46,46 @@ Polaris为Discovery高级定制版，特色功能
| 框架名称 | 框架版本 | 支持Discovery版本 | 支持Spring Cloud版本 | 使用许可 |
| --- | --- | --- | --- | --- |
| Polaris | 1.x.x | 6.x.x | Finchley ~ Hoxton | 闭源，商业许可 |
-| Polaris | 2.x.x | 7.x.x | 202x | 闭源，商业许可 |
+| Polaris | 2.x.x | 7.x.x ~ 9.x.x | 2020 ~ 2022 | 闭源，商业许可 |
有商业版需求的企业和用户，请添加微信1394997，联系作者，洽谈合作事宜
+### 入门资料
 Discovery【探索】企业级云原生微服务开源解决方案
-① 解决方案
+① 快速入门
+- [快速入门Github版](https://github.com/Nepxion/Discovery/wiki)
+- [快速入门Gitee版](https://gitee.com/Nepxion/Discovery/wikis/pages)
+
+② 解决方案
- [解决方案WIKI版](http://nepxion.com/discovery)
- [解决方案PPT版](http://nepxion.gitee.io/discovery/docs/link-doc/discovery-ppt.html)
-② 平台界面
-- [平台界面WIKI版](http://nepxion.com/discovery-platform)
+③ 最佳实践
+- [最佳实践PPT版](http://nepxion.gitee.io/discovery/docs/link-doc/discovery-ppt-1.html)
-③ 快速入门
-- [快速入门Github版](https://github.com/Nepxion/Discovery/wiki)
-- [快速入门Gitee版](https://gitee.com/Nepxion/Discovery/wikis/pages)
+④ 平台界面
+- [平台界面WIKI版](http://nepxion.com/discovery-platform)
-④ 框架源码
+⑤ 框架源码
- [框架源码Github版](https://github.com/Nepxion/Discovery)
- [框架源码Gitee版](https://gitee.com/Nepxion/Discovery)
-⑤ 指南示例源码
+⑥ 指南示例源码
- [指南示例源码Github版](https://github.com/Nepxion/DiscoveryGuide)
- [指南示例源码Gitee版](https://gitee.com/Nepxion/DiscoveryGuide)
-⑥ 指南示例说明
-- 对于入门级玩家，参考[6.x.x指南示例极简版](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-simple)，分支为6.x.x-simple
-- 对于熟练级玩家，参考[6.x.x指南示例精进版](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x)，分支为6.x.x。除上述《极简版》功能外，涉及到指南篇里的绝大多数高级功能
-- 对于骨灰级玩家，参考[6.x.x指南示例高级版](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-complex)，分支为6.x.x-complex。除上述《精进版》功能外，涉及到指南篇里的ActiveMQ、MongoDB、RabbitMQ、Redis、RocketMQ、MySQL等高级调用链和蓝绿灰度调用链的整合
-- 上述指南实例分支是针对Spring Cloud旧版本。对于Spring Cloud 202x版本，参考[7.x.x指南示例精进版](https://github.com/Nepxion/DiscoveryGuide/tree/master)，分支为master
+⑦ 指南示例说明
+- Spring Cloud Finchley ~ Hoxton版本
+ - [极简版指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-simple)，分支为6.x.x-simple
+ - [极简版域网关部署指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-simple-domain-gateway)，分支为6.x.x-simple-domain-gateway
+ - [极简版非域网关部署指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-simple-non-domain-gateway)，分支为6.x.x-simple-non-domain-gateway
+ - [集成版指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x)，分支为6.x.x
+ - [高级版指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/6.x.x-complex)，分支为6.x.x-complex
+- Spring Cloud 202x版本
+ - [极简版指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/master-simple)，分支为master-simple
+ - [极简版本地化指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/master-simple-native)，分支为master-simple-native
+ - [集成版指南示例](https://github.com/Nepxion/DiscoveryGuide/tree/master)，分支为master
 Polaris【北极星】企业级云原生微服务商业解决方案
@@ -91,42 +101,10 @@ Polaris为Discovery高级定制版，特色功能
- [指南示例源码Gitee版](https://gitee.com/polaris-paas/polaris-guide)
④ 指南示例说明
-- Spring Cloud旧版本，参考[1.x.x指南示例](https://github.com/polaris-paas/polaris-guide/tree/1.x.x)，分支为1.x.x
-- Spring Cloud新版本，参考[2.x.x指南示例](https://github.com/polaris-paas/polaris-guide/tree/master)，分支为master
-
- Discovery【探索】和Polaris【北极星】架构体系
-
-① Discovery【探索】和Polaris【北极星】联合架构图
-
-
-
-② Discovery【探索】和Polaris【北极星】联合拓扑图
-
-
-
-③ Polaris【北极星】分层架构图
-
-
-
-④ Discovery【探索】实施方案图
-
-
-
-⑤ Discovery【探索】域网关实施图
-
-
-
-⑥ Discovery【探索】非域网关实施图
-
-
-
-⑦ Discovery【探索】全局订阅实施图
-
-
-
-⑧ Discovery【探索】配置中心发布订阅图
-
-
+- Spring Cloud Finchley ~ Hoxton版本
+ - [指南示例](https://github.com/polaris-paas/polaris-guide/tree/1.x.x)，分支为1.x.x
+- Spring Cloud 202x版本
+ - [指南示例](https://github.com/polaris-paas/polaris-guide/tree/master)，分支为master
## 请联系我
微信、钉钉、公众号和文档
diff --git a/discovery-agent-example/discovery-agent-example-agent/pom.xml b/discovery-agent-example/discovery-agent-example-agent/pom.xml
index 1f59c68..95da492 100644
--- a/discovery-agent-example/discovery-agent-example-agent/pom.xml
+++ b/discovery-agent-example/discovery-agent-example-agent/pom.xml
@@ -9,7 +9,7 @@
Title: Nepxion Discovery
+ *Description: Nepxion Discovery
+ *Copyright: Copyright (c) 2017-2050
+ *Company: Nepxion
+ * @author zifeihan + * @version 1.0 + */ + +import javassist.ClassPool; +import javassist.CtClass; +import javassist.CtConstructor; +import javassist.CtField; +import javassist.CtMethod; + +import java.lang.reflect.Method; +import java.security.ProtectionDomain; + +import com.nepxion.discovery.agent.async.AsyncContextAccessor; +import com.nepxion.discovery.agent.callback.TransformCallback; +import com.nepxion.discovery.agent.logger.AgentLogger; +import com.nepxion.discovery.agent.util.ClassInfo; + +public abstract class ThreadTransformCallback implements TransformCallback { + private static final AgentLogger LOG = AgentLogger.getLogger(ThreadTransformCallback.class.getName()); + + @Override + public byte[] doInTransform(ClassLoader classLoader, String className, Class classBeingRedefined, ProtectionDomain protectionDomain, byte[] classfileBuffer) { + try { + ClassInfo classInfo = new ClassInfo(className, classfileBuffer, classLoader); + CtClass ctClass = classInfo.getCtClass(); + + addField(ctClass, AsyncContextAccessor.class); + + CtConstructor[] declaredConstructors = ctClass.getDeclaredConstructors(); + for (CtConstructor ctConstructor : declaredConstructors) { + ctConstructor.insertAfter(ThreadConstant.CONSTRUCTOR_INTERCEPTOR); + } + + String implMethodName = getImplMethodName(); + CtMethod ctMethod = ctClass.getDeclaredMethod(implMethodName); + if (null != ctMethod) { + ctMethod.insertBefore(ThreadConstant.RUN_BEFORE_INTERCEPTOR); + ctMethod.insertAfter(ThreadConstant.RUN_AFTER_INTERCEPTOR); + } + + return ctClass.toBytecode(); + } catch (Exception e) { + LOG.warn(String.format("Transform %s error, message:", className), e); + + return null; + } + } + + public void addField(CtClass ctClass, Class clazz) { + try { + ClassPool aDefault = ClassPool.getDefault(); + CtClass makeInterface = aDefault.makeInterface(clazz.getName()); + ctClass.addInterface(makeInterface); + + Method[] methods = clazz.getDeclaredMethods(); + if (methods.length != 2) { + throw new IllegalArgumentException("accessorType has to declare 2 methods. " + clazz.getName() + " has " + methods.length); + } + + Method getter; + Method setter; + + if (methods[0].getParameterTypes().length == 0) { + getter = methods[0]; + setter = methods[1]; + } else { + getter = methods[1]; + setter = methods[0]; + } + + Class fieldType = getter.getReturnType(); + String fieldName = fieldType.getSimpleName().toLowerCase(); + String field = String.format("private %s %s;", fieldType.getName(), fieldName); + + CtField f1 = CtField.make(field, ctClass); + ctClass.addField(f1); + + String getMethod = String.format("public %s %s(){return %s;}", fieldType.getName(), getter.getName(), fieldName); + String setMethod = String.format("public void %s(%s %s){this.%s = %s;}", setter.getName(), fieldType.getName(), fieldName, fieldName, fieldName); + + CtMethod m1 = CtMethod.make(getMethod, ctClass); + CtMethod m2 = CtMethod.make(setMethod, ctClass); + ctClass.addMethod(m1); + ctClass.addMethod(m2); + } catch (Exception e) { + LOG.warn(String.format("Add field %s error, message:", clazz.getName()), e); + } + } + + public abstract String getImplMethodName(); +} \ No newline at end of file diff --git a/pom.xml b/pom.xml index fddef1b..bdca16d 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@