Android 创建RocketMQ消费者Client,ManagementFactory异常 20C

使用RocketMQ创建Android 消费者客户端,consumer.start()的时候出现下面异常

java.lang.NoClassDefFoundError: Failed resolution of: Ljava/lang/management/ManagementFactory;

(直接在PC端使用创建Java的消费者客户端可以使用)

2

1个回答

0
huang1165441461
myhuanghai 您好,如果是安卓一般都是建议通过mqtt的方式接入哈,LMQ底层也是使用的RocketMQ,目前RocketMQ的TCP JAVA SDK对于android设备没有集成测试,也不保证一定可以正常运行哈,可能会出现很多未知的问题,另外,您这个报错看起来是java.lang.management.ManagementFactory这个类没有找到,您看下是否是未引用,或者存在类冲突呢?
6 个月之前 回复
shengyanlove
shengyanlove 回复alex_wuze: 没有解决
大约一年之前 回复
yindalei00
yindalei00 回复shengyanlove: 可以手动 修改 出错的 代码 github 有源码的
一年多之前 回复
alex_wuze
alex_wuze 回复shengyanlove: 你好, 我想问下, 后来解决了吗
一年多之前 回复
shengyanlove
shengyanlove 你好,我仔细看了链接中博客前后的几篇文章,发现没有提及到提问中的问题,如果您对RocketMQ很熟悉的话
一年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
RocketMQ 学习之五 —— 消费者
目录 1、DefaultMQPushConsumer 2、DefaultMQPullConsumer 消费者分为两种类型。一种是 DefaultMQPushConsumer,由系统控制读取操作,收到消息后自动调用传入的处理方法来处理;另一个是 DefaultMQPullConsumer,读取操作中的大部分功能由使用者自主控制。 1、DefaultMQPushConsumer 上一篇...
rocketmq生产者和消费者
1、生产者: package com.ebways.mq.test.mq; import com.alibaba.rocketmq.client.exception.MQClientException; import com.alibaba.rocketmq.client.producer.DefaultMQProducer; import com.alibaba.rocketmq...
RocketMQ消费者示例程序
  转载请注明出处:http://www.cnblogs.com/xiaodf/   本博客实现了一个简单的RocketMQ消费者的示例,MQ里存储的是经过Avro序列化的消息数据,程序读取数据并反序列化后,将消息从控制台打印出来。   程序通过stdin.xml配置文件获取主要参数值,stdin.xml文件内容如下: <?xml version="1.0" encoding...
