apache / rocketmq
Duplication

Places in code with 6 or more lines that are exactly the same.

Intro
Learn more...
Duplication Overall
system11% (14,389 lines)
dependency graphs: 2D graph | 3D graph | 3D graph (with duplicates)...
Duplication per Extension
java11% (13,975 lines)
xml30% (414 lines)
Duplication per Component (primary)
client16% (2,820 lines)
broker10% (2,302 lines)
tools21% (2,160 lines)
remoting16% (1,967 lines)
store7% (1,586 lines)
proxy9% (1,029 lines)
common8% (733 lines)
example20% (552 lines)
auth12% (313 lines)
controller7% (241 lines)
namesrv10% (195 lines)
filter5% (150 lines)
container12% (125 lines)
tieredstore2% (116 lines)
distribution34% (34 lines)
style14% (34 lines)
openmessaging2% (26 lines)
srvutil5% (6 lines)
bazel0% (0 lines)
dev0% (0 lines)

Duplication Between Components (50+ lines)

G broker broker client client broker--client 399 proxy proxy broker--proxy 382 remoting remoting broker--remoting 306 store store broker--store 252 common common broker--common 116 container container broker--container 227 controller controller broker--controller 135 namesrv namesrv broker--namesrv 97 tools tools broker--tools 66 client--proxy 132 client--remoting 264 client--common 90 proxy--remoting 204 remoting--store 82 remoting--tools 116 tieredstore tieredstore remoting--tieredstore 60 common--proxy 211 common--remoting 239 common--store 151 controller--namesrv 176 namesrv--proxy 67

Download: SVG DOT (open online Graphviz editor)

Open 2D force graph... Open 3D force graph...

