DC / OS中具有Java和数据库应用程序的服务发现

该博客将展示一个简单的Java应用程序如何使用DC / OS中的服务发现与数据库进行对话。

为什么要进行服务发现?

应用程序通常由多个组件组成,例如应用程序服务器,数据库,Web服务器,缓存和消息传递服务器。 通常,每个组件的多个副本将根据应用程序的需求运行。 使用容器编排框架部署此应用程序意味着每个副本都将作为容器运行。 因此,通常将应用程序部署为多容器应用程序。

每个容器在其生命周期内都分配有唯一的IP地址。 但是容器是短暂的,可以通过业务流程框架终止并重新安排在其他主机上。 在这种情况下,通常会为容器分配一个不同的IP地址。 这意味着部署在应用程序服务器中的应用程序不能依赖数据库的IP地址。 这是需要服务发现的地方。

因此,将为组件的多个副本分配一个逻辑名称。 例如,对于所有应用程序服务器容器为web ,对于所有数据库容器为db 。 现在,应用程序可以使用逻辑服务名称与数据库容器进行对话。 这使数据库容器可以在群集中的任何位置进行重新调度,也可以动态扩展和缩减。

让我们看看如何在DC / OS中使用单个应用程序服务器和数据库服务器实例来完成此任务。 该博客将使用WildFly作为应用程序服务器,并使用Couchbase作为数据库。

具有DC / OS的Mesos上的Couchbase群集提供了有关如何在DC / OS上设置Couchbase群集的更多详细信息。

该博客将使用以下主要步骤:

  • 设置DC / OS群集
  • 马拉松比赛的定义
  • 部署应用

本博客中使用的完整源代码位于github.com/arun-gupta/dcos-java-database 。

非常感谢@unterstein创建了Maven插件并帮助我了解了DC / OS的内部工作原理。

设置DC / OS群集

可以使用CloudFormation模板轻松创建DC / OS集群。 可在AWS上安装DC / OS上获得包括系统要求以及屏幕截图和设置在内的详细说明。

CloudFormation输出看起来如下所示:

记下为键DnsAddressPublicSlaveDnsAddress显示的值。 第一个键的值可用于访问DC / OS GUI ,如下所示:

按照CLI中的说明配置DC / OS CLI 。 简而言之,使用以下命令:

  • dcos config set core.dcos_url http://${DnsAddress}${DnsAddress}替换${DnsAddress}输出中的相应值。
  • dcos auth login
  • dcos config show core.dcos_acs_token 。 如果尚未完成,请从github.com/arun-gupta/dcos-java-database克隆存储库 。 创建一个新文件.dcos-token并将命令的输出复制到此文件中。
  • dcos package install marathon-lb

马拉松应用定义

Marathon框架用于调度DC / OS中的容器。 可以通过提供应用程序定义来定义马拉松应用程序 。

如前所述,该博客将展示一个简单的Java应用程序如何与数据库对话。 我们将使用WildFly中部署的Java EE应用程序,并将Couchbase用作数据库。 应用程序定义如下:

{  "id":"/webapp","apps":[  {  "id":"database","cpus":4,"mem":4096,"instances":1,"container":{  "type":"DOCKER","docker":{  "image":"arungupta/couchbase:travel","network":"USER"}},"ipAddress":{  "networkName":"dcos"}},{  "id":"web","dependencies":[  "/webapp/database"],"cpus":2,"mem":4096,"instances":1,"container":{  "type":"DOCKER","docker":{  "image":"arungupta/wildfly-couchbase-javaee:travel","network":"USER","portMappings":[  {  "hostPort":0,"containerPort":8080,"protocol":"tcp"}]}},"ipAddress":{  "networkName":"dcos"},"env":{  "COUCHBASE_URI":"database-webapp.marathon.containerip.dcos.thisdcos.directory"},"labels":{  "HAPROXY_0_VHOST":"DCOS-PublicSlaveLo-DD2EGGFVCJA0-1604955948.us-west-1.elb.amazonaws.com","HAPROXY_GROUP":"external"}}]
}

