龙空技术网

轻量级RPC服务框架 MyThrift

懂点代码的程序员 413

前言:

今天同学们对“apache pool2创建socket连接池”大致比较关心,兄弟们都想要分析一些“apache pool2创建socket连接池”的相关资讯。那么小编在网络上搜集了一些对于“apache pool2创建socket连接池””的相关文章,希望姐妹们能喜欢,你们快快来学习一下吧!

基于以下组件打造的一款轻量级RPC服务框架:thrift(facebook出品)、commons-pool(socket连接池)、自研服务治理框架(zookeeper).

1-运维组创建maven私服

一般,公司内部代码,如果有别的项目组需要引用的jar包,一般放在公司内部maven私服上,所以,请先创建一个maven私服。可以参考网上的文章: 具体过程就不说了,读者自己解决,最后,我们可以获得一个类似网址的就可以了,这里的IP是你自己的实际IP.后面用到时请自行替换IP.

2-架构组上传common工程jar包

common工程一般是公司的架构组负责维护,业务方不需要关心。common工程有新的版本替换时,告知业务方使用新的版本打包即可。1)eclipse单独引入common工程,进行源码修改(有必要的话,比如架构组需要升级).2)进入common项目工程,开始编译打包 mvn -X clean compile package3)顺利的话,可以看到2个jar包,一个有依赖,一个不带依赖。4)请上传其中一个jar包到你的maven私服上,可以选择手动上传,如果对maven熟悉的话也可以命令行自动上传。这里我选择的是不带依赖包的jar包上传到maven私服。上传之后,记住相关的maven信息,后面会用到。这个信息在maven私服里也可以看到的,比如我的就是com.freedom.rpcmythrift-common2.0.1

3-服务提供方上传service工程jar包

好,到了这里比如公司需要有一个服务,指定了一个团队负责这个微服务,此时,这个团队需要定义好服务的接口,这样就可以打包上传到maven私服,让别的团队先用起来,然后自己再慢慢写代码实现,两方都不耽误所以,这里重点是定义一个空的接口定义文件。但是在编写接口文件之前,我们需要搭建文件的编译环境。1)Thrift编译环境搭建首先,用户需要知道怎么搭建thrift的编译环境打开 输入图片说明红色方框内的网址实际上是: 下载到你的linux机器上,解压缩,然后依次执行下列命令:./configure --with-lua=no 这一步时间会比较长makesudo make install}看到下面的图片表示安装成功输入图片说明2)编写接口文件&生成对应的java文件必须知道的是,thrift需要先定义一个 xx.thrift文件,此文件用来定义类似于interface的若干接口下面举个例子,我有一个HelloWorldService.thrift文件,内容如下:输入图片说明那么,用户会问“我怎么知道有什么类型呢”,别急,见文档 :第一个参数前面就是1,第2个参数就是2,比如string helloWorldString(1:string content, 2:string param2 , 3:string param3)好,现在已经有了接口文件,然后如何生成对应的java文件呢?因为是为了生成java文件,所以执行thrift --gen java HelloWorldService.thrift然后就会看到当前文件夹有个gen-java文件夹,如图所示:输入图片说明可以看到这个文件很大,这是因为thrift已经帮我们做好了很多额外的工作,比如序列化和反序列化,这样我们才可以很轻松的享受便利!那么,到这里,我们实际上,已经完成了1)定义xx.thrift2) 根据xx.thrift生成接口类下面就开始使用这2个文件了3)业务java接口文件融入java框架工程里已经有了一个service demo工程,模仿它的结构,创建一个你自己的maven工程把你自己的接口java代码放在src/main/java里,.thrift存根文件放在src/main/resources目录下这个时候会报错,在pom.xml中加上对mythrift-common的jar包依赖,同时还需要增加别的相关依赖,因为common包里并没有把依赖包打进去。比如thrift的依赖包就是<!-- thrift --> <dependency> <groupId>org.apache.thrift</groupId> <artifactId>libthrift</artifactId> <version>0.9.3</version> </dependency> 必要的话,修改里面的maven私服地址。接下来,很重要的一个步骤,加上接口文件的注解,这个非常重要,比如在类上加上// 加上注解,才可以被扫描到@Processor(group = "test", service = "HelloWorldService", edition = "2.0.1")分别代表组名,服务名,版本号!Processor找不到的话,加上import com.freedom.rpc.thrift.common.annotation.Processor;然后,开始打包,打完包后,上传到maven私服,这样别的团队才可以使用接口。

4.1-服务提供方编码实现service

微服务业务团队,模仿demo中的server工程,创建一个类似的工程

比如包含接口文件的具体实现,还有自己的主类调用RpcServer.start(args);

注意:接口文件实现类和service接口文件的定义必须在同一个包里

比如:

接口文件在service的a.b.c

那么实现类你可以放在server里的a.b.c.impl目录下

研究下pom文件,看看需要修改的自行修改

比如需要加上service的maven依赖,还有common工程的maven依赖,其它缺失的依赖自己补上。

然后,实现接口实现文件里面的每个接口函数就可以了。

最后就可以打包,打包的时候,注意不要把log4j.properties和server.properties打包进去。

打完包后,

将二进制文件thrift-server-binary-[版本号].tar.gz解压缩在linux下某个目录下

然后mythrift-server/target/mythrift-server-[版本号]-jar-with-dependencies.jar

替换之前解压缩的目录/lib/对应的jar包,注意,是替换,老的jar包需要删除。

同时替换log4j.properties{在common工程里}和server.properties文件{server工程里}

原有的压缩包里的配置文件比较老了,务必用最新的工程里的配置文件代替它,并修改相应的参数信息。

然后审查linux环境下的conf目录里的各个配置文件-log4j.properties ,server.properties的配置是否正确

修改下run.sh里面的主类为你自己的主类

然后启动./run.sh即可。

在linux上发布,启动run.sh脚本即可。

4.2-业务调用方编码调用service

请自行研究下demo里的client工程代码,在你自己的业务代码里调用即可。(实际中,是在你的web工程/其它工程 中调用的)注意配置文件的参数。将二进制文件thrift-client-binary-[版本号].tar.gz解压缩在linux下某个目录下然后将编译好的mythrift-client/target/mythrift-client-[版本号]-jar-with-dependencies.jar替换之前解压缩的目录/lib/对应的jar包,注意,是替换,老的jar包需要删除。同时替换log4j.properties{在common工程里}和client.properties文件{client工程里}原有的压缩包里的配置文件比较老了,务必用最新的配置文件代替它,并修改相应的参数信息。然后审查linux环境下的conf目录里的各个配置文件-log4j.properties ,client.properties的配置是否正确修改下run.sh里面的主类为你自己的主类然后启动./run.sh即可,然后查看日志文件(logs目录下)的输出,确认是否成功执行!这样,一个简单的RPC服务就编写完毕,

标签: #apache pool2创建socket连接池