Show more details on duplication between components...
Longest Duplicates
The list of 50 longest duplicates.
See data for all 2,788 duplicates...
Size#FoldersFilesLinesCode
56 x 2 broker/src/main/java/org...etmq/broker/transaction
store/src/main/java/org/...he/rocketmq/store/timer
171:255 (40%)
225:309 (32%)
view
53 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
115:187 (14%)
107:179 (22%)
view
44 x 2 common/src/main/java/org/apache/rocketmq/common
proxy/src/main/java/org/...e/rocketmq/proxy/config
232:317 (28%)
1212:1297 (5%)
view
42 x 2 common/src/main/java/org...e/rocketmq/common/stats
common/src/main/java/org...e/rocketmq/common/stats
93:150 (28%)
48:105 (26%)
view
31 x 2 broker/src/main/java/org...cketmq/broker/processor
broker/src/main/java/org...cketmq/broker/processor
89:130 (24%)
66:106 (54%)
view
31 x 2 tools/src/main/java/org/.../tools/command/consumer
tools/src/main/java/org/.../tools/command/consumer
109:151 (35%)
93:135 (42%)
view
29 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
137:173 (9%)
121:157 (9%)
view
29 x 2 tools/src/main/java/org/...cketmq/tools/command/ha
tools/src/main/java/org/...cketmq/tools/command/ha
57:99 (40%)
54:96 (35%)
view
29 x 2 common/src/main/java/org/apache/rocketmq/common
common/src/main/java/org...etmq/common/compression
364:400 (6%)
60:96 (54%)
view
29 x 2 tools/src/main/java/org/...etmq/tools/command/auth
tools/src/main/java/org/...etmq/tools/command/auth
78:120 (38%)
78:120 (38%)
view
28 x 2 remoting/src/main/java/o.../remoting/protocol/body
remoting/src/main/java/o.../remoting/protocol/body
27:71 (96%)
27:71 (96%)
view
28 x 2 client/src/main/java/org...q/client/consumer/store
client/src/main/java/org...q/client/consumer/store
77:116 (16%)
58:97 (19%)
view
28 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
347:387 (7%)
262:302 (11%)
view
28 x 2 filter/src/main/java/org.../rocketmq/filter/parser
filter/src/main/java/org.../rocketmq/filter/parser
161:188 (34%)
69:96 (77%)
view
27 x 2 remoting/src/main/java/o...protocol/header/namesrv
remoting/src/main/java/o...protocol/header/namesrv
31:75 (93%)
34:77 (93%)
view
24 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
58:97 (53%)
71:113 (46%)
view
24 x 2 client/src/main/java/org...he/rocketmq/client/hook
client/src/main/java/org...he/rocketmq/client/hook
44:89 (42%)
66:111 (36%)
view
23 x 2 broker/src/main/java/org...cketmq/broker/pagecache
broker/src/main/java/org...cketmq/broker/pagecache
73:111 (42%)
73:111 (42%)
view
23 x 2 controller/src/main/java...mq/controller/processor
namesrv/src/main/java/or...ketmq/namesrv/processor
269:297 (11%)
616:644 (5%)
view
22 x 2 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...cketmq/tools/command/ha
64:95 (33%)
66:97 (27%)
view
22 x 2 auth/src/main/java/org/a...h/authorization/manager
auth/src/main/java/org/a...h/authorization/manager
65:96 (13%)
98:129 (13%)
view
22 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
192:219 (7%)
181:208 (7%)
view
21 x 2 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...cketmq/tools/command/ha
64:94 (32%)
69:99 (29%)
view
21 x 2 broker/src/main/java/org...cketmq/broker/processor
proxy/src/main/java/org/...proxy/remoting/activity
1703:1730 (<1%)
100:127 (21%)
view
21 x 2 store/src/main/java/org/apache/rocketmq/store
store/src/main/java/org/...he/rocketmq/store/queue
885:914 (2%)
315:344 (2%)
view
21 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
34:54 (23%)
38:58 (16%)
view
20 x 2 broker/src/main/java/org...cketmq/broker/pagecache
broker/src/main/java/org...cketmq/broker/pagecache
76:111 (37%)
67:101 (42%)
view
20 x 2 common/src/main/java/org/apache/rocketmq/common
common/src/main/java/org/apache/rocketmq/common
1720:1757 (1%)
248:285 (13%)
view
20 x 2 client/src/main/java/org...e/rocketmq/client/trace
client/src/main/java/org...e/rocketmq/client/trace
78:124 (25%)
77:114 (21%)
view
20 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
30:65 (90%)
25:60 (95%)
view
20 x 2 common/src/main/java/org/apache/rocketmq/common
proxy/src/main/java/org/...e/rocketmq/proxy/config
1720:1757 (1%)
1228:1265 (2%)
view
20 x 2 broker/src/main/java/org...cketmq/broker/pagecache
broker/src/main/java/org...cketmq/broker/pagecache
67:101 (42%)
76:111 (37%)
view
20 x 2 store/src/main/java/org/.../rocketmq/store/dledger
store/src/main/java/org/.../rocketmq/store/dledger
626:647 (2%)
770:791 (2%)
view
20 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
52:88 (33%)
83:119 (20%)
view
20 x 2 controller/src/main/java...ocketmq/controller/impl
controller/src/main/java...ocketmq/controller/impl
191:211 (5%)
193:213 (10%)
view
19 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
34:61 (90%)
35:62 (70%)
view
19 x 2 auth/src/main/java/org/a.../authentication/context
auth/src/main/java/org/a...h/authorization/context
47:74 (54%)
31:58 (54%)
view
19 x 2 store/src/main/java/org/apache/rocketmq/store
store/src/main/java/org/...he/rocketmq/store/queue
1134:1164 (2%)
1106:1136 (2%)
view
19 x 2 client/src/main/java/org...he/rocketmq/client/impl
proxy/src/main/java/org/...q/proxy/service/message
865:885 (<1%)
384:403 (5%)
view
19 x 2 broker/src/main/java/org...cketmq/broker/config/v1
broker/src/main/java/org...tmq/broker/subscription
26:52 (90%)
26:52 (90%)
view
19 x 2 common/src/main/java/org...rocketmq/common/message
common/src/main/java/org...rocketmq/common/message
235:273 (3%)
350:389 (3%)
view
19 x 2 client/src/main/java/org...mq/client/impl/producer
client/src/main/java/org...mq/client/impl/producer
686:709 (1%)
1334:1357 (1%)
view
19 x 2 tieredstore/src/main/jav...tmq/tieredstore/metrics
tieredstore/src/main/jav...tmq/tieredstore/metrics
178:200 (9%)
211:233 (9%)
view
19 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
103:139 (21%)
108:144 (15%)
view
18 x 2 store/src/main/java/org/apache/rocketmq/store
store/src/main/java/org/apache/rocketmq/store
138:170 (7%)
234:266 (7%)
view
18 x 2 example/src/main/java/or...ketmq/example/benchmark
example/src/main/java/or...ketmq/example/benchmark
238:261 (6%)
355:378 (6%)
view
18 x 2 broker/src/main/java/org...che/rocketmq/broker/out
client/src/main/java/org...he/rocketmq/client/impl
1430:1448 (1%)
1022:1040 (<1%)
view
18 x 2 common/src/main/java/org/apache/rocketmq/common
common/src/main/java/org...etmq/common/compression
408:429 (3%)
34:55 (33%)
view
18 x 2 remoting/src/main/java/o...emoting/protocol/header
remoting/src/main/java/o...emoting/protocol/header
46:75 (43%)
46:75 (42%)
view
18 x 2 tools/src/main/java/org/...tmq/tools/command/topic
tools/src/main/java/org/...tmq/tools/command/topic
73:99 (16%)
78:103 (16%)
view
Duplicated Units
The list of top 43 duplicated units.
See data for all 43 unit duplicates...
Size#FoldersFilesLinesCode
41 x 2 broker/src/main/java/org...etmq/broker/transaction
store/src/main/java/org/...he/rocketmq/store/timer
181:226 
235:280 
view
23 x 2 tools/src/main/java/org/...cketmq/tools/command/ha
tools/src/main/java/org/...cketmq/tools/command/ha
68:96 
65:93 
view
18 x 2 auth/src/main/java/org/a...h/authorization/factory
auth/src/main/java/org/a.../authentication/factory
136:155 
133:152 
view
16 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
275:292 
360:377 
view
14 x 2 controller/src/main/java...che/rocketmq/controller
namesrv/src/main/java/org/apache/rocketmq/namesrv
128:148 
160:180 
view
13 x 2 tools/src/main/java/org/...cketmq/tools/command/ha
tools/src/main/java/org/...mq/tools/command/broker
47:65 
68:86 
view
13 x 2 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...tmq/tools/command/topic
46:64 
51:69 
view
13 x 2 client/src/main/java/org...q/client/consumer/store
client/src/main/java/org...q/client/consumer/store
78:93 
59:74 
view
11 x 2 tools/src/main/java/org/...etmq/tools/command/auth
tools/src/main/java/org/...etmq/tools/command/auth
50:67 
49:66 
view
11 x 2 auth/src/main/java/org/a...h/authorization/context
auth/src/main/java/org/a.../authentication/context
32:44 
48:60 
view
10 x 3 tools/src/main/java/org/...cketmq/tools/command/ha
tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
48:62 
44:58 
45:59 
view
10 x 2 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...q/tools/command/message
56:70 
47:60 
view
10 x 2 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
51:65 
43:57 
view
10 x 3 tools/src/main/java/org/...mq/tools/command/offset
tools/src/main/java/org/...etmq/tools/command/auth
tools/src/main/java/org/...etmq/tools/command/auth
43:57 
46:61 
46:61 
view
10 x 2 tools/src/main/java/org/...ools/command/controller
tools/src/main/java/org/...q/tools/command/namesrv
44:58 
39:52 
view
10 x 2 remoting/src/main/java/o...rocketmq/remoting/netty
proxy/src/main/java/org/...rocketmq/proxy/remoting
212:225 
100:113 
view
10 x 3 example/src/main/java/or...mq/example/tracemessage
example/src/main/java/or...mq/example/tracemessage
example/src/main/java/or...mq/example/tracemessage
65:77 
58:70 
84:96 
view
9 x 2 broker/src/main/java/org/apache/rocketmq/broker
store/src/main/java/org/apache/rocketmq/store
2261:2271 
2162:2172 
view
9 x 2 client/src/main/java/org...q/client/consumer/store
client/src/main/java/org...q/client/consumer/store
217:228 
183:193 
view
8 x 2 tools/src/main/java/org/...mq/tools/command/export
tools/src/main/java/org/...mq/tools/command/export
50:60 
63:73 
view
7 x 7 tools/src/main/java/org/...ools/command/connection
tools/src/main/java/org/...tmq/tools/command/topic
tools/src/main/java/org/...tmq/tools/command/topic
tools/src/main/java/org/...tools/command/container
tools/src/main/java/org/...tools/command/container
tools/src/main/java/org/...q/tools/command/namesrv
tools/src/main/java/org/...q/tools/command/namesrv
43:53 
66:76 
48:58 
40:50 
40:50 
39:48 
43:53 
view
7 x 2 tools/src/main/java/org/...ools/command/connection
tools/src/main/java/org/...tmq/tools/command/topic
46:56 
49:58 
view
7 x 6 tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
tools/src/main/java/org/...mq/tools/command/broker
example/src/main/java/or...example/benchmark/timer
41:51 
41:51 
40:50 
52:62 
54:64 
145:155 
view
7 x 2 tools/src/main/java/org/.../tools/command/consumer
tools/src/main/java/org/...tmq/tools/command/topic
54:64 
49:58 
view
7 x 2 tools/src/main/java/org/...q/tools/command/message
tools/src/main/java/org/...q/tools/command/message
43:53 
38:47 
view
7 x 2 common/src/main/java/org...e/rocketmq/common/stats
common/src/main/java/org...e/rocketmq/common/stats
87:95 
190:198 
view
7 x 2 common/src/main/java/org...e/rocketmq/common/stats
common/src/main/java/org...e/rocketmq/common/stats
97:105 
200:208 
view
7 x 2 broker/src/main/java/org/apache/rocketmq/broker
container/src/main/java/...ache/rocketmq/container
262:270 
369:377 
view
7 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
433:442 
1173:1182 
view
7 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
155:163 
79:87 
view
7 x 2 controller/src/main/java...che/rocketmq/controller
namesrv/src/main/java/org/apache/rocketmq/namesrv
154:164 
229:238 
view
7 x 2 auth/src/main/java/org/a...h/authorization/context
auth/src/main/java/org/a.../authentication/context
46:54 
62:70 
view
6 x 2 common/src/main/java/org...rocketmq/common/message
common/src/main/java/org...rocketmq/common/message
61:68 
68:75 
view
6 x 3 broker/src/main/java/org...tmq/broker/subscription
broker/src/main/java/org...cketmq/broker/config/v2
broker/src/main/java/org...cketmq/broker/config/v1
30:37 
121:128 
30:37 
view
6 x 3 broker/src/main/java/org...cketmq/broker/config/v1
broker/src/main/java/org...cketmq/broker/config/v1
broker/src/main/java/org...cketmq/broker/config/v1
158:165 
164:171 
201:208 
view
6 x 2 broker/src/main/java/org...e/rocketmq/broker/topic
client/src/main/java/org...mq/client/impl/producer
181:188 
457:464 
view
6 x 4 broker/src/main/java/org...cketmq/broker/processor
controller/src/main/java...mq/controller/processor
container/src/main/java/...ache/rocketmq/container
namesrv/src/main/java/or...ketmq/namesrv/processor
3312:3319 
332:339 
277:284 
675:682 
view
6 x 2 store/src/main/java/org/.../rocketmq/store/metrics
store/src/main/java/org/.../rocketmq/store/metrics
146:153 
243:250 
view
6 x 3 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/producer
106:113 
676:683 
483:490 
view
6 x 2 client/src/main/java/org...mq/client/impl/consumer
client/src/main/java/org...mq/client/impl/consumer
423:430 
1163:1170 
view
6 x 2 remoting/src/main/java/o...rocketmq/remoting/netty
remoting/src/main/java/o...rocketmq/remoting/netty
341:349 
876:884 
view
6 x 2 remoting/src/main/java/o.../remoting/protocol/body
remoting/src/main/java/o.../remoting/protocol/body
65:72 
65:72 
view
6 x 2 auth/src/main/java/org/a...h/authorization/manager
auth/src/main/java/org/a.../authentication/manager
54:61 
48:55 
view