此应用程序定义中的关键点是什么?

  • 应用程序具有两个容器: databaseweb 。 Web容器对使用dependencies属性定义的数据库容器具有dependencies
  • database容器使用arungupta/couchbase:travel Docker映像。 该图像是从github.com/arun-gupta/couchbase-javaee/tree/master/couchbase创建的。 它使用Couchbase基本映像,并使用Couchbase REST API来预配置数据库。 样本存储桶也被加载到数据库中。
  • web容器使用arungupta/wildfly-couchbase-javaee:travel图片。 该图像是从github.com/arun-gupta/couchbase-javaee/blob/master/Dockerfile创建的。 这是WildFly中捆绑的Java EE 7应用程序。 该应用程序使用COUCHBASE_URI作为环境变量来连接到Couchbase数据库。 此环境变量的值配置为使用DNS服务发现,并按照“ 虚拟网络”中的说明派生。

确保更改HAPROXY_0_VHOST的值以匹配${PublicSlaveDnsAddress}输出中的${PublicSlaveDnsAddress}的值。 标签HAPROXY_0_VHOST指示Marathon-LB在具有虚拟主机的外部负载均衡器上公开Docker容器(在我们的情况下为WildFly应用服务器)。 标签键中的0对应于servicePort索引,从0开始。如果您有多个servicePort定义,则将其迭代为0、1、2,依此类推。 使用marathon-lb部署内部和外部负载平衡的应用程序将提供有关如何配置marathon-lb的更多详细信息。

服务发现和负载平衡提供了有关DC / OS中服务发现和负载平衡的更多详细信息。

使用Maven部署应用程序

可以使用dcos-maven-plugin部署该应用程序。

插件看起来像:

<plugin><groupId>dcos</groupId><artifactId>dcos-maven-plugin</artifactId><version>0.2</version><configuration><dcosUrl>http://DCOS-ElasticLoadBa-1TH4TXIU5P783-1163025470.us-west-1.elb.amazonaws.com/</dcosUrl><deployable>group</deployable><ignoreSslCertificate>true</ignoreSslCertificate></configuration><executions><execution><id>dcos:deploy</id><phase>install</phase><goals><goal>deploy</goal></goals></execution></executions>
</plugin>

该片段的要点是:

  • 插件版本为0.2。 这表明该插件仍处于开发的早期阶段。
  • dcosUrl${DnsAddress}输出中${DnsAddress}键的值。 该地址用于部署应用程序。
  • <deployable>元素支持不同类型的部署-应用程序,组或Pod。 该元素是对插件的提示,随着Marathon API的整合,该元素可能会在将来的版本中消失。 遵循#11了解更多详细信息。

有关该插件的其他详细信息和配置位于dcos-maven-plugin 。

部署应用程序:

mvn install

显示以下输出:

[INFO] --- dcos-maven-plugin:0.2:deploy (dcos:deploy) @ dcos-java-database ---
[INFO] About to execute DC/OS deploy
[INFO] app definition: /Users/arungupta/workspaces/dcos-java-database/app-definition.json
[INFO] dcos token: /Users/arungupta/workspaces/dcos-java-database/.dcos-token
[INFO] dcos url: http://DCOS-ElasticLoadBa-1TH4TXIU5P783-1163025470.us-west-1.elb.amazonaws.com/
[INFO] ignore ssl certificate: true
[INFO] deployable: group
[INFO] Response from DC/OS [200] {"version":"2017-03-07T13:27:49.970Z","deploymentId":"dbc80f96-28cb-4040-8d0d-78452e461ec1"}

这是DC / OS控制台的一些更新输出。

首次更新的服务标签:

服务中的两个应用程序:

数据库应用程序具有一项任务:

数据库任务的状态:

来自数据库任务的日志:

它显示了用于配置服务器的Couchbase REST API的输出。

网络任务的状态:

来自Web任务的日志:

它显示Java EE应用程序已成功部署。

访问应用程序:

curl http://DCOS-PublicSlaveLo-DD2EGGFVCJA0-1604955948.us-west-1.elb.amazonaws.com/airlines/resources/airline

该地址是${PublicSlaveDnsAddress}输出中键${PublicSlaveDnsAddress}的值。 格式化的输出(例如jq )如下所示:

[{"travel-sample": {"country": "United States","iata": "Q5","callsign": "MILE-AIR","name": "40-Mile Air","icao": "MLA","id": 10,"type": "airline"}},{"travel-sample": {"country": "United States",. . ."icao": "RLA","id": 1203,"type": "airline"}}
]

而已!

如前所述,此博客中使用的完整源代码位于github.com/arun-gupta/dcos-java-database 。