RocketMQ 生产者与消费者的封装
一、抽象消费类封装: public abstract class Consumer { protected final Logger logger = LoggerFactory.getLogger(getClass()); protected DefaultMQPushConsumer defaultMQPushConsumer; @Value("${rocket...
RocketMQ 消费者 多线程 源码
/** * Wrapped push consumer.in fact,it works as remarkable as the pull consumer * * @author shijia.wxr<vintage.wang@gmail.com> * @since 2013-7-24 */ public class DefaultMQPushConsum...
rocketMQ生产者和消费者
简单写一个MQ的生产者和消费者。生产者生产4个topic。消费者订阅消费,多线程启动4个线程,每个线程新建一个消费者来消费一个topic的数据。rocketMQ本身就是多线程的,设置每个消费者的线程数为5个。例子如下: 生产者代码如下: import javax.annotation.PreDestroy; import com.alibaba.rocketmq.cli
RocketMq(4)消费者demo
@Component public class PayConsumer { private DefaultMQPushConsumer consumer; private String consumerGroup="pay_consumer_group"; public PayConsumer() throws MQClientException { ...
RocketMQ消费者实践
  最近工作中用到了RocketMQ,现记录下,如何正确实现消费~ 消费者需要注意的问题 防止重复消费 如何快速消费 消费失败如何处理 Consumer具体实现 防止重复消费     重复消费会造成数据不一致等问题。所以,消费者要做到消费幂等。     1)每次消费,记录messageId;如果再次消费该message,查询messageId是否已存在,已存...
解析RocketMQ的client客户端
1.解析RocketMQ的client客户端 参考:http://www.cnblogs.com/atliwen/p/5216849.html 1.2个核心接口,3个默认实现 interface MQProducer --- DefaultMQProducer interface MQConsumer --- DefaultMQ
RocketMq案例,生产者,消费者,消息订阅
1、RocketMq集群配置参考:http://blog.csdn.net/tototuzuoquan/article/details/78314572使用的rocketmq的ip等是上面博文提及的ip等内容2、创建RocketMq工程工程目录结构如下: 3、编写pom.xml文件<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http
rocketmq 消费者负载均衡相关源码
2019独角兽企业重金招聘Python工程师标准&gt;&gt;&gt; ...
rocketmq 消费者无法消费问题排查
2019独角兽企业重金招聘Python工程师标准&gt;&gt;&gt; ...
RocketMq实现原理--PUSH消费者负载均衡
RocketMq实现原理--PUSH消费者负载均衡双负载均衡消费者客户端hash算法broker上消费者集合容灾措施缺陷 全新的界面设计 ,将会带来全新的写作体验; 双负载均衡 rocketmq是客户端负载均衡实现。 rocketmq消息是使用broker(服务器)与queueid(消息分组)两个单位实现消费逻辑。rocketmq集群是由若干个broker,每个topic在broker上存在若...
《RocketMq》六、Client-Consumer消费者详解
Consumer-集群Push模式-简介:0、背景介绍         Consumer主要用于向Broker请求Producer产生的消息,对其进行消费;对于RocketMQ,我们一定很好奇,如何实现分布式的Consumer消费,如何保证Consumer的顺序性,不重复性呢? 存在的问题:1. 如果在集群模式中新增/减少 组(group) 消费者,可能会导致重复消费;原因是:假设新增消费者前,C...
RocketMQ实战(三)之生产者、消费者
一:Maven配置 加入rocketmq-client依赖 二:生产者、消费者 1:生产者 2:消费者 DefaultMQPushConsumer和DefaultMQProducer需要设置三个参数: 一是这个Consumer的GroupName,二是NameServer的地址和端口号,三是Topic的名称。 无论生产者、消费者都必须给出GroupName,而且具有唯一性...
RocketMQ 生产者与消费者的封装与调用
一、抽象消费类封装: package cn.shaker.media.basic.rocketMq.consumer; import com.google.common.collect.Maps; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; ...
RocketMQ之Pull消费者客户端启动
Pull消费者客户端(主动拉取消息的消费者)即构造了DefaultMQPullConsumer对象,DefaultMQPullConsumer继承了ClientConfig类。我们先看其构造方法 public DefaultMQPullConsumer(final String consumerGroup, RPCHook rpcHook) { this.consumerGr...
详解RocketMQ不同类型的消费者
根据使用者对读取操作的控制情况,分为两种类型。一个是DefaultMQPushConsumer,由系统控制读取操作,收到消息后自动调用传入的处理方法来处理;另一个是DefaultMQPullConsumer,读取操作中的大部分功能由使用者自主控制。1.DefaultMQPushConsumer的使用使用DefaultMQPushConsumer主要是设置...
rocketmq消费者消息重试机制
转载:https://www.jianshu.com/p/5843cdcd02aa
Rocketmq生产者和push消费者demo
1.Rocketmq生产者[java] view plain copypublic class Producer {      public static void main(String[] args) throws MQClientException{          /**          * 一个应用创建一个Producer,由应用来维护此对象,可以设置为全局对象或者单例&amp;lt;br&amp;...
Spring延时初始化RocketMQ消费者
Spring加载RocketMq消费者实例后会立即开始消费,不论Spring容器是否初始化完毕。这就意味着如果Spring容器由于某种原因导致容器初始化失败,但应用程序没有因为容器初始化失败而关闭,那么会出现不可预期的后果,例如Spring容器初始化失败,导致定时任务不能正常执行,而MQ消费需要定时任务从数据库中拉取的配置信息,这样会导致MQ消费失败。因此,可以在Spring容器启动完成后再初始化...
ROCKETMQ源码分析笔记2:client
CLIENT 之前讲过tools里面有大量调用client的东西。为了从源码层面了解rocket,决定啃下client这块骨头。 pom 先看pom,看看CLIENT依赖谁。看完后原来是依赖common的。common又依赖remoting的 翻开remoting看了看,都是一些接口定义。明白了,remoting应该是通信协议,公共接口。看来如果讲框架的时候,应该从remoting开...
RocketMQ异常(一)
RocketMQ异常(一) org.apache.rocketmq.client.exception.MQClientException: No route info for this topic, TopicTestjjj 根据官方文档配置的MQ,并且复制的示例代码,但是运行就报错了。 参考了很多博客得出以下三种结论 Broker没有开启自动创建主题 Broker 没有正确连接到 Nam...
RocketMQ实战异常汇总
今天的博客主题 MQ消息中间件 --》RocketMQ --》RocketMQ实战异常汇总 目录 No route info of this topic, xxxTopic CODE: 1 DESC: The broker does not support consumer to filter message by SQL92 MQ控制台查询%DLQ%Topic消息异常 b...
RocketMQ异常问题解决
RocketMQ消费端,接收不到消息,但是其他消费端能接收到。且在RocketMQ Console控制台打印异常信息 com.alibaba.rocketmq.client.exception.MQClientException: Not found the consumer group consume stats, because return offset table is empty, m
RocketMQ nameserver、broker、生产者和消费者之间的关系
一 nameserver 相对来说,nameserver的稳定性非常高。原因有二: 1 nameserver互相独立,彼此没有通信关系,单台nameserver挂掉,不影响其他nameserver,即使全部挂掉,也不影响业务系统使用,这点类似于dubbo的zookeeper。 2 nameserver不会有频繁的读写,所以性能开销非常小,稳定性很高。二 broker 1 与nameserve
四、RocketMq简单的消费者和生产者(示例代码)
一、生产者   使用RocketMQ以三种方式发送消息:可靠的同步,可靠的异步和单向传输。   (1)同步发送消息(可靠的同步传输,适用于重要的短信通知等) public class SyncProducer { public static void main(String[] args) throws Exception { //Instantiate wi...
RocketMQ消费者,设置setConsumeFromWhere无效的问题
今天用了阿里开源的RocketMQ,第一次消费,使用新的consumserGroup消费,设置 consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET); 但是结果还是从offset为0 开始消费。网上也有很多人遇到了这个问题,但是并没有答案。所以我查看了一下源码,在客户端代码(rocketmq-clie
sqoop2启动client异常
java环境: java version "10.0.1" ,启动sqoop-shell端或者是sqoop-client端异常,异常如下: [root@hadoop1 home]# sqoop2-shell Setting conf dir: /home/sqoop-1.99.7/bin/../confSqoop home directory: /home/sqoop-1.99.7WARNI...
rocketmq 消费者负载均衡-分布式下的messageQueue的分配和锁定
思考一个问题,分布式环境,网络不稳定. a台broker上有messageQueue,b台queue. a,b都会随着网络不稳定而变动,你如何分配,并且保证messageQueue都被分配出去. rocketMq实现: 客户端实现负载均衡,每个人的算法都一样. (源自于大家都从zk上获取, topic总messageQueue和consumers ) 然后平均分配. 有可能因为某些原因,得
RocketMQ - 8 消费者 push和pull模式,配置参数
PushConsumer配置 consumerGroup DEFAULT_CONSUMER Consumer 组名,多个 Consumer如果属于一个应用,订阅同样的消息,且消费逻辑一致,则应该将它们归为同一组 messageModel CLUSTERING 消息模型,支持以下两种 1、集群消费 2、广播消费 consumeFromWhere CONSUME_FROM_LAST_OFF...
RocketMQ中的生产者和消费者的流转过程
一:RocketMQ中Remoting RocketMQ消息队列的整体部署架构如下图所示: RocketMQ集群的一部分通信: (1)Broker启动后需要完成一次将自己注册至NameServer的操作;随后每隔30s时间定期向NameServer上报Topic路由信息; (2)消息生产者Producer作为客户端发送消息时候,需要根据Msg的Topic从本地缓存的TopicPublis...
rocketmq学习笔记 二 官方实例<消费者操作>
来学习最后一个例子,消费者的一些操作api 0.拉消息 1.推消息 2.定时拉消息
RocketMQ(7)消费者核心配置和核心知识
1、消息队列RocketMQ4.X消费者核心配置 consumeFromWhere配置(某些情况失效:参考https://blog.csdn.net/a417930422/article/details/83585397) 创建新的topic和group组的时候有可能存在消费之前历史消息(存在内存中的) CONSUME_FROM_FIRST_OFFSET: 初次从消息队列头部开始消费,即历...
RocketMQ生产者和消费者关键概念总结
生产者: 每隔30S向Master发送心跳,心跳信息内只包含producerGroup名称,同时上传FilterClassSource 每隔30S从Namesrv获取最新的TopicRouteData,提取信息封装成TopicPuhlishInfo 根据最新的TopicRouteData,定时更新持有的Broker列表,清空下线的Broker 当未开启延迟容错机制(默认)情形下,轮流按顺序向所...
rocketmq消费者不能连接到nameserver的问题
国庆放假之前,主管将数据库更新并且重启所有的服务器。然后国庆之后发现国庆期间消费者并没有处理消息。 消息的生产是正常的,国庆期间产生了好几万条消息,但是查看消费订阅组却发现并没有消费者存在。 我多次重启了消费者服务器,但是发现并没有报错也没有打印消费日志,找了各种代码的原因都没有发现问题。 因为一直不报错,这是最让程序员头疼的情况,所以我故意写了错误的nameserver地址, 原来的配置...
RocketMQ原理学习--消费者消费消息
        在之前的一篇博客《RocketMQ原理学习--消息类型》中我们有介绍过RocketMQ的消息类型,这篇博客我们简单介绍一下RocketMQ消费者是如何消费消息的。 一、Pull or Push         简单来说RocketMQ给我们提供了两种消息消费方式,Pull模式和Push模式,简单理解我们可能会认为Pull模式是消费者主动去拉取消息,Push模式是RocketMQ...
RocketMQ(一) 生产者和消费者完整示例
生产者和消费者,发消息和接收消息,完整示例    RocketMQ是阿里巴巴在2012年开源的分布式消息中间件,目前已经捐赠给Apache基金会,已经于2016年11月成为 Apache 孵化项目,相信RocketMQ的未来会发挥着越来越大的作用,将有更多的开发者因此受益。         本文仅对RocketMQ的简单实用做入门性介绍,不对RocketMQ的底层原理进行深入介绍,后续文章将...
Rocketmq 消费者组 顺序、平均消费实现原理
1.测试环境: broker :1master,1slave producer: 1 consumer:3 2.架构图: 3.实现功能 Producer 投递到Broker 的消息,要实现顺序消费,而且Consumer 消费组C1,C2,C3要实现负载均衡消费 4.技术原理 Broker 的里面的Topic(消息逻辑存储单元)包含多个Queue(假...
rocketmq源码分析(1)client模块--生产者的启动
过程:从定义DefaultProducer到DefaultProducer.start()。 一.测试代码 测试代码: public class Producer { public static void main(String[] args) throws MQClientException, InterruptedException { DefaultMQProducer