文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

JavaAgent如何实现http接口发布

2023-07-05 08:21

关注

这篇文章主要介绍“JavaAgent如何实现http接口发布”,在日常操作中,相信很多人在JavaAgent如何实现http接口发布问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”JavaAgent如何实现http接口发布”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

需求

公司运维系统想要监控服务是否正常启动,这些服务是k8s部署的,运维人员的要求业务服务提供一个http接口用于监控服务健康监测,要求所有的接口请求的URL,参数等都是相同的,这么做的目的是不需要通过规范来约束开发人员去开一个服务健康监测的接口。

使用服务接口来检测服务我觉得相比较监控进程启动,端口监听等方式更准确一些。所以,为了满足运维同学的要求,起初想到的方案是提供一个jar,专门集成到项目中用于发布监控接口,但是想了一下,这么做需要涉及到服务的改造,我理想的方式是对应用无侵入的方式实现。

初步方案

说到对应用无入侵,首先想到的就是javaagent技术,此前使用该技术实现了无入侵增强程序日志的工具,所以对使用javaagent已经没有问题,此时需要考虑的是如何发布接口了。

基础技术 JavaAgent

支持的技术 SpringBoot和DubboX发布的rest服务

公司服务大致分为两类,一个是使用springboot发布的Spring MVC rest接口,另一种是基于DubboX发布的rest接口,因为公司在向服务网格转,所以按要求是去dubbo化的,没办法还是有其他小组由于一些其他原因没有或者说短期内不想进行服务改造的项目,这些项目比较老,不是springboot的,是使用spring+DubboX发布的rest服务。所以这个agent要至少能支持这两种技术。

支持SpringBoot

想要支持SpringBoot很简单,因为SpringBoot支持自动装配,所以,我要写一个spring.factories来进行自动装配。

支持DubboX

业务系统是传统spring+DubboX实现的,并不支持自动装配,这是个问题点,还有个问题点就是如何也发布一个DubboX的rest接口,这两个问题实际上就需要对SpringBean生命周期和Dubbo接口发布的流程有一定的了解了,这个一会儿再说。

技术实现

pom文件依赖

    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>            <version>2.3.6.RELEASE</version>            <optional>true</optional>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-autoconfigure</artifactId>            <version>2.3.6.RELEASE</version>            <optional>true</optional>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-configuration-processor</artifactId>            <version>2.3.6.RELEASE</version>            <optional>true</optional>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>fastjson</artifactId>            <version>1.2.70</version>        </dependency>        <dependency>            <groupId>org.apache.zookeeper</groupId>            <artifactId>zookeeper</artifactId>            <version>3.4.6</version>            <exclusions>                <exclusion>                    <groupId>log4j</groupId>                    <artifactId>log4j</artifactId>                </exclusion>            </exclusions>        </dependency>        <dependency>            <groupId>com.101tec</groupId>            <artifactId>zkclient</artifactId>            <version>0.7</version>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>dubbo</artifactId>            <version>2.8.4</version>            <exclusions>                <exclusion>                    <groupId>org.springframework</groupId>                    <artifactId>spring</artifactId>                </exclusion>            </exclusions>        </dependency>        <dependency>            <groupId>javax.ws.rs</groupId>            <artifactId>javax.ws.rs-api</artifactId>            <version>2.0.1</version>        </dependency>    </dependencies>

实现一个JavaAgent

实现一个JavaAgent很容易,以下三步就可以了,这里不细说了。

定义JavaAgent入口

public class PreAgent {    public static void premain(String args, Instrumentation inst) {        System.out.println("输入参数:" + args);        // 通过参数控制,发布的接口是DubboX还是SpringMVC        Args.EXPORT_DUBBOX = args;    }}

Maven打包配置

