媒体转码服务设置了API流控限制，避免因短时间内重复调用API导致服务中断的情况出现。API流控限制说明如表1所示。表1 API流控限制

【摘要】广州微梦信息科技有限公司是一家专业的网络服务提供商，公司主营的业务有网站建站，SEO优化推广，小程序开发等业务。公司致力于帮助企业打造出让人眼前一亮的企业品牌形象。 【导语】2018年7月22日，广州微梦信息科技有限公司入驻华为云市场，网站建设，SEO优化推广，小程序开发是我们的主要业务。目前微梦使用的系统，很大程度地降低了企业使用网站难度，实现让企业主无需懂任何代码知识，即能轻松地应用和使用网站，后台操作方式是拖拽完成的。那目前产品应用主要有几个方面。 一、企业建站：在目前互联网、移动互联网高度发达的世界，建立一个企业网站，几乎是一个企业开启业务的标配，但是现在建站市场鱼龙混杂，很多企业几乎都遇到了以下的这些问题：1、   网站不易管理，更新维护需要专业人员。2、  不懂SEO，没流量，网站成僵尸摆设。3、  兼容性差，修改需要花钱改版微梦深知中小企业的痛点，推出了适合于企业应用的H5响应网站，网站采用SAAS部署，繁琐的服务器设置和维护交给我们。界面采用流行的可视化操作方式，让企业管理人员可以专注于企业发展，而无需在网站方面花费太多的时间。   而针对用户最头痛的问题，网站的流量问题，系统采用专业的算法，可以做到定时提醒你对网站做某一方面的操作来提高网站的排名，比如提醒您发布发文章，添加产品等。目前行内还没了解到其它家能做到如此。         二、小程序建设：小程序最近的应用非常火，很多的企业都想拥有自己的小程序，分享流量的红利，但是对于企业来说，如何用性价比最高的产品来实现自己的需求，就很重要了，微梦科技对于，专门开发了一套小程序的应用系统，让用户在以最低的成本，最快的速度和最快捷的方式实现小程序的上线。目前，我司开发出来的小程序被大量应用于企业展示、商城、商圈、酒店、美容、培训、餐饮等行业。      当然，除了上面的服务，微梦科技也提供seo优化，商城、分销商城，O2O等服务，更多详情可以进入云市场店铺查看。  三、结束语 好的产品，再配上华为云计算的地基，相信一定能给用户带来更加可靠稳定的服务，让我们一起期待见证。我们的联系方式：公司网址：www.wmcom.cn公司地址：广州市天河区潭村路348号马赛国际商务中心1711联系电话：18520224701

    马上就是星期五 17:30，面对眼前满满两页A4纸的API列表，下周一就要上线，想想要手动把这些API一个个的注册到网关上，是否有几分无奈，您是否觉得这个周末的约会又要泡汤了？    不要怕，有问题AOS来帮忙解决。亲爱的华为云 AOS用户：    AOS最新版本已经实现华为云API网关服务基本资源对象的编排管理，包括：API、API分组、API流控。AOS提供快速编排API资源的能力，您可以通过在模板中复制已有的API对象，快速完成大量API资源对象的编写，并通过AOS的编排能力，迅速在API网关上进行批量注册和流控配置，提升API管理效率十倍以上。有关华为云AOS的更多信息，请访问我们的网站：产品页面 控制台  帮助文档 发布历史 支持的华为云资源 

体验demo链接：https://console.huaweicloud.com/apig/#/apig/expdemo以“电话号码归属地查询”为例，一键式体验demo，一分钟内完成API的开放，有图有真相。1、开始“体验Demo”，后台自动完成API的开放。2、调试API，查看返回结果。3、通过浏览器调用API，查询电话号码的归属地。  通过以下界面查看体验demo创建的API分组详情、API调用情况、修改流控策略方法：查看体验demo创建的API分组详情： 查看体验demo创建的API调用情况（请求次数、调用延迟时间、调用错误次数）：修改体验demo创建的流控信息：如果想要了解更多功能，请参见《API网关 用户指南》。

