java databus_linkedin 的 databus 部署「建议收藏」

java databus_linkedin 的 databus 部署「建议收藏」1.下载源码复制ojdbc.jar到相应的文件夹gitclonehttps://github.com/linkedin/databus/sandbox-repo/com/oracle/ojdbc6/11.2.0.2.0/ojdbc6-11.2.0.2.0.jar2.在subprojects.gradle中加上options.addStringOption(‘encodi…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

1. 下载源码 复制 ojdbc.jar 到相应的文件夹

git clone https://github.com/linkedin/databus/

sandbox-repo/com/oracle/ojdbc6/11.2.0.2.0/ojdbc6-11.2.0.2.0.jar

2. 在 subprojects.gradle 中 加上

options.addStringOption(‘encoding’, ‘UTF-8’)

最后的结果为

if (JavaVersion.current().isJava8Compatible()) {

allprojects {

tasks.withType(Javadoc) {

options.addStringOption(‘Xdoclint:none’, ‘-quiet’)

options.addStringOption(‘encoding’, ‘UTF-8’)

}

}

}

3. 在 build.gradle 中加上

tasks.withType(JavaCompile) { options.encoding = “UTF-8” }

4. 在 com.linkedin.databus2.core.container.netty.ServerContainer 的 initializeContainerJmx() 方法中加上一句

LocateRegistry.createRegistry(_containerStaticConfig.getJmx().getRmiRegistryPort());