        <plugins>            <plugin>                <artifactId>maven-deploy-plugin</artifactId>                <configuration>                    <skip>true</skip>                </configuration>            </plugin>            <plugin>                <groupId>org.apache.maven.plugins</groupId>                <artifactId>maven-shade-plugin</artifactId>                <version>1.4</version>                <executions>                    <execution>                        <phase>package</phase>                        <goals>                            <goal>shade</goal>                        </goals>                        <configuration>                            <keepDependenciesWithProvidedScope>true</keepDependenciesWithProvidedScope>                            <promoteTransitiveDependencies>false</promoteTransitiveDependencies>                            <createDependencyReducedPom>true</createDependencyReducedPom>                            <minimizeJar>false</minimizeJar>                            <createSourcesJar>true</createSourcesJar>                            <transformers>                                <transformer                                        implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">                                    <manifestEntries>                                        <Premain-Class>com.ruubypay.agent.PreAgent</Premain-Class>                                    </manifestEntries>                                </transformer>                            </transformers>                        </configuration>                    </execution>                </executions>            </plugin>        </plugins>

MANIFEST.MF编写

注:该文件在resource/META-INF/目录下

Manifest-Version: 1.0
Can-Redefine-Classes: true
Can-Retransform-Classes: true
Premain-Class: com.ruubypay.agent.PreAgent

支持SpringBoot发布的Http接口

编写Controller

接口很简单就发布一个get接口,响应pong即可。

@RestControllerpublic class PingServiceController {    @GetMapping(value = "/agentServer/ping")    public String ping() {        return "pong";    }}

创建spring.factories

通过这个配置文件可以实现SpringBoot自动装配,这里不细说SpringBoot自动装配的原理了,该文件的配置内容就是要自动装配的Bean的全路径,代码如下:

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
  com.ruubypay.config.WebConfiguration

WebConfiguration配置类

这个配置配置类很简单,@Configuration声明这是个配置类,@ComponentScan扫描包。

@Configuration@ComponentScan(value = "com.ruubypay")public class WebConfiguration {}

支持DubboX发布的rest接口

定义API

使用的是DubboX发布rest接口需要javax.ws.rs包的注解,@Produces({ContentType.APPLICATION_JSON_UTF_8})声明序列化方式,@Pathrest接口的路径,@GET声明为get接口。

@Produces({ContentType.APPLICATION_JSON_UTF_8})@Path("/agentServer")public interface IPingService {        @GET    @Path("/ping")    String ping();}

编写API实现类

@Component("IPingService")public class IPingServiceImpl implements IPingService {    @Override    public String ping() {        return "pong";    }}

实现发布Dubbo接口

如何实现发布接口是实现的难点;首先程序并不支持自动装配了,我们就要考虑如何获取到Spring上下文,如果能够注册BeanSpring容器中,如何触发发布Dubbo接口等问题。

Spring上下文获取及注册Bean到Spring容器中

触发Bean注册,获取Spring上下文我们通过Spring的Aware接口可以实现,我这里使用的是ApplicationContextAware;注册BeanSpring容器中可以使用BeanDefinition先创建Bean然后使用DefaultListableBeanFactoryregisterBeanDefinitionBeanDefinition注册到Spring上下文中。

@Componentpublic class AgentAware implements ApplicationContextAware {    private static final String DUBBOX = "1";    private ApplicationContext applicationContext;    @Override    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {        this.applicationContext = applicationContext;        // 如果不是DubboX,不用发布接口        if (DUBBOX.equals(Args.EXPORT_DUBBOX)) {            // 注册配置Bean WebConfiguration            webConfiguration();            // 发布DubboX接口            exportDubboxService();        }    }    public void webConfiguration() {        System.out.println("创建WebConfiguration的bean");        ConfigurableApplicationContext configurableApplicationContext = (ConfigurableApplicationContext) applicationContext;        DefaultListableBeanFactory listableBeanFactory = (DefaultListableBeanFactory) configurableApplicationContext.getAutowireCapableBeanFactory();        // 创建WebConfiguration的bean        BeanDefinition webConfigurationBeanDefinition = new RootBeanDefinition(WebConfiguration.class);        // 注册到集合beanFactory中        System.out.println("注册到集合beanFactory中");        listableBeanFactory.registerBeanDefinition(WebConfiguration.class.getName(), webConfigurationBeanDefinition);    }}

发布Dubbo接口

通过ApplicationContextAware我们已经能够获取Spring上下文了,也就是说应用程序的Dubbo注册中心,发布接口协议,Dubbo Application等配置都已经存在Spring容器中了,我们只要拿过来使用即可,拿过来使用没问题,我们接下来就需要考虑,如何发布接口,这需要对Dubbo服务发布的流程有一定的了解,这里我不细说了,感兴趣的可以自己了解下,或者看我以前发布的文章;

首先Dubbo接口的Provider端的核心Bean是com.alibaba.dubbo.config.spring.ServiceBean,使用Spring配置文件中的标签<dubbo:service标签生成的Bean就是ServiceBean,所以,这里我们只需要创建ServiceBean对象并且初始化对象中的必要数据,然后调用ServiceBean#export()方法就可以发布Dubbo服务了。

这里需要的对象直接通过依赖查找的方式从Spring容器获取就可以了 ApplicationConfig,ProtocolConfig,RegistryConfig,IPingService

    public void exportDubboxService() {        try {            System.out.println("开始发布dubbo接口");            // 获取ApplicationConfig            ApplicationConfig applicationConfig = applicationContext.getBean(ApplicationConfig.class);            // 获取ProtocolConfig            ProtocolConfig protocolConfig = applicationContext.getBean(ProtocolConfig.class);            // 获取RegistryConfig            RegistryConfig registryConfig = applicationContext.getBean(RegistryConfig.class);            // 获取IPingService接口            IPingService iPingService = applicationContext.getBean(IPingService.class);            // 创建ServiceBean            ServiceBean<IPingService> serviceBean = new ServiceBean<>();            serviceBean.setApplicationContext(applicationContext);            serviceBean.setInterface("com.ruubypay.api.IPingService");            serviceBean.setApplication(applicationConfig);            serviceBean.setProtocol(protocolConfig);            serviceBean.setRegistry(registryConfig);            serviceBean.setRef(iPingService);            serviceBean.setTimeout(12000);            serviceBean.setVersion("1.0.0");            serviceBean.setOwner("rubby");            // 发布dubbo接口            serviceBean.export();            System.out.println("dubbo接口发布完毕");        } catch (Exception e) {            e.printStackTrace();        }    }

使用方式

到此,关于“JavaAgent如何实现http接口发布”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注编程网网站,小编会继续努力为大家带来更多实用的文章!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