一、概要 Hadoop YARN提供开放在8088和8090端口的REST API，允许用户直接通过这些API创建和提交任务（http://hadoop.apache.org/docs/r2 ... ISubmit_Application） 近期，有攻击者利用此REST API对未启用Kerbose认证的MRS集群进行攻击，攻击者可以在未授权的情况下远程执行脚本和代码，从而再进一步下载启动挖矿程序达到挖矿的目的。该漏洞也可导致ECS虚机被攻击者控制。 请涉及威胁的租户根据自身业务情况，采取防护措施。 二、威胁级别 威胁级别：【紧急】 （说明：威胁级别共四级：一般、重要、严重、紧急。） 三、影响范围 未启用Kerbose认证的MRS集群，MRS Master节点绑定弹性IP（EIP），绑定弹性IP的节点端口入方向的安全组规则开放Any或0.0.0.0。 四、排查和处置 排查方法： 1.检查MRS Master节点绑定弹性IP； 2.检查系绑定弹性IP的节点端口入方向的安全组规则开放Any或0.0.0.0； 3.检查YARN的Application列表是否存在未知任务； 4.检查操作系统是否存在/var/tmp/java的进程； 5.检查操作系统中是否存在文件/var/spool/cron/yarn_user； 6.检查crontab任务列表是否存在未知任务。 处置方案： 1.MRS Master节点解绑弹性IP或删除对端口入方向的安全组规则开放Any或0.0.0.0的安全组规则； 2.通过iptables或者安全组规则配置访问策略，限制端口入方向规则仅允许指定IP； 3.Kill掉YARN上的未知Application； 4.Kill掉所有/var/tmp/java进程，并删除/var/tmp/java文件； 5.删除/var/spool/cron/yarn_user文件； 6.删除未知的crontab任务。 五、安全建议 1.使用启用Kerbose认证的MRS集群； 2.如有实际需求使用未启用Kerbose认证的MRS集群，配置严格访问范围的安全组规则，禁止入方向允许Any或0.0.0.0的访问。

API测试体验官活动已于4月30日结束，感谢大家的参与及提出的宝贵意见，现将获奖名单公布如下：优质建议奖：1. 获奖楼层：板凳；论坛用户名：ecstatic2. 获奖楼层：第五楼；论坛用户名：allenzhang奖品：肩颈**器一个幸运满满奖：1. 获奖楼层：沙发；论坛用户名：zekelove2. 获奖楼层：地板；论坛用户名：LL3. 获奖楼层：第六楼；论坛用户名：好友4. 获奖楼层：第八楼；论坛用户名：蓝书签5. 获奖楼层：第十楼；论坛用户名：小豆奖品：笔记本支架一个恭喜以上获奖用户，请在5个自然日内扫描下方二维码添加服务人员微信，验证信息输入“API”，请将华为云用户名、帖子所在楼层、姓名、手机号、收货地址发送给微信服务人员，奖品将尽快为您寄出。所有奖品均包邮，不额外收取任何费用。14756

本帖最后由 云彩飞扬 于 2018-3-20 10:42 编辑[*]下载并解压DmsKafkaDemo示例工程代码。 [*]打开Eclipse，通过“File -> Import…”，“Select an import source”选择“Exiting Projects Into Workspace”，选择DmsKafkaDemo解压目录，导入示例工程代码。 [*]选择“Project -> Build Project”，执行编译构建。 [*]鼠标右键单击DmsKafkaDemo项目，在弹出的上下文菜单中选择“Export…”，选择“Java -> JAR file”，填写待生成的JAR文件保存位置和名称，导出JAR文件。 [*]使用新生成的JAR文件替换弹性云服务器DmsKafkaDemo/dist/libs目录下的dms.kafka.demo.jar文件，按照“运行示例工程”执行验证。

