opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity
1,982 Commits 73 Branches 40 Tags
459b9d0be86e9584b2633f84be047beea8410a41
Commit Graph
144 Commits
Author SHA1 Message Date
huangli 8fa9ca592c [ISSUE 3825] Use default SO_SNDBUF/SO_RCVBUF/WRITE_BUFFER_WATER_MARK value. (#3826) 
This commit may greatly increase thoughtput when network lantency is big or message size is big, especially for consumer.

In one broker (M/S sync master async flush), one producer send test.

250 byte body: 0.93x old version
4000 byte body: 3.85x of old version
16000 byte body: 6.07x of old version
100000 byte body: 7.93x of old version

The old version is 4.9.3-SNAPSHOT in this test. In this test the network latency from producer to broker is 1.61ms.
 2022-02-10 11:15:04 +08:00
sunhangda 1b3b3a8146 Adding exception message with broker addr when occuring broker connect timeout (#3772) 
* fix:when broker is down,async send model can not retry

* fix Issue #3556

* fix Issue #3556

* fix Issue #3556

* fix Issue #3556

* async send model success retry when occurs Exception

* test case testSendMessageAsync_WithException

* modify test case testSendMessageAsync_WithException

* adding exception message with broker addr when occuring broker connect
timeout

* repair code style
 2022-01-19 11:07:52 +08:00
Kobold 43009b76ac [ISSUE #3685] Fix param spelling error (#3678) 
* Update .travis.yml

Depracated MODERATE noisy mail for dev@rocketmq.apache.org. Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327) @dongeforever

* fix class[RemotingHelper]  method[exceptionSimpleDesc] var[element] spelling error
 2022-01-06 09:51:20 +08:00
rushsky518 75557b8700 [ISSUE #1750] Fix display of SocketAddress is 'ocalhost/127.0.0.1:9876' 
* #1750 lastIndex of /

* optimize code
 2021-12-25 17:15:37 +08:00
huangli e4394b6cbe [ISSUE 3585] [Part C] cache the result of parseChannelRemoteAddr() and eliminate this method in flame graph. (used 4.84% cpu before this commit in producer side) (#3589) 2021-12-20 21:00:46 +08:00
tianliuliu 17d25ea56b [ISSUE #3651] for add netty channel option WRITE_BUFFER_WATER_MARK 2021-12-16 21:15:12 +08:00
Chengyang He ecb061ae42 fix code style of PR #3475 (#3650) 2021-12-15 20:47:55 +08:00
Chengyang He e1571eedb5 修复协议解析漏洞 (#3475) 2021-12-11 17:43:56 +08:00
赵延 1635856fea [ISSUE #2535] Polish log variable. (#2536) 
* [ISSUE #2535] Use one variable value to log info when eventQueue's size more than 10000.

* add the queue limit value when evenQueue size is enough.
 2021-12-10 23:04:08 +08:00
彭小漪 be6ded9049 [ISSUE #3528] The value of ChannelOption.SO_BACKLOG can not be hard-coded. (#3529) 
According to the official Linux documentation, the meaning of this value(ChannelOption.SO_BACKLOG) has changed since Linux 2.2.
 2021-11-24 10:43:37 +08:00
tigerlee 21faa68b4c [maven-release-plugin] prepare for next development iteration 2021-10-22 13:44:14 +08:00
tigerlee c840b20833 [maven-release-plugin] prepare release rocketmq-all-4.9.2 2021-10-22 13:43:57 +08:00
孙不服 daf1b9df79 [ISSUE #503] NOT_CONSUME_YET not righht in RocketMQ Console (#3091) 2021-09-27 09:07:59 +08:00
WJL3333 83b04d03f6 [ISSUE #3346]Avoid double parse remoteAddr in rpcHook call 2021-09-13 13:55:35 +08:00
gorden5566 44bdeedad2 [ISSUE 3203] Replace the class 'StringBuffer' by 'StringBuilder' (#3204) 2021-08-04 14:02:47 +08:00
zongtanghu bb34171289 [maven-release-plugin] prepare for next development iteration 2021-08-01 20:01:59 +08:00
zongtanghu e9c4253218 [maven-release-plugin] prepare release rocketmq-all-4.9.1 2021-08-01 20:01:39 +08:00
guyinyou 1eaa38f639 [ISSUE #3200] Fix code style in 'NettySystemConfig.java' 2021-07-30 19:06:27 +08:00
Heng Du d60643a2b6 Merge pull request #2720 from EZLippi/feature/issue2715 
[ISSUE #2715] make netty parameter configure by system property
 2021-07-25 08:55:11 +08:00
Heng Du 9a9039e8dc Merge pull request #3032 from messense/upgrade-netty-all 
[ISSUE #3031] Upgrade netty-all dependency version to 4.1.65.Final
 2021-07-23 13:32:41 +08:00
mxsm 7c364687c6 [ISSUE #3089] fix Print log format is incorrect in NettyRemotingAbstract class (#3126) 2021-07-05 16:09:34 +08:00
messense 361eb8d286 Upgrade netty-all dependency version to 4.1.65.Final 2021-06-23 13:36:34 +08:00
zongtanghu df1d93fc88 [maven-release-plugin] prepare for next development iteration 2021-06-10 21:36:05 +08:00
zongtanghu 5203d52f1b [maven-release-plugin] prepare release rocketmq-all-4.9.0 2021-06-10 21:35:41 +08:00
Walker Xiaandyuanyuan.xia 662404edfd [ISSUE #1057]Filter out docker0 when finding a local address (#1177) 
* Filter out docker0 when finding a local address

* sweep out bridge interface

Co-authored-by: yuanyuan.xia <yuanyuan.xia@envisioncn.com>
 2021-05-19 19:38:10 +08:00
ezlippi.ouyang 59cbbc4337 feat: add some test case 2021-03-15 10:08:26 +08:00
ezlippi.ouyang 67ceb64eb6 fix: add license 2021-03-12 18:05:22 +08:00
ezlippi.ouyang 98237b139a feat: add some test case 2021-03-12 15:27:31 +08:00
ezlippi.ouyang 03adb63c4c feat: add some test case 2021-03-12 14:47:56 +08:00
ezlippi.ouyang 33a533b3b7 feat: add some test case 2021-03-12 14:14:14 +08:00
SSpirits e9b2d8522d [ISSUE #1233] Fix CVE-2011-1473 2021-03-11 18:11:29 +08:00
ezlippi.ouyang b954d358ab feat: issue2715, make netty parameter configure by system property 2021-03-09 13:52:27 +08:00
赵延 e297221d50 [ISSUE #2622] Change variable name 'lockTreeMap' to 'treeMapLock' (#2624) 2021-02-01 17:32:02 +08:00
谷徳爆 4cfe00d722 [ISSUE #2642] Remove unused imports 2021-01-31 10:33:00 +08:00
Crazywen 0239421fa5 Remove useless netty-tcnative-boringssl-static dependencies 2020-12-25 11:23:04 +08:00
RongtongJin f35cafe128 [maven-release-plugin] prepare for next development iteration 2020-12-08 18:17:12 +08:00
RongtongJin 39bb9386f1 [maven-release-plugin] prepare release rocketmq-all-4.8.0 2020-12-08 18:16:49 +08:00
vongosling 3e5008f288 refactor(build): Remove duplicated logback-core dependency and update some modules to 1.8 compiler lever 2020-07-29 14:12:13 +08:00
RongtongJin fac30c3596 [maven-release-plugin] prepare for next development iteration 2020-06-24 14:05:55 +08:00
RongtongJin 9f95a972e1 [maven-release-plugin] prepare release rocketmq-all-4.7.1 2020-06-24 14:05:32 +08:00
lizhiboo 7e7568826e [ISSUE #1931] Remove duplicated doAfterRpcHooks logic 
fix bug: doAfterRpcHooks execute twice.
 2020-06-05 17:51:56 +08:00
wqliang 3245bd3cc6 select a new namesrv when namesrvAddrChoosed not in new addr list 2020-05-25 23:59:33 +08:00
rongtongjin 3974677f04 [maven-release-plugin] prepare for next development iteration 2020-03-05 19:07:09 +08:00
rongtongjin 8ef01a6c63 [maven-release-plugin] prepare release rocketmq-all-4.7.0 2020-03-05 19:06:47 +08:00
Heng Du 997164b1cd Merge pull request #1800 from Cczzzz/master 
[ISSUE #1781]Fix asynchronous send retry
 2020-02-28 19:36:06 +08:00
Heng Du 64e4ca727d Merge pull request #1516 from shenhui0509/sync_pipeline 
[ISSUE #1515] SYNC_MASTER could be change into pipeline manner
 2020-02-28 18:22:06 +08:00
Cc be67ff4a9e Merge branch 'master' into master 2020-02-27 22:22:05 +08:00
Cczzzz 40710b071b Fix asynchronous send retry 2020-02-20 18:39:37 +08:00
rongtongjin dd94362257 [maven-release-plugin] prepare for next development iteration 2020-01-20 22:11:43 +08:00
rongtongjin 73bb4b402a [maven-release-plugin] prepare release rocketmq-all-4.6.1 2020-01-20 22:11:21 +08:00