该博客显示了一个简单的Java应用程序如何使用DC / OS中的服务发现与数据库进行对话。

有关更多信息,请查看:

  • DC / OS文件
  • 容器上的Couchbase
  • Couchbase 开发人员门户
  • 在Couchbase论坛或堆栈溢出中提问
  • 下载Couchbase

翻译自: https://www.javacodegeeks.com/2017/03/service-discovery-java-database-application-dcos.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/350114.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

RAC环境下创建本地数据文件的解决方法

引用收藏&#xff1a;http://blog.itpub.net/501889/viewspace-1083311/ 同事不小心&#xff0c;在RAC环境下创建了本地数据文件&#xff0c;这个肯定会出问题的&#xff0c;节点2不能访问此数据文件。其实发现做错了&#xff0c;立马删掉应该没有问题。数据文件还没有数据。下…

诺基亚n1平板电脑刷机教程_【个人记事本】闲鱼购买平板的经历

今年由于疫情原因&#xff0c;国内开展了全体学生在家学习的模式&#xff0c;这就避免不了老师发一些课件&#xff0c;还有一些录课的视频等电子学习资料等。考虑到开学复习的便利性&#xff08;平板比笔记本电脑更具有便携性&#xff0c;更方便&#xff09;。所以&#xff0c;…

找出一个字符串中出现次数最多的字_487,重构字符串

想了解更多数据结构以及算法题&#xff0c;可以关注微信公众号“数据结构和算法”&#xff0c;每天一题为你精彩解答。问题描述给定一个字符串S&#xff0c;检查是否能重新排布其中的字母&#xff0c;使得两相邻的字符不同。若可行&#xff0c;输出任意可行的结果。若不可行&am…

一、数据设计规范

一、数据设计规范 1、表的前缀 1、表名称不应该取得太长&#xff08;一般不超过三个英文单词。不推荐使用中文拼音&#xff0c;总的长度不要超过30个字符&#xff09; 格式:Tbl_Wms_log 表示 表_Wms系统_log 好处:执行查询方式辨别SQL类别(T_表-Table、V_视图-View、S_存储过…

http缓存管理器_小心缓存管理器

http缓存管理器如果使用spring和JPA&#xff0c;则很有可能利用ehcache&#xff08;或其他缓存提供程序&#xff09;。 您可以在两种不同的情况下进行此操作&#xff1a;JPA 2级缓存和spring方法缓存。 配置应用程序时&#xff0c;通常会设置JPA提供程序的二级缓存提供程序&am…

cad线加粗怎么设置_AutoCAD2019怎么加粗线条 将不同线段加粗方法

AutoCAD2019是一款非常专业的制图软件&#xff0c;那有很多用户表示自己不知道这款软件怎么加粗线条&#xff0c;下面就通过这篇文章给大家介绍一下&#xff0c;一起往下看吧&#xff01;如图所示&#xff0c;我用L命令绘制一根线段&#xff1a;&#xff0c;这根线段的宽度为默…

时间管理——你不可不知的3种时间管理方法

时间管理——你不可不知的3种时间管理方法 时间管理 英文名:Time Management   请问&#xff0c;如果每天都有86400元进入你的银行户头&#xff0c;而你必须当天用光&#xff0c;你会如何运用这笔钱&#xff1f;   天下真有这样的好事吗&#xff1f;   是的&#xff0c;…

python tkinter布局混用_[宜配屋]听图阁

这篇文章主要介绍了python tkinter控件布局项目实例,文中通过示例代码介绍的非常详细&#xff0c;对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下代码部分&#xff1a;from tkinter import *import tkinter.messagebox as messageboxclass Tkdemo():def __i…

ASP.NET中利用ashx实现图片防盗链

盗链的危害我就不说了&#xff0c;网上有很多。 直接分析盗链原理&#xff1a;看下面用httpwatch截获的http发送的数据 GET /Img.ashx?imgsvn_work.gif HTTP/1.1 Accept: */* Referer: http://www.svnhost.cn/ Accept-Language: zh-cn UA-CPU: x86 Accept-Encoding: gzip, def…

适用于Java开发人员的Elasticsearch:Java的Elasticsearch

本文是我们学院课程的一部分&#xff0c;该课程的标题为Java开发人员的Elasticsearch教程 。 在本课程中&#xff0c;我们提供了一系列教程&#xff0c;以便您可以开发自己的基于Elasticsearch的应用程序。 我们涵盖了从安装和操作到Java API集成和报告的广泛主题。 通过我们简…