本帖最后由 云彩飞扬 于 2018-3-20 10:39 编辑[*]登录弹性云服务器。说明：用户可以直接在192网段的ECS虚拟机上运行。 [*]安装Java JDK或JRE，并配置JAVA_HOME与PATH环境变量，使用执行用户在用户家目录下修改.bash_profile，添加如下行。 export JAVA_HOME=/opt/java/jdk1.8.0_151export PATH=$JAVA_HOME/bin:$PATH执行source .bash_profile命令使修改生效。 说明：ECS虚拟机默认自带的JDK可能不符合要求，例如OpenJDK，需要配置为Oracle的JDK，可至Oracle官方下载页面下载Java Development Kit 1.8.111及以上版本。 [*]使用root用户编辑/etc/resolv.conf文件，配置DNS服务器地址。 在第一行增加如下：nameserver 100.125.1.250 [*]下载DmsKafkaDemo示例工程代码。 [*]解压DmsKafkaDemo.zip压缩包。 $ unzip DmsKafkaDemo.zip [*]进入DmsKafkaDemo/dist目录，该目录下包含预编译好的二进制文件和执行脚本。 $ cd DmsKafkaDemo/dist [*]编辑配置文件config/dms_kafka_client_jaas.conf，设置access_key、secret_key和project_id。 $ vim config/dms_kafka_client_jaas.conf设置内容如下（其中标红内容需要替换为实际值）：KafkaClient { com.huawei.middleware.kafka.sasl.client.KafkaLoginModule required access_key=VAODAIIJGPUAYTJRRLOD secret_key=ZHN49c6bpwDiQvPqKJ5CxutJxqc04Glt9xSzxYWi project_id=bd67aaead60940d688b872c31bdc653b;}; [*]编辑配置文件config/producer.properties，设置topic和bootstrap.servers。 $ vim config/producer.properties设置内容如下（其中标红内容需要替换为实际值）：topic=k-bd67aaead60940d688b872c31bdc653b-4df89da6-ede4-4072-93e0-28dc6e866299bootstrap.servers=dms-kafka.cn-north-1.myhuaweicloud.com:37000ssl.truststore.password=dms@kafkaacks=allretries=1batch.size=16384buffer.memory=33554432key.serializer=org.apache.kafka.common.serialization.StringSerializervalue.serializer=org.apache.kafka.common.serialization.StringSerializersecurity.protocol=SASL_SSLsasl.mechanism=DMS [*]编辑配置文件config/consumer.properties，设置topic、bootstrap.servers和group.id。 $ vim config/consumer.properties设置内容如下（其中标红内容需要替换为实际值）：topic=k-bd67aaead60940d688b872c31bdc653b-4df89da6-ede4-4072-93e0-28dc6e866299bootstrap.servers=dms-kafka.cn-north-1.myhuaweicloud.com:37000group.id=g-7ec0caac-01fb-4f91-a4f2-0a9dd48f8af7ssl.truststore.password=dms@kafkasecurity.protocol=SASL_SSLsasl.mechanism=DMSkey.deserializer=org.apache.kafka.common.serialization.StringDeserializervalue.deserializer=org.apache.kafka.common.serialization.StringDeserializerauto.offset.reset=earliestenable.auto.commit=false [*]运行生产消息示例。 $ bash produce.sh [*]运行消费消息示例。 $ bash consume.sh