最后的结果为 (不然会报 Cannot bind to URL rmi://localhost:1099 ServiceUnavailableException )

protected void initializeContainerJmx() {

if (_containerStaticConfig.getJmx().isRmiEnabled()) {

try {

JMXServiceURL jmxServiceUrl = new JMXServiceURL(

“service:jmx:rmi://” + _containerStaticConfig.getJmx().getJmxServiceHost() + “:”

+ _containerStaticConfig.getJmx().getJmxServicePort() + “/jndi/rmi://”

+ _containerStaticConfig.getJmx().getRmiRegistryHost() + “:”

+ _containerStaticConfig.getJmx().getRmiRegistryPort() + “/jmxrmi”

+ _containerStaticConfig.getJmx().getJmxServicePort());

LocateRegistry.createRegistry(_containerStaticConfig.getJmx().getRmiRegistryPort());

_jmxConnServer = JMXConnectorServerFactory.newJMXConnectorServer(jmxServiceUrl, null, getMbeanServer());

} catch (Exception e) {

LOG.warn(“Unable to instantiate JMX server”, e);

}

}

}

5. 修改 databus2-example-client-pkg/conf/client_person.properties (非必须)

databus.client.connectionDefaults.enablePullerMessageQueueLogging=false

不然 databus2-example-client-pkg 中的 databus2-client-person.out 日志文件会快速增长

6. 修改 oracle/bin/createUser.sh

sqlplus system/manager\@${DBNAME} as sysdba << __EOF__

改为自己的oracle管理员 用户名 密码

system为管理员用户名 manager为密码

7. 修改 databus2-example/database/person/tablespace (不改也没关系 下面的要一致 我是改成了 tbs_dbbus)

8. 修改 sources-person.json 改为

{

“name”: “person”,

“id”: 1,

“uri”: “jdbc:oracle:thin:dbbus/dbbus@localhost:1521:orcl”,

“slowSourceQueryThreshold”: 2000,

“sources”: [

{

“id”: 101,

“name”: “com.linkedin.events.example.person.Person”,

“uri”: “dbbus.person”,

“partitionFunction”: “constant:1”

}

]

}

9. 打包命令

gradle -Dopen_source=true assemble

生成的工程在 父项目的 build 目录下 (这一点gradle和maven不一样的 )

10. 运行 createUser.sh 新建oracle 用户 dbbus/dbbus 这里的 db_table_space 要与 第8步骤中 databus2-example/database/person/tablespace 里面内容一致

db_path 存放 oracle .dbf 文件的地方 如果不知道 find / -name ‘.dbf’ 就可以找到路径了 乱写应该问题也不大(我没试过)

#createUser.sh db_username db_password db_id db_table_space db_path

sh createUser.sh dbbus dbbus orcl tbs_dbbus /home/u02/11g/dbs/

11.运行 createSchema.sh 在oracle中生成必要的 package table seq tigger Procedure 等

#createSchema.sh db_username/db_password@db_id tab_and_view_path

sh createSchema.sh dbbus/dbbus@orcl /home/yiwu/databus/databus2-example/database/person/

12. 生成 apache-avro 序列化文件

如 com.linkedin.events.example.person.Person.1.avsc com.linkedin.events.example.person.Person_V1.java

这步可以省略 官方的例子已经给你生成好了

avroOutDir javaOutDir 自定义 不需要太准确 生成好之后 拷贝到相应的目录就可以了

#create Avro records

sh dbus2-avro-schema-gen.sh -namespace com.linkedin.events.example.person -recordName Person -viewName “sy\$person” -avroOutDir /home/yiwu/dbtmp -avroOutVersion 1 -javaOutDir /home/yiwu/dbtmp -userName dbbus -password dbbus -database jdbc:oracle:thin:@127.0.0.1:1521:orcl

13. 运行 relay

#解压

tar -zxvf build/databus2-example-relay-pkg/distributions/databus2-example-relay-pkg-2.0.0.tar.gz

#运行

sh start-example-relay.sh person

14. 运行 client

#解压

tar -zxvf build/databus2-example-client-pkg/distributions/databus2-example-client-pkg-2.0.0.tar.gz

#运行

sh start-example-client.sh person

15. 在oracle中执行insert语句

INSERT INTO person(id,first_name, last_name) VALUES(1,’balaji’, ‘varadaran’);

就可以在 build/databus2-example-client-pkg/distributions/logs/client.log 中看到相应的记录了

2017-08-24 14:46:46,795 +752167 [callback-1] (INFO) {PersonConsumer} firstName: balaji, lastName: varadaran, birthDate: null, deleted: false

end

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181118.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 十大经典思维面试题_JS面试题大全

    十大经典思维面试题_JS面试题大全年轻人你不讲武德,耗子尾汁~~~总结就是为了形成自己的js知识网,提升自己,加油!开始干1、介绍js的基本数据类型  答:Undefined、Null、Boolean、Number、String2、js有哪些内置对象? 答:数据封装类对象:Object、Array、Boolean、Number和String  其他对象:Function、Arguments、Math、Date、RegExp、Error  3、this对象的理解 答:this总是指向函数的直接调用者(而非间接调用者

  • onStart和onResume的区别

    onStart和onResume的区别当Activity被onCreate后就会进入onStart状态,使这个Activity对用户来说呈可见状态,但不能交互。onStart之后调用onResume使得这个Activity获得焦点,排在了所有其他Activity之前,从而获得与用户交互的能力。

  • Java Calendar.MONTH

    Java Calendar.MONTH1、遇到一个大坑,intnowmonth=c.get(Calendar.MONTH)+1;才为真实的月份,需要加1!2、在Java里的数据库查询语言,如果判断的条件是数据库中的Date格式,可以直接用String格式来匹配判断,不需要转换。3、数据库里一个变量增加1可以写Updatename=name+1

  • 用WijmoJS玩转您的Web应用 —— Ionic

    用WijmoJS玩转您的Web应用 —— Ionic

  • selenium-webdriver_web driver

    selenium-webdriver_web driverChrome:https://chromedriver.storage.proxy.ustclug.org/index.html         https://sites.google.com/a/chromium.org/chromedriver/downloads Firefox:https://github.com/mozilla/geckodriver/release…

  • 无法连接服务器怎么办(原始服务器找不到目标资源)

    Tomcat启动成功访问404:源服务器未能找到目标资源的表示或者是不愿公开一个已经存在的资源表示。项目右键->Properties->JavaBuildPath->Libraries->addLibraries-选择要使用的tomcat版本查看了一下Tomcat文件夹中的webapps文件夹,发现里面并没有我的项目,但是我确实是把项目部署进去了,于是我查看…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号