matlab 日期排序_MATLAB时间序列的排序函数

sort功能&#xff1a;对时间序列x进行排序。格式&#xff1a;m sort(x, mode) % 当参数mode‘ascend’&#xff0c;表示对x进行升序重排&#xff1b;当mode‘descend’&#xff0c;表示降序重排wrev功能&#xff1a;得到时间序列x的逆序。格式&#xff1a;m wrev(x)如>>…

c标签foreach遍历list_遍历 Dictionary,你会几种方式?

一&#xff1a;背景 1. 讲故事昨天在 StackOverflow 上看到一个很有趣的问题&#xff0c;说: 你会几种遍历字典的方式&#xff0c;然后跟帖就是各种奇葩的回答&#xff0c;挺有意思&#xff0c;马上就要国庆了&#xff0c;娱乐娱乐吧&#xff0c;说说这种挺无聊的问题???。二…

[HDU 4666]Hyperspace[最远曼哈顿距离][STL]

题意: 许多 k 维点, 求这些点之间的最远曼哈顿距离. 并且有 q 次操作, 插入一个点或者删除一个点. 每次操作之后均输出结果. 思路: 用"疑似绝对值"的思想, 维护每种状态下各点的计算值, 插入或删除一个点就更新一次每种状态(用 multiset 或 map 或 priority_queue 实…

过滤器匹配符包含单词_Hamcrest包含匹配器

过滤器匹配符包含单词与Hamcrest 1.2相比 &#xff0c;针对Matchers类的Hamcrest 1.3 Javadoc文档为该类的几种方法添加了更多文档。 例如&#xff0c;四个重载的contains方法具有更具描述性的Javadoc文档&#xff0c;如下面所示的两个比较屏幕快照所示。 尽管仅通过尝试就可以…

linux配置4g网络命令_树莓派移动网络连接(配置4G网卡)

1、识别上网卡使用命令lsusb&#xff0c;如果能够识别则可以继续往下。2、安装网卡驱动程序上网卡一般都会带有2个功能&#xff0c;一个是虚拟光驱&#xff0c;用来安装驱动程序&#xff1b;另一个是进行网络连接的modem。在Linux下&#xff0c;需要安装usb-modeswitch驱动程序…

Hibernate 配置详解(5)

9) hibernate.batch_fetch_style: 该配置是hibernate4.2.0新添加的&#xff0c;使用这个设置可以配置hibernate在做batch-fetch的时候&#xff0c;生成SQL的策略。该配置项的可选值为org.hibernate.loader.BatchFetchStyle这个枚举类型中的可选值。所以&#xff0c;目前有三个选…

使用HazelCast进行休眠缓存:JPA缓存基础知识

HazelCast的最大功能之一就是对hibernate二级缓存的支持 。 JPA具有两个级别的缓存。 一级缓存在事务期间缓存对象的状态。 通过查询相同的对象两次&#xff0c;您必须获得第一次获取的对象。 但是&#xff0c;在包含您检索到的对象并访问数据库的复杂查询的情况下&#xff…

mvcc原理_Mysql MVCC实现原理

本文中用到的概念解释数据读取特性不可重复读指一个事务范围内两个相同的查询却返回了不同数据这是由于查询时系统中其他事务修改的提交而引起的幻读在两个连续的查找之间一个并发的修改事务修改了查询的数据集&#xff0c;导致这两个查询返回了不同的结果这是由于查询时系统中…

java数组复制的方式和效率比较

java中&#xff0c;数组的复制有以下三种方式&#xff1a; 1. 调用System.arraycopy&#xff08;Arrays.copyOfRange可以当作第四种&#xff0c;但是底层调用的是System.arraycopy&#xff0c;所以&#xff0c;认为是同一种&#xff0c;下面是Arrays.copyOfRange的方法实现&…

Java命令行界面(第18部分):JCLAP

Giles Winstanley的JCLAP &#xff08; Java命令行参数解析器 &#xff09;是基于Java的命令行处理库的系列文章中介绍的第18个库。 这篇文章的示例基于需要Java 8的 JCLAP 1.4 。 JCLAP主页上指出&#xff1a;“ JCLAP帮助Java开发人员为其应用程序创建易于使用的命令行界面。…