本帖最后由 云彩飞扬 于 2018-3-20 10:22 编辑 开发环境Eclipse：Eclipse 3.6.0及以上版本，可至Eclipse官方网站下载。JDK：Java Development Kit 1.8.111及以上版本，可至Oracle官方下载页面下载。Maven：Apache Maven 3.0.3及以上版本。创建Kafka队列通过浏览器登录华为云，在分布式消息服务控制台中创建队列，队列类型选择“Kafka队列”。请记录Kafka Topic ID，后续访问需要使用。如果已创建过Kafka队列，可以跳过此步骤。创建消费组通过浏览器登录华为云，在分布式消息服务控制台中选择上文创建的Kafka队列，为该队列创建一个消费组。请记录消费组ID，后续访问需要使用。如果已为该Kafka队列创建过消费组，可以跳过此步骤。创建访问密钥通过浏览器登录华为云，选择“我的凭证”菜单，单击“管理访问密钥”标签，新增一组访问密钥，保存credentials.csv文件到本地。从credentials.csv文件中可以提取“Access Key Id”和“Secret Access Key”。如果之前已创建过访问密钥，可以跳过此步骤。获取项目ID通过浏览器登录华为云，选择“我的凭证”菜单，单击“项目列表”标签，根据所属区域记录对应的项目ID。获取区域和EndpointRegion域名说明中国华北区1dms-kafka.cn-north-1.myhuaweicloud.com:37000在华为云（ECS）上运行Demo示例，使用该endpoint访问DMS服务。中国华东区2dms-kafka.cn-east-2.myhuaweicloud.com:37000中国华南区1dms-kafka.cn-south-1.myhuaweicloud.com:37000中国华北区1dms-kafka.cn-north-1.myhuaweicloud.com:37003在本地（公网）运行Demo示例，使用该endpoint访问DMS服务。申请弹性云服务器说明：在华为云（ECS）上运行DMS Demo示例，需要先申请弹性云服务器。 通过浏览器登录华为云，在弹性云服务器控制台中申请创建一台Linux弹性云服务器，并绑定弹性IP。请记录弹性IP地址、用户名和密码，后续访问需要使用。如果已申请过华为云弹性云服务器，可以跳过此步骤。说明：弹性IP用于登录弹性云服务器，以及上传文件等。 环境信息汇总表1 环境信息汇总类型项目收集的信息（以下为示例，请根据实际情况替换）弹性云服务器弹性IP114.115.141.228用户名huaweicloud密码password分布式消息服务队列名称my-kafka-queue队列ID4df89da6-ede4-4072-93e0-28dc6e866299队列类型Kafka队列Kafka Topick-bd67aaead60940d688b872c31bdc653b-4df89da6-ede4-4072-93e0-28dc6e866299消费组名称my-consumer-group消费组IDg-7ec0caac-01fb-4f91-a4f2-0a9dd48f8af7访问密钥AK (Access Key Id)VAODAIIJGPUAYTJRRLODSK (Secret Access Key）ZHN49c6bpwDiQvPqKJ5CxutJxqc04Glt9xSzxYWi项目ID所属区域中国华北区1项目cn-north-1项目IDbd67aaead60940d688b872c31bdc653b区域和Endpoint区域名称中国华北区1Endpointdms-kafka.cn-north-1.myhuaweicloud.comDNSDNS服务器IP华北：100.125.1.250华东：100.125.17.29华南：100.125.1.250

[*]（可选）配置DNS。公网无法直接访问DMS，必须要先创建ECS，在ECS上才可以访问DMS。新创建的ECS不需要再配置DNS，如果使用已有的ECS需要配置DNS。[*]华北区的DNS IP：100.125.1.250 [*]华东区的DNS IP：100.125.17.29 [*]华南区的DNS IP：100.125.1.250 [*]参考表1的配置示例的配置项。表1 dms.client.properties参数说明 参数说明dms.server.ipDMS服务端的地址，配置为IP或者域名。华北区域名：dms-tcp.cn-north-1.myhuaweicloud.com华东区域名：dms-tcp.cn-east-2.myhuaweicloud.com华南区域名：dms-tcp.cn-south-1.myhuaweicloud.comdms.server.portDMS服务TCP端口，配置为60010。dms.client.blocked.worker.num执行阻塞callback的线程数，默认为-1，小于0则默认使用CPU核数两倍。dms.client.conn.timeout连接超时时间，单位为毫秒，默认6000dms.client.reconn.attempt.times连接重试次数，默认3次。dms.client.reconn.attempt.interval连接重试间隔，单位为毫秒,默认3000。dms.client.request.timeout请求超时时间，单位为毫秒，默认60000。dms.client.start.timeout启动超时时间，单位为毫秒，默认60000。dms.client.project.idproject id，获取方法参见获取project id。dms.client.access.keyaccess key，获取方法参见获取AK/SK。dms.client.secret.keysecret key，获取方法参见获取AK/SK。[*]开始编写代码，API接口请参考获取SDK中的dms.sdk.api.chm文档。

本章节以新建名为“tcpdemo”的Maven Project为例。操作步骤[*]打开Eclipse，建议使用4.6以上版本，新建一个Maven Project，工程名自定义，这里以tcpdemo为例。[*]单击“Finish”。 [*]导入DMS TCP SDK的jar包。 [list=a] [*]右键单击新建的工程“tcpdemo”，新建一个Folder，命名为libs。 [*]将dms.sdk-1.0.0.jar和dms.protocol-1.0.0.jar复制到libs目录下。 [*]在pom.xml文件中增加如下行，将DMS TCP SDK的jar包导入Maven仓库。 com.huawei.middleware.dms dms.protocol 1.0.0 jar system ${basedir}/libs/dms.protocol-1.0.0.jar com.huawei.middleware.dms dms.sdk 1.0.0 jar system ${basedir}/libs/dms.sdk-1.0.0.jar [*]保存“pom.xml”。 [*]如果没有自动导入第三方依赖包，请参考“DmsTcpDemo示例”将third_lib.zip中的包导入Maven仓库。

如果您还没有下载SDK，请访问http://developer.huaweicloud.com/sdk/java/dms-tcp.html下载SDK压缩包。下载dms.sdk.zip压缩包，即为DMS TCP SDK开发包，包含如下文件：[*]dms.sdk-1.0.0.jar：DMS TCP SDK包 [*]dms.protocol-1.0.0.jar： DMS TCP SDK包 [*]dms.client.properties：配置文件 [*]README.txt：发布说明文件 [*]third_lib.zip：DMS TCP SDK依赖的第三方jar包 [*]dms.sdk.api.chm：API接口参考

本帖最后由 云彩飞扬 于 2018-3-19 14:47 编辑 开发环境Eclipse：Eclipse 3.6.0及以上版本，可至Eclipse官方网站下载。JDK：Java Development Kit 1.8.111及以上版本，可至Oracle官方下载页面下载。Maven：Apache Maven 3.0.3及以上版本。获取队列ID和消费组的ID使用SDK接口访问DMS服务，需要先创建队列和消费组，步骤如下：[*]登录管理控制台。 [*]单击“服务列表”，选择“应用服务 > 分布式消息服务”，进入分布式消息服务信息页面。 [*]单击左侧菜单栏的“队列管理”。 [*]在“队列管理”页面，单击页面上方的“创建队列”。 每个用户默认最多可以创建5个队列，您可以在“删除队列”按钮上面看到您还可以创建多少个队列。如果您想创建更多队列，请联系客服申请增加配额。 [*]填写队列名称和描述信息。 表1 参数说明参数说明当前区域表示当前创建队列的区域。队列名称队列的名称，必须唯一。DMS为您自动生成了队列名称，您可以根据需要修改，队列名称只能包含a~z，A~Z，0-9，-，_，长度是[1，64]。创建队列后不能修改名称。队列类型[*]普通队列：包括分区有序和全局有序 [*]AMQP队列：使用AMQP协议的队列。Advanced Message Queuing Protocol，是统一消息服务的应用层标准的高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。 [*]Kafka队列：支持使用开源kafka客户端进行生产消息和消费消息，支持高吞吐和高可靠两种模式。队列模式队列类型为普通队列时，队列模式取值范围： [*]分区有序：的普通队列具有更高的并发性能，不保证先入先出（FIFO）的严格顺序。 [*]全局有序：的普通队列保证消息先入先出（FIFO）的严格顺序。 队列类型为Kafka队列时，队列模式取值范围： [*]高吞吐：消息副本异步落盘，具有较高的性能 [*]高可靠：消息多副本同步落盘，保证消息的可靠性。是否开启死信仅队列类型为普通队列时，才有该参数。是否开启死信消息，死信消息是指无法被正常消费的消息。当达到最大消费次数仍然消费失败后，DMS会将该条消息转存到死信队列中，有效期为72小时，用户可以根据需要对死信消息进行重新消费。消费死信消息时，只能消费该消费组产生的死信消息。全局有序的队列的死信消息依然按照先入先出（FIFO）的顺序存储在死信队列中。默认值：关闭。消息保留时长（小时）仅Kafka队列才有该参数。指定kafka队列的消息保存时间，超过该时长的消息将会被删除，删除的消息无法被消费。取值范围：1-72，必须为整数。默认值：72小时。最大消费次数仅开启死信时，才有该参数。消息进入死信队列前可重复接收次数。取值范围：1~100默认值：3描述（可选）队列描述不能包含，长度是[0，160]。图1 创建队列[*]单击“确定”。创建队列完成。 [*]单击队列名称，显示队列详情，获取队列ID，如图2所示。 图2 获取队列ID [*]单击“创建消费组”。进入“创建消费组”页面。 [*]填写消费组的名称。 DMS为您自动生成了消费组名称，您可以根据需要修改，消费组的名称只能包含a~z，A~Z，0~9，-，_，长度是[1，32]。同个队列的消费组名称不能重复。 [*]单击“确定”。创建消费组完成，获取消费组ID，如图3所示。 图3 获取消费组ID 获取project id在调用接口的时候，需要填入项目编号project_id，所以需要先在管理控制台上获取到项目编号，步骤如下：[*]注册并登录管理控制台。 [*]单击用户名，在下拉列表中单击“我的凭证”。 [*]在“我的凭证”页面的“项目列表”中查看项目ID。 图4 获取项目ID 获取AK/SK[*]登录管理控制台。 [*]单击用户名，在下拉列表中单击“我的凭证”。 [*]在“我的凭证”页，单击“管理访问密钥”页签。 [*]单击“新增访问密钥”，进入“新增访问密钥”页面。 [*]输入当前用户的登录密码。 [*]通过邮箱或者手机进行验证，输入对应的验证码。 [*]单击“确定”，下载访问密钥。 说明：为防止访问密钥泄露，建议您将其保存到安全的位置。 [*]保存文件到本地，从下载的credentials.csv文件中获取“Access Key Id”和“Secret Access Key”。 获取区域和Endpoint Region域名端口号中国华北区1dms-tcp.cn-north-1.myhuaweicloud.com60010中国华东区2dms-tcp.cn-east-2.myhuaweicloud.com60010中国华南区1dms-tcp.cn-south-1.myhuaweicloud.com60010购买弹性云服务器使用DMS TCP SDK之前，需要购买弹性云服务器ECS，否则公网无法直接访问DMS，购买方法请参考“购买弹性云服务器”。说明：弹性IP用于登录弹性云服务器，以及上传文件等。配置内网DNS。说明：新创建的ECS不需要再配置DNS，如果使用已有的旧的ECS，则需要配置DNS的IP。华北区的DNS IP：100.125.1.250华东区的DNS IP：100.125.17.29华南区的DNS IP：100.125.1.250示例如下：环境信息汇总表2 环境信息汇总类型项目收集的信息（以下为示例，请根据实际情况替换）弹性云服务器弹性IP114.115.141.228用户名huaweicloud密码password分布式消息服务队列名称my-tcp-queue队列ID5964181e-b67e-4d35-9281-a58c352abda6队列类型普通队列消费组名称my-tcp-group消费组IDg-c861aa48-a082-48ff-bc9d-ff36fe7aed38访问密钥AK (Access Key Id)VAODAIIJGPUAYTJRRLODSK (Secret Access Key）ZHN49c6bpwDiQvPqKJ5CxutJxqc04Glt9xSzxYWi项目ID所属区域中国华北区1项目cn-north-1项目IDbd67aaead60940d688b872c31bdc663b区域和Endpoint区域名称中国华北区1Endpointdms-tcp.cn-north-1.myhuaweicloud.com端口号60010DNSDNS服务器IP华北：100.125.1.250华东：100.125.17.29华南：100.125.1.250

本帖最后由 云彩飞扬 于 2018-3-16 11:55 编辑 DMS TCP Demo示例工程中包含DmsProducerDemo和DmsConsumerDemo两个示例，DmsProducerDemo用于展示生产消息流程，DmsConsumerDemo用于展示消费和确认消息流程。生产消息[*]创建并启动DmsProducer。 DmsProducer producer = new DmsProducerImpl();producer.start(); [*]构建要发送的消息内容。 List messages = new ArrayList();final int messageNum = 10;for (int i = 0; i messageNum; i++){ DmsMessage record = new DmsMessage(); record.setBody(("Hello DMS syn produce: " + i).getBytes()); messages.add(record);} [*]发送消息。 try{ List result = producer.produce(queueId, messages); result.forEach(r -> { System.out.println(r.getState()); });}catch (Throwable t){ t.printStackTrace();} [*]停止生产。 producer.stop();消费消息[*]创建并启动消费实例。 DmsConsumer consumer = new DmsConsumerImpl();consumer.start(); [*]消费消息。 List records = consumer.consume(queueId, groupId); [*]构建确认请求。 DmsCommitRequest commitRequest = new DmsCommitRequest();List messages = new ArrayList();for (DmsConsumeResult record : records){ System.out.println(record.getHandler()); DmsCommitItem commitItem = new DmsCommitItem(); //确认时需要回填对应消息handler commitItem.setHandler(record.getHandler()); //设置消息处理状态: true or false commitItem.setStatus(true); messages.add(commitItem);}//一次可确认多条消息commitRequest.setMessage(messages); [*]确认消息。 DmsCommitResult commitResult = consumer.commit(queueId, groupId, commitRequest); [*]停止消费。 consumer.stop();

本帖最后由 云彩飞扬 于 2018-3-16 11:35 编辑1.下载并解压。DMS TCP Demo示例工程代码2.打开Eclipse，通过“File -> Import…”菜单导入已存在的Maven工程，选择DmsTcpDemoClient解压目录，导入示例工程代码。3.鼠标右键点击“dms.tcp.demo”项目，在弹出的上下文菜单中选择“Run As -> Maven build…”，执行目标输入“clean package”，执行编译构建。4.构建输出位于DmsTcpDemoClient工程的target目录下，缺省文件名为dms.tcp.demo-1.0.0-SNAPSHOT.jar。5.使用dms.tcp.demo-1.0.0-SNAPSHOT.jar替换弹性云服务器DmsTcpDemoClient/dist/libs目录下的dms.tcp.demo-1.0.0.jar文件，按照“运行示例工程”执行验证。