Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
Apache RocketMQ
Rocketmq
提交
e57f9ac4
R
Rocketmq
项目概览
Apache RocketMQ
/
Rocketmq
上一次同步 接近 3 年
通知
259
Star
16138
Fork
69
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
R
Rocketmq
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
e57f9ac4
编写于
5月 27, 2017
作者:
D
dongeforever
浏览文件
操作
浏览文件
下载
差异文件
Merge remote-tracking branch 'wip/ROCKETMQ-206' into develop
上级
04c8925d
aced0de7
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
22 addition
and
5 deletion
+22
-5
client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
.../rocketmq/client/consumer/store/LocalFileOffsetStore.java
+12
-2
example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java
.../java/org/apache/rocketmq/example/benchmark/Consumer.java
+2
-1
example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java
...ain/java/org/apache/rocketmq/example/filter/Consumer.java
+2
-1
namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java
...org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java
+6
-1
未找到文件。
client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
浏览文件 @
e57f9ac4
...
@@ -180,7 +180,12 @@ public class LocalFileOffsetStore implements OffsetStore {
...
@@ -180,7 +180,12 @@ public class LocalFileOffsetStore implements OffsetStore {
}
}
private
OffsetSerializeWrapper
readLocalOffset
()
throws
MQClientException
{
private
OffsetSerializeWrapper
readLocalOffset
()
throws
MQClientException
{
String
content
=
MixAll
.
file2String
(
this
.
storePath
);
String
content
=
null
;
try
{
content
=
MixAll
.
file2String
(
this
.
storePath
);
}
catch
(
IOException
e
)
{
log
.
warn
(
"Load local offset store file exception"
,
e
);
}
if
(
null
==
content
||
content
.
length
()
==
0
)
{
if
(
null
==
content
||
content
.
length
()
==
0
)
{
return
this
.
readLocalOffsetBak
();
return
this
.
readLocalOffsetBak
();
}
else
{
}
else
{
...
@@ -198,7 +203,12 @@ public class LocalFileOffsetStore implements OffsetStore {
...
@@ -198,7 +203,12 @@ public class LocalFileOffsetStore implements OffsetStore {
}
}
private
OffsetSerializeWrapper
readLocalOffsetBak
()
throws
MQClientException
{
private
OffsetSerializeWrapper
readLocalOffsetBak
()
throws
MQClientException
{
String
content
=
MixAll
.
file2String
(
this
.
storePath
+
".bak"
);
String
content
=
null
;
try
{
content
=
MixAll
.
file2String
(
this
.
storePath
+
".bak"
);
}
catch
(
IOException
e
)
{
log
.
warn
(
"Load local offset store bak file exception"
,
e
);
}
if
(
content
!=
null
&&
content
.
length
()
>
0
)
{
if
(
content
!=
null
&&
content
.
length
()
>
0
)
{
OffsetSerializeWrapper
offsetSerializeWrapper
=
null
;
OffsetSerializeWrapper
offsetSerializeWrapper
=
null
;
try
{
try
{
...
...
example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java
浏览文件 @
e57f9ac4
...
@@ -17,6 +17,7 @@
...
@@ -17,6 +17,7 @@
package
org.apache.rocketmq.example.benchmark
;
package
org.apache.rocketmq.example.benchmark
;
import
java.io.IOException
;
import
java.util.LinkedList
;
import
java.util.LinkedList
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Timer
;
import
java.util.Timer
;
...
@@ -39,7 +40,7 @@ import org.apache.rocketmq.srvutil.ServerUtil;
...
@@ -39,7 +40,7 @@ import org.apache.rocketmq.srvutil.ServerUtil;
public
class
Consumer
{
public
class
Consumer
{
public
static
void
main
(
String
[]
args
)
throws
MQClientException
{
public
static
void
main
(
String
[]
args
)
throws
MQClientException
,
IOException
{
Options
options
=
ServerUtil
.
buildCommandlineOptions
(
new
Options
());
Options
options
=
ServerUtil
.
buildCommandlineOptions
(
new
Options
());
CommandLine
commandLine
=
ServerUtil
.
parseCmdLine
(
"benchmarkConsumer"
,
args
,
buildCommandlineOptions
(
options
),
new
PosixParser
());
CommandLine
commandLine
=
ServerUtil
.
parseCmdLine
(
"benchmarkConsumer"
,
args
,
buildCommandlineOptions
(
options
),
new
PosixParser
());
if
(
null
==
commandLine
)
{
if
(
null
==
commandLine
)
{
...
...
example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java
浏览文件 @
e57f9ac4
...
@@ -17,6 +17,7 @@
...
@@ -17,6 +17,7 @@
package
org.apache.rocketmq.example.filter
;
package
org.apache.rocketmq.example.filter
;
import
java.io.File
;
import
java.io.File
;
import
java.io.IOException
;
import
java.util.List
;
import
java.util.List
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
...
@@ -28,7 +29,7 @@ import org.apache.rocketmq.common.message.MessageExt;
...
@@ -28,7 +29,7 @@ import org.apache.rocketmq.common.message.MessageExt;
public
class
Consumer
{
public
class
Consumer
{
public
static
void
main
(
String
[]
args
)
throws
InterruptedException
,
MQClientException
{
public
static
void
main
(
String
[]
args
)
throws
InterruptedException
,
MQClientException
,
IOException
{
DefaultMQPushConsumer
consumer
=
new
DefaultMQPushConsumer
(
"ConsumerGroupNamecc4"
);
DefaultMQPushConsumer
consumer
=
new
DefaultMQPushConsumer
(
"ConsumerGroupNamecc4"
);
ClassLoader
classLoader
=
Thread
.
currentThread
().
getContextClassLoader
();
ClassLoader
classLoader
=
Thread
.
currentThread
().
getContextClassLoader
();
...
...
namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java
浏览文件 @
e57f9ac4
...
@@ -43,7 +43,12 @@ public class KVConfigManager {
...
@@ -43,7 +43,12 @@ public class KVConfigManager {
}
}
public
void
load
()
{
public
void
load
()
{
String
content
=
MixAll
.
file2String
(
this
.
namesrvController
.
getNamesrvConfig
().
getKvConfigPath
());
String
content
=
null
;
try
{
content
=
MixAll
.
file2String
(
this
.
namesrvController
.
getNamesrvConfig
().
getKvConfigPath
());
}
catch
(
IOException
e
)
{
log
.
warn
(
"Load KV config table exception"
,
e
);
}
if
(
content
!=
null
)
{
if
(
content
!=
null
)
{
KVConfigSerializeWrapper
kvConfigSerializeWrapper
=
KVConfigSerializeWrapper
kvConfigSerializeWrapper
=
KVConfigSerializeWrapper
.
fromJson
(
content
,
KVConfigSerializeWrapper
.
class
);
KVConfigSerializeWrapper
.
fromJson
(
content
,
KVConfigSerializeWrapper
.
class
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录