Aggregate packaging specific files to a new sub-module: distribution
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/7e37799e Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/7e37799e Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/7e37799e Branch: refs/heads/develop Commit: 7e37799e822cda30b0607f859fc5574f468a49f3 Parents: 203cb30 Author: Zhanhui Li <[email protected]> Authored: Tue Mar 28 20:34:30 2017 +0800 Committer: Zhanhui Li <[email protected]> Committed: Tue Mar 28 20:34:30 2017 +0800 ---------------------------------------------------------------------- .gitignore | 3 +- BUILDING | 34 +- LICENSE-BIN | 299 ----------------- NOTICE-BIN | 36 -- bin/README.md | 29 -- bin/cachedog.sh | 42 --- bin/cleancache.sh | 20 -- bin/cleancache.v1.sh | 40 --- bin/mqadmin | 45 --- bin/mqadmin.cmd | 18 - bin/mqadmin.xml | 43 --- bin/mqbroker | 45 --- bin/mqbroker.cmd | 23 -- bin/mqbroker.numanode0 | 47 --- bin/mqbroker.numanode1 | 47 --- bin/mqbroker.numanode2 | 47 --- bin/mqbroker.numanode3 | 47 --- bin/mqbroker.xml | 43 --- bin/mqfiltersrv | 45 --- bin/mqfiltersrv.cmd | 23 -- bin/mqfiltersrv.xml | 43 --- bin/mqnamesrv | 45 --- bin/mqnamesrv.cmd | 23 -- bin/mqnamesrv.xml | 43 --- bin/mqshutdown | 49 --- bin/mqshutdown.cmd | 35 -- bin/os.sh | 64 ---- bin/play.cmd | 30 -- bin/play.sh | 33 -- bin/runbroker.cmd | 42 --- bin/runbroker.sh | 61 ---- bin/runserver.cmd | 37 --- bin/runserver.sh | 48 --- bin/setcache.sh | 40 --- bin/startfsrv.sh | 45 --- bin/tools.cmd | 35 -- bin/tools.sh | 43 --- conf/2m-2s-async/broker-a-s.properties | 22 -- conf/2m-2s-async/broker-a.properties | 22 -- conf/2m-2s-async/broker-b-s.properties | 22 -- conf/2m-2s-async/broker-b.properties | 22 -- conf/2m-2s-sync/broker-a-s.properties | 22 -- conf/2m-2s-sync/broker-a.properties | 22 -- conf/2m-2s-sync/broker-b-s.properties | 22 -- conf/2m-2s-sync/broker-b.properties | 22 -- conf/2m-noslave/broker-a.properties | 22 -- conf/2m-noslave/broker-b.properties | 22 -- conf/broker.conf | 22 -- conf/logback_broker.xml | 328 ------------------- conf/logback_filtersrv.xml | 91 ----- conf/logback_namesrv.xml | 91 ----- conf/logback_tools.xml | 96 ------ distribution/LICENSE-BIN | 299 +++++++++++++++++ distribution/NOTICE-BIN | 36 ++ distribution/bin/README.md | 29 ++ distribution/bin/cachedog.sh | 42 +++ distribution/bin/cleancache.sh | 20 ++ distribution/bin/cleancache.v1.sh | 40 +++ distribution/bin/mqadmin | 45 +++ distribution/bin/mqadmin.cmd | 18 + distribution/bin/mqadmin.xml | 43 +++ distribution/bin/mqbroker | 45 +++ distribution/bin/mqbroker.cmd | 23 ++ distribution/bin/mqbroker.numanode0 | 47 +++ distribution/bin/mqbroker.numanode1 | 47 +++ distribution/bin/mqbroker.numanode2 | 47 +++ distribution/bin/mqbroker.numanode3 | 47 +++ distribution/bin/mqbroker.xml | 43 +++ distribution/bin/mqfiltersrv | 45 +++ distribution/bin/mqfiltersrv.cmd | 23 ++ distribution/bin/mqfiltersrv.xml | 43 +++ distribution/bin/mqnamesrv | 45 +++ distribution/bin/mqnamesrv.cmd | 23 ++ distribution/bin/mqnamesrv.xml | 43 +++ distribution/bin/mqshutdown | 49 +++ distribution/bin/mqshutdown.cmd | 35 ++ distribution/bin/os.sh | 64 ++++ distribution/bin/play.cmd | 30 ++ distribution/bin/play.sh | 33 ++ distribution/bin/runbroker | 15 + distribution/bin/runbroker.cmd | 42 +++ distribution/bin/runbroker.sh | 61 ++++ distribution/bin/runserver.cmd | 37 +++ distribution/bin/runserver.sh | 48 +++ distribution/bin/setcache.sh | 40 +++ distribution/bin/startfsrv.sh | 45 +++ distribution/bin/tools.cmd | 35 ++ distribution/bin/tools.sh | 43 +++ .../conf/2m-2s-async/broker-a-s.properties | 22 ++ .../conf/2m-2s-async/broker-a.properties | 22 ++ .../conf/2m-2s-async/broker-b-s.properties | 22 ++ .../conf/2m-2s-async/broker-b.properties | 22 ++ .../conf/2m-2s-sync/broker-a-s.properties | 22 ++ .../conf/2m-2s-sync/broker-a.properties | 22 ++ .../conf/2m-2s-sync/broker-b-s.properties | 22 ++ .../conf/2m-2s-sync/broker-b.properties | 22 ++ .../conf/2m-noslave/broker-a.properties | 22 ++ .../conf/2m-noslave/broker-b.properties | 22 ++ distribution/conf/broker.conf | 22 ++ distribution/conf/logback_broker.xml | 328 +++++++++++++++++++ distribution/conf/logback_filtersrv.xml | 91 +++++ distribution/conf/logback_namesrv.xml | 91 +++++ distribution/conf/logback_tools.xml | 96 ++++++ distribution/pom.xml | 125 +++++++ distribution/release-client.xml | 62 ++++ distribution/release.xml | 82 +++++ pom.xml | 48 +-- release-client.xml | 62 ---- release.xml | 70 ---- .../org/apache/rocketmq/store/ConsumeQueue.java | 11 +- .../org/apache/rocketmq/store/MappedFile.java | 2 +- 111 files changed, 2824 insertions(+), 2696 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/.gitignore ---------------------------------------------------------------------- diff --git a/.gitignore b/.gitignore index 3f5f9f0..80c6f56 100644 --- a/.gitignore +++ b/.gitignore @@ -8,7 +8,6 @@ devenv *.iml .idea/ *.versionsBackup -*bin !NOTICE-BIN !LICENSE-BIN -.DS_Store +.DS_Store \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/BUILDING ---------------------------------------------------------------------- diff --git a/BUILDING b/BUILDING index 1498b3e..8a30495 100644 --- a/BUILDING +++ b/BUILDING @@ -1,37 +1,37 @@ -Build instructions for RocketMQ +Build Instructions for Apache RocketMQ ==================================================== -(1) Requisites +(1) Prerequisites -JDK 1.7+ is required in order to compile and run RocketMQ. + JDK 1.7+ is required in order to compile and run RocketMQ. -RocketMQ utilizes Maven as a distribution management and packaging tool. Version 3.0.3 or later is required. -Maven installation and configuration instructions can be found here: + RocketMQ utilizes Maven as a distribution management and packaging tool. Version 3.0.3 or later is required. + Maven installation and configuration instructions can be found here: -http://maven.apache.org/run-maven/index.html + http://maven.apache.org/run-maven/index.html -(2) Executing test cases +(2) Run test cases -Execute the following command in order to compile and test the components: + Execute the following command in order to compile and run test cases of each components: -$ mvn test + $ mvn test -(3) Importing projects to eclipse +(3) Import projects to Eclipse IDE -First, generate eclipse project files: + First, generate eclipse project files: -$ mvn -U eclipse:eclipse + $ mvn -U eclipse:eclipse -Then, import to eclipse by specifying the root directory of the project via: + Then, import to eclipse by specifying the root directory of the project via: -[File] > [Import] > [Existing Projects into Workspace]. + [File] > [Import] > [Existing Projects into Workspace]. -(4) Building packages +(4) Build distribution packages -Execute the following command in order to build the tar.gz packages and install JAR to the local repository: + Execute the following command in order to build the tar.gz packages and install JAR into local repository: -$ mvn clean install -Prelease-all assembly:assembly -U \ No newline at end of file + $ mvn -Prelease-all -DskipTests clean package install -U \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/LICENSE-BIN ---------------------------------------------------------------------- diff --git a/LICENSE-BIN b/LICENSE-BIN deleted file mode 100644 index 9796b3c..0000000 --- a/LICENSE-BIN +++ /dev/null @@ -1,299 +0,0 @@ - Apache License - Version 2.0, January 2004 - http://www.apache.org/licenses/ - - TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION - - 1. Definitions. - - "License" shall mean the terms and conditions for use, reproduction, - and distribution as defined by Sections 1 through 9 of this document. - - "Licensor" shall mean the copyright owner or entity authorized by - the copyright owner that is granting the License. - - "Legal Entity" shall mean the union of the acting entity and all - other entities that control, are controlled by, or are under common - control with that entity. For the purposes of this definition, - "control" means (properties) the power, direct or indirect, to cause the - direction or management of such entity, whether by contract or - otherwise, or (ii) ownership of fifty percent (50%) or more of the - outstanding shares, or (iii) beneficial ownership of such entity. - - "You" (or "Your") shall mean an individual or Legal Entity - exercising permissions granted by this License. - - "Source" form shall mean the preferred form for making modifications, - including but not limited to software source code, documentation - source, and configuration files. - - "Object" form shall mean any form resulting from mechanical - transformation or translation of a Source form, including but - not limited to compiled object code, generated documentation, - and conversions to other media types. - - "Work" shall mean the work of authorship, whether in Source or - Object form, made available under the License, as indicated by a - copyright notice that is included in or attached to the work - (an example is provided in the Appendix below). - - "Derivative Works" shall mean any work, whether in Source or Object - form, that is based on (or derived from) the Work and for which the - editorial revisions, annotations, elaborations, or other modifications - represent, as a whole, an original work of authorship. For the purposes - of this License, Derivative Works shall not include works that remain - separable from, or merely link (or bind by name) to the interfaces of, - the Work and Derivative Works thereof. - - "Contribution" shall mean any work of authorship, including - the original version of the Work and any modifications or additions - to that Work or Derivative Works thereof, that is intentionally - submitted to Licensor for inclusion in the Work by the copyright owner - or by an individual or Legal Entity authorized to submit on behalf of - the copyright owner. For the purposes of this definition, "submitted" - means any form of electronic, verbal, or written communication sent - to the Licensor or its representatives, including but not limited to - communication on electronic mailing lists, source code control systems, - and issue tracking systems that are managed by, or on behalf of, the - Licensor for the purpose of discussing and improving the Work, but - excluding communication that is conspicuously marked or otherwise - designated in writing by the copyright owner as "Not a Contribution." - - "Contributor" shall mean Licensor and any individual or Legal Entity - on behalf of whom a Contribution has been received by Licensor and - subsequently incorporated within the Work. - - 2. Grant of Copyright License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - copyright license to reproduce, prepare Derivative Works of, - publicly display, publicly perform, sublicense, and distribute the - Work and such Derivative Works in Source or Object form. - - 3. Grant of Patent License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - (except as stated in this section) patent license to make, have made, - use, offer to sell, sell, import, and otherwise transfer the Work, - where such license applies only to those patent claims licensable - by such Contributor that are necessarily infringed by their - Contribution(s) alone or by combination of their Contribution(s) - with the Work to which such Contribution(s) was submitted. If You - institute patent litigation against any entity (including a - cross-claim or counterclaim in a lawsuit) alleging that the Work - or a Contribution incorporated within the Work constitutes direct - or contributory patent infringement, then any patent licenses - granted to You under this License for that Work shall terminate - as of the date such litigation is filed. - - 4. Redistribution. You may reproduce and distribute copies of the - Work or Derivative Works thereof in any medium, with or without - modifications, and in Source or Object form, provided that You - meet the following conditions: - - (a) You must give any other recipients of the Work or - Derivative Works a copy of this License; and - - (b) You must cause any modified files to carry prominent notices - stating that You changed the files; and - - (c) You must retain, in the Source form of any Derivative Works - that You distribute, all copyright, patent, trademark, and - attribution notices from the Source form of the Work, - excluding those notices that do not pertain to any part of - the Derivative Works; and - - (d) If the Work includes a "NOTICE" text file as part of its - distribution, then any Derivative Works that You distribute must - include a readable copy of the attribution notices contained - within such NOTICE file, excluding those notices that do not - pertain to any part of the Derivative Works, in at least one - of the following places: within a NOTICE text file distributed - as part of the Derivative Works; within the Source form or - documentation, if provided along with the Derivative Works; or, - within a display generated by the Derivative Works, if and - wherever such third-party notices normally appear. The contents - of the NOTICE file are for informational purposes only and - do not modify the License. You may add Your own attribution - notices within Derivative Works that You distribute, alongside - or as an addendum to the NOTICE text from the Work, provided - that such additional attribution notices cannot be construed - as modifying the License. - - You may add Your own copyright statement to Your modifications and - may provide additional or different license terms and conditions - for use, reproduction, or distribution of Your modifications, or - for any such Derivative Works as a whole, provided Your use, - reproduction, and distribution of the Work otherwise complies with - the conditions stated in this License. - - 5. Submission of Contributions. Unless You explicitly state otherwise, - any Contribution intentionally submitted for inclusion in the Work - by You to the Licensor shall be under the terms and conditions of - this License, without any additional terms or conditions. - Notwithstanding the above, nothing herein shall supersede or modify - the terms of any separate license agreement you may have executed - with Licensor regarding such Contributions. - - 6. Trademarks. This License does not grant permission to use the trade - names, trademarks, service marks, or product names of the Licensor, - except as required for reasonable and customary use in describing the - origin of the Work and reproducing the content of the NOTICE file. - - 7. Disclaimer of Warranty. Unless required by applicable law or - agreed to in writing, Licensor provides the Work (and each - Contributor provides its Contributions) on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - implied, including, without limitation, any warranties or conditions - of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A - PARTICULAR PURPOSE. You are solely responsible for determining the - appropriateness of using or redistributing the Work and assume any - risks associated with Your exercise of permissions under this License. - - 8. Limitation of Liability. In no event and under no legal theory, - whether in tort (including negligence), contract, or otherwise, - unless required by applicable law (such as deliberate and grossly - negligent acts) or agreed to in writing, shall any Contributor be - liable to You for damages, including any direct, indirect, special, - incidental, or consequential damages of any character arising as a - result of this License or out of the use or inability to use the - Work (including but not limited to damages for loss of goodwill, - work stoppage, computer failure or malfunction, or any and all - other commercial damages or losses), even if such Contributor - has been advised of the possibility of such damages. - - 9. Accepting Warranty or Additional Liability. While redistributing - the Work or Derivative Works thereof, You may choose to offer, - and charge a fee for, acceptance of support, warranty, indemnity, - or other liability obligations and/or rights consistent with this - License. However, in accepting such obligations, You may act only - on Your own behalf and on Your sole responsibility, not on behalf - of any other Contributor, and only if You agree to indemnify, - defend, and hold each Contributor harmless for any liability - incurred by, or claims asserted against, such Contributor by reason - of your accepting any such warranty or additional liability. - - END OF TERMS AND CONDITIONS - - APPENDIX: How to apply the Apache License to your work. - - To apply the Apache License to your work, attach the following - boilerplate notice, with the fields enclosed by brackets "[]" - replaced with your own identifying information. (Don't include - the brackets!) The text should be enclosed in the appropriate - comment syntax for the file format. We also recommend that a - file or class name and description of purpose be included on the - same "printed page" as the copyright notice for easier - identification within third-party archives. - - Copyright [yyyy] [name of copyright owner] - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ------- -This product has a bundle logback, which is available under the EPL v1.0 License. -The source code of logback can be found at https://github.com/qos-ch/logback. - -Logback LICENSE ---------------- - -Logback: the reliable, generic, fast and flexible logging framework. -Copyright (C) 1999-2015, QOS.ch. All rights reserved. - -This program and the accompanying materials are dual-licensed under -either the terms of the Eclipse Public License v1.0 as published by -the Eclipse Foundation - - or (per the licensee's choosing) - -under the terms of the GNU Lesser General Public License version 2.1 -as published by the Free Software Foundation. - ------- -This product has a bundle slf4j, which is available under the MIT License. -The source code of slf4j can be found at https://github.com/qos-ch/slf4j. - - Copyright (c) 2004-2017 QOS.ch - All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining - a copy of this software and associated documentation files (the - "Software"), to deal in the Software without restriction, including - without limitation the rights to use, copy, modify, merge, publish, - distribute, sublicense, and/or sell copies of the Software, and to - permit persons to whom the Software is furnished to do so, subject to - the following conditions: - - The above copyright notice and this permission notice shall be - included in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, - EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF - MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND - NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE - LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION - OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION - WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. - ------- -This product has a bundle fastjson, which is available under the ASL2 License. -The source code of fastjson can be found at https://github.com/alibaba/fastjson. - - Copyright 1999-2016 Alibaba Group Holding Ltd. - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - ------- -This product has a bundle javassist, which is available under the ASL2 License. -The source code of javassist can be found at https://github.com/jboss-javassist/javassist. - - Copyright (C) 1999- by Shigeru Chiba, All rights reserved. - - Javassist (JAVA programming ASSISTant) makes Java bytecode manipulation simple. - It is a class library for editing bytecodes in Java; it enables Java programs to define a new class - at runtime and to modify a class file when the JVM loads it. Unlike other similar bytecode editors, - Javassist provides two levels of API: source level and bytecode level. If the users use the source- level API, - they can edit a class file without knowledge of the specifications of the Java bytecode. - The whole API is designed with only the vocabulary of the Java language. - You can even specify inserted bytecode in the form of source text; Javassist compiles it on the fly. - On the other hand, the bytecode-level API allows the users to directly edit a class file as other editors. - - This software is distributed under the Mozilla Public License Version 1.1, - the GNU Lesser General Public License Version 2.1 or later, or the Apache License Version 2.0. - ------- -This product has a bundle jna, which is available under the ASL2 License. -The source code of jna can be found at https://github.com/java-native-access/jna. - - This copy of JNA is licensed under the - Apache (Software) License, version 2.0 ("the License"). - See the License for details about distribution rights, and the - specific rights regarding derivate works. - - You may obtain a copy of the License at: - - http://www.apache.org/licenses/ - - A copy is also included in the downloadable source code package - containing JNA, in file "AL2.0", under the same directory - as this file. \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/NOTICE-BIN ---------------------------------------------------------------------- diff --git a/NOTICE-BIN b/NOTICE-BIN deleted file mode 100644 index 73589d4..0000000 --- a/NOTICE-BIN +++ /dev/null @@ -1,36 +0,0 @@ -Apache RocketMQ (incubating) -Copyright 2016-2017 The Apache Software Foundation - -This product includes software developed at -The Apache Software Foundation (http://www.apache.org/). - ------- -This product has a bundle netty: - The Netty Project - ================= - -Please visit the Netty web site for more information: - - * http://netty.io/ - -Copyright 2014 The Netty Project - -The Netty Project licenses this file to you under the Apache License, -version 2.0 (the "License"); you may not use this file except in compliance -with the License. You may obtain a copy of the License at: - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, WITHOUT -WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the -License for the specific language governing permissions and limitations -under the License. - -Also, please refer to each LICENSE.<component>.txt file, which is located in -the 'license' directory of the distribution file, for the license terms of the -components that this product depends on. - ------- -This product has a bundle commons-lang, which includes software from the Spring Framework, -under the Apache License 2.0 (see: StringUtils.containsWhitespace()) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/README.md ---------------------------------------------------------------------- diff --git a/bin/README.md b/bin/README.md deleted file mode 100644 index efbb67d..0000000 --- a/bin/README.md +++ /dev/null @@ -1,29 +0,0 @@ -### Operating system tuning -Before deploying broker servers, it's highly recommended to run **os.sh**, which is to optimize your operating system for better performance. - -## Notice -### os.sh should be executed only once with root permission. -### os.sh parameter settings are for reference purpose only. You can tune them according to your target host configurations. - - -### Start broker -* Unix platform - - `nohup sh mqbroker &` - -### Shutdown broker - sh mqshutdown broker - -### Start Nameserver -* Unix platform - - `nohup sh mqnamesrv &` - -### Shutdown Nameserver - sh mqshutdown namesrv - -### Update or create Topic - sh mqadmin updateTopic -b 127.0.0.1:10911 -t TopicA - -### Update or create subscription group - sh mqadmin updateSubGroup -b 127.0.0.1:10911 -g SubGroupA \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/cachedog.sh ---------------------------------------------------------------------- diff --git a/bin/cachedog.sh b/bin/cachedog.sh deleted file mode 100755 index 9329fdb..0000000 --- a/bin/cachedog.sh +++ /dev/null @@ -1,42 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -export PATH=$PATH:/sbin - -while true; do - nr_free_pages=`fgrep -A 10 Normal /proc/zoneinfo |grep nr_free_pages |awk -F ' ' '{print $2}'` - high=`fgrep -A 10 Normal /proc/zoneinfo |grep high |awk -F ' ' '{print $2}'` - - NOW_DATE=`date +%D` - NOW_TIME=`date +%T` - - if [ ${nr_free_pages} -le ${high} ]; then - sysctl -w vm.drop_caches=3 - nr_free_pages_new=`fgrep -A 10 Normal /proc/zoneinfo |grep nr_free_pages |awk -F ' ' '{print $2}'` - - printf "%s %s [CLEAN] nr_free_pages < high, clean cache. nr_free_pages=%s ====> nr_free_pages=%s\n" "${NOW_DATE}" "${NOW_TIME}" ${nr_free_pages} ${nr_free_pages_new} - - sysctl -w vm.drop_caches=1 - echo - echo - echo - else - printf "%s %s [NOTHING] nr_free_pages=%s high=%s\n" "${NOW_DATE}" "${NOW_TIME}" ${nr_free_pages} ${high} - fi - - sleep 1 -done http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/cleancache.sh ---------------------------------------------------------------------- diff --git a/bin/cleancache.sh b/bin/cleancache.sh deleted file mode 100755 index 9c6e9ab..0000000 --- a/bin/cleancache.sh +++ /dev/null @@ -1,20 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -export PATH=$PATH:/sbin - -sysctl -w vm.drop_caches=3 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/cleancache.v1.sh ---------------------------------------------------------------------- diff --git a/bin/cleancache.v1.sh b/bin/cleancache.v1.sh deleted file mode 100755 index b334841..0000000 --- a/bin/cleancache.v1.sh +++ /dev/null @@ -1,40 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -export PATH=$PATH:/sbin - -# -# GB -# -function changeFreeCache() -{ - EXTRA=$1 - MIN=$2 - sysctl -w vm.extra_free_kbytes=${EXTRA}000000 - sysctl -w vm.min_free_kbytes=${MIN}000000 -} - - -if [ $# -ne 1 ] -then - echo "Usage: $0 freecache(GB)" - echo "Example: $0 15" - exit -fi - -changeFreeCache 3 $1 -changeFreeCache 3 1 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqadmin ---------------------------------------------------------------------- diff --git a/bin/mqadmin b/bin/mqadmin deleted file mode 100644 index cd0253b..0000000 --- a/bin/mqadmin +++ /dev/null @@ -1,45 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -sh ${ROCKETMQ_HOME}/bin/tools.sh org.apache.rocketmq.tools.command.MQAdminStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqadmin.cmd ---------------------------------------------------------------------- diff --git a/bin/mqadmin.cmd b/bin/mqadmin.cmd deleted file mode 100644 index 4e061f0..0000000 --- a/bin/mqadmin.cmd +++ /dev/null @@ -1,18 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%ROCKETMQ_HOME%\bin\tools.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 -call "%ROCKETMQ_HOME%\bin\tools.cmd" org.apache.rocketmq.tools.command.MQAdminStartup %* \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqadmin.xml ---------------------------------------------------------------------- diff --git a/bin/mqadmin.xml b/bin/mqadmin.xml deleted file mode 100644 index d014743..0000000 --- a/bin/mqadmin.xml +++ /dev/null @@ -1,43 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<java> - <debug>false</debug> - - <javahome>${JAVA_HOME}</javahome> - - <jvmtype>server</jvmtype> - - <mainclass>org.apache.rocketmq.tools.command.MQAdminStartup</mainclass> - - <properties> - <java.ext.dirs>${cpd}/../lib</java.ext.dirs> - <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> - </properties> - - <classpaths> - </classpaths> - - <options> - <-Xms512m></-Xms512m> - <-Xmx1g></-Xmx1g> - <-XX:NewSize>256M</-XX:NewSize> - <-XX:MaxNewSize>512M</-XX:MaxNewSize> - <-XX:PermSize>128M</-XX:PermSize> - <-XX:MaxPermSize>128M</-XX:MaxPermSize> - </options> -</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker ---------------------------------------------------------------------- diff --git a/bin/mqbroker b/bin/mqbroker deleted file mode 100644 index 6a79c39..0000000 --- a/bin/mqbroker +++ /dev/null @@ -1,45 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -sh ${ROCKETMQ_HOME}/bin/runbroker.sh org.apache.rocketmq.broker.BrokerStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.cmd ---------------------------------------------------------------------- diff --git a/bin/mqbroker.cmd b/bin/mqbroker.cmd deleted file mode 100644 index 3efb475..0000000 --- a/bin/mqbroker.cmd +++ /dev/null @@ -1,23 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%ROCKETMQ_HOME%\bin\runbroker.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 - -call "%ROCKETMQ_HOME%\bin\runbroker.cmd" org.apache.rocketmq.broker.BrokerStartup %* - -IF %ERRORLEVEL% EQU 0 ( - ECHO "Broker starts OK" -) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.numanode0 ---------------------------------------------------------------------- diff --git a/bin/mqbroker.numanode0 b/bin/mqbroker.numanode0 deleted file mode 100644 index b7486a7..0000000 --- a/bin/mqbroker.numanode0 +++ /dev/null @@ -1,47 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -export RMQ_NUMA_NODE=0 - -sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.numanode1 ---------------------------------------------------------------------- diff --git a/bin/mqbroker.numanode1 b/bin/mqbroker.numanode1 deleted file mode 100644 index c301fed..0000000 --- a/bin/mqbroker.numanode1 +++ /dev/null @@ -1,47 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -export RMQ_NUMA_NODE=1 - -sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.numanode2 ---------------------------------------------------------------------- diff --git a/bin/mqbroker.numanode2 b/bin/mqbroker.numanode2 deleted file mode 100644 index ea95304..0000000 --- a/bin/mqbroker.numanode2 +++ /dev/null @@ -1,47 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -export RMQ_NUMA_NODE=2 - -sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.numanode3 ---------------------------------------------------------------------- diff --git a/bin/mqbroker.numanode3 b/bin/mqbroker.numanode3 deleted file mode 100644 index 25d3d1d..0000000 --- a/bin/mqbroker.numanode3 +++ /dev/null @@ -1,47 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -export RMQ_NUMA_NODE=3 - -sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqbroker.xml ---------------------------------------------------------------------- diff --git a/bin/mqbroker.xml b/bin/mqbroker.xml deleted file mode 100644 index d1bc16f..0000000 --- a/bin/mqbroker.xml +++ /dev/null @@ -1,43 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<java> - <debug>false</debug> - - <javahome>${JAVA_HOME}</javahome> - - <jvmtype>server</jvmtype> - - <mainclass>org.apache.rocketmq.broker.BrokerStartup</mainclass> - - <properties> - <java.ext.dirs>${cpd}/../lib</java.ext.dirs> - <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> - </properties> - - <classpaths> - </classpaths> - - <options> - <-Xms512m></-Xms512m> - <-Xmx1g></-Xmx1g> - <-XX:NewSize>256M</-XX:NewSize> - <-XX:MaxNewSize>512M</-XX:MaxNewSize> - <-XX:PermSize>128M</-XX:PermSize> - <-XX:MaxPermSize>128M</-XX:MaxPermSize> - </options> -</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqfiltersrv ---------------------------------------------------------------------- diff --git a/bin/mqfiltersrv b/bin/mqfiltersrv deleted file mode 100644 index 2fd0cbe..0000000 --- a/bin/mqfiltersrv +++ /dev/null @@ -1,45 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.filtersrv.FiltersrvStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqfiltersrv.cmd ---------------------------------------------------------------------- diff --git a/bin/mqfiltersrv.cmd b/bin/mqfiltersrv.cmd deleted file mode 100644 index 0503026..0000000 --- a/bin/mqfiltersrv.cmd +++ /dev/null @@ -1,23 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%ROCKETMQ_HOME%\bin\runbroker.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 - -call "%ROCKETMQ_HOME%\bin\runserver.cmd" org.apache.rocketmq.filtersrv.FiltersrvStartup %* - -IF %ERRORLEVEL% EQU 0 ( - ECHO "Filtersrv starts OK" -) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqfiltersrv.xml ---------------------------------------------------------------------- diff --git a/bin/mqfiltersrv.xml b/bin/mqfiltersrv.xml deleted file mode 100644 index 8fdea39..0000000 --- a/bin/mqfiltersrv.xml +++ /dev/null @@ -1,43 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<java> - <debug>false</debug> - - <javahome>${JAVA_HOME}</javahome> - - <jvmtype>server</jvmtype> - - <mainclass>org.apache.rocketmq.filtersrv.FiltersrvStartup</mainclass> - - <properties> - <java.ext.dirs>${cpd}/../lib</java.ext.dirs> - <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> - </properties> - - <classpaths> - </classpaths> - - <options> - <-Xms512m></-Xms512m> - <-Xmx1g></-Xmx1g> - <-XX:NewSize>256M</-XX:NewSize> - <-XX:MaxNewSize>512M</-XX:MaxNewSize> - <-XX:PermSize>128M</-XX:PermSize> - <-XX:MaxPermSize>128M</-XX:MaxPermSize> - </options> -</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqnamesrv ---------------------------------------------------------------------- diff --git a/bin/mqnamesrv b/bin/mqnamesrv deleted file mode 100644 index c1e70bd..0000000 --- a/bin/mqnamesrv +++ /dev/null @@ -1,45 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.namesrv.NamesrvStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqnamesrv.cmd ---------------------------------------------------------------------- diff --git a/bin/mqnamesrv.cmd b/bin/mqnamesrv.cmd deleted file mode 100644 index 2828bdc..0000000 --- a/bin/mqnamesrv.cmd +++ /dev/null @@ -1,23 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%ROCKETMQ_HOME%\bin\runserver.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 - -call "%ROCKETMQ_HOME%\bin\runserver.cmd" org.apache.rocketmq.namesrv.NamesrvStartup %* - -IF %ERRORLEVEL% EQU 0 ( - ECHO "Namesrv starts OK" -) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqnamesrv.xml ---------------------------------------------------------------------- diff --git a/bin/mqnamesrv.xml b/bin/mqnamesrv.xml deleted file mode 100644 index dc5736a..0000000 --- a/bin/mqnamesrv.xml +++ /dev/null @@ -1,43 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<java> - <debug>false</debug> - - <javahome>${JAVA_HOME}</javahome> - - <jvmtype>server</jvmtype> - - <mainclass>org.apache.rocketmq.namesrv.NamesrvStartup</mainclass> - - <properties> - <java.ext.dirs>${cpd}/../lib</java.ext.dirs> - <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> - </properties> - - <classpaths> - </classpaths> - - <options> - <-Xms512m></-Xms512m> - <-Xmx1g></-Xmx1g> - <-XX:NewSize>256M</-XX:NewSize> - <-XX:MaxNewSize>512M</-XX:MaxNewSize> - <-XX:PermSize>128M</-XX:PermSize> - <-XX:MaxPermSize>128M</-XX:MaxPermSize> - </options> -</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqshutdown ---------------------------------------------------------------------- diff --git a/bin/mqshutdown b/bin/mqshutdown deleted file mode 100644 index d2d51fc..0000000 --- a/bin/mqshutdown +++ /dev/null @@ -1,49 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -case $1 in - broker) - - pid=`ps ax | grep -i 'org.apache.rocketmq.broker.BrokerStartup' |grep java | grep -v grep | awk '{print $1}'` - if [ -z "$pid" ] ; then - echo "No mqbroker running." - exit -1; - fi - - echo "The mqbroker(${pid}) is running..." - - kill ${pid} - - echo "Send shutdown request to mqbroker(${pid}) OK" - ;; - namesrv) - - pid=`ps ax | grep -i 'org.apache.rocketmq.namesrv.NamesrvStartup' |grep java | grep -v grep | awk '{print $1}'` - if [ -z "$pid" ] ; then - echo "No mqnamesrv running." - exit -1; - fi - - echo "The mqnamesrv(${pid}) is running..." - - kill ${pid} - - echo "Send shutdown request to mqnamesrv(${pid}) OK" - ;; - *) - echo "Useage: mqshutdown broker | namesrv" -esac http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/mqshutdown.cmd ---------------------------------------------------------------------- diff --git a/bin/mqshutdown.cmd b/bin/mqshutdown.cmd deleted file mode 100644 index 50af026..0000000 --- a/bin/mqshutdown.cmd +++ /dev/null @@ -1,35 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%JAVA_HOME%\bin\jps.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! & EXIT /B 1 - -setlocal - -set "PATH=%JAVA_HOME%\bin;%PATH%" - -if /I "%1" == "broker" ( - echo killing broker - for /f "tokens=1" %%i in ('jps -m ^| find "BrokerStartup"') do ( taskkill /F /PID %%i ) - echo Done! -) else if /I "%1" == "namesrv" ( - echo killing name server - - for /f "tokens=1" %%i in ('jps -m ^| find "NamesrvStartup"') do ( taskkill /F /PID %%i ) - - echo Done! -) else ( - echo Unknown role to kill, please specify broker or namesrv -) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/os.sh ---------------------------------------------------------------------- diff --git a/bin/os.sh b/bin/os.sh deleted file mode 100755 index f620158..0000000 --- a/bin/os.sh +++ /dev/null @@ -1,64 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -export PATH=$PATH:/sbin - -# sudo sysctl -w vm.extra_free_kbytes=2000000 -# sudo sysctl -w vm.min_free_kbytes=1000000 -sudo sysctl -w vm.overcommit_memory=1 -sudo sysctl -w vm.drop_caches=1 -sudo sysctl -w vm.zone_reclaim_mode=0 -sudo sysctl -w vm.max_map_count=655360 -sudo sysctl -w vm.dirty_background_ratio=50 -sudo sysctl -w vm.dirty_ratio=50 -sudo sysctl -w vm.dirty_writeback_centisecs=360000 -sudo sysctl -w vm.page-cluster=3 -sudo sysctl -w vm.swappiness=1 - -echo 'ulimit -n 655350' >> /etc/profile -echo '* hard nofile 655350' >> /etc/security/limits.conf - -echo '* hard memlock unlimited' >> /etc/security/limits.conf -echo '* soft memlock unlimited' >> /etc/security/limits.conf - -DISK=`df -k | sort -n -r -k 2 | awk -F/ 'NR==1 {gsub(/[0-9].*/,"",$3); print $3}'` -[ "$DISK" = 'cciss' ] && DISK='cciss!c0d0' -echo 'deadline' > /sys/block/${DISK}/queue/scheduler - - -echo "---------------------------------------------------------------" -sysctl vm.extra_free_kbytes -sysctl vm.min_free_kbytes -sysctl vm.overcommit_memory -sysctl vm.drop_caches -sysctl vm.zone_reclaim_mode -sysctl vm.max_map_count -sysctl vm.dirty_background_ratio -sysctl vm.dirty_ratio -sysctl vm.dirty_writeback_centisecs -sysctl vm.page-cluster -sysctl vm.swappiness - -su - admin -c 'ulimit -n' -cat /sys/block/$DISK/queue/scheduler - -if [ -d ${HOME}/tmpfs ] ; then - echo "tmpfs exist, do nothing." -else - ln -s /dev/shm tmpfs - echo "create tmpfs ok" -fi http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/play.cmd ---------------------------------------------------------------------- diff --git a/bin/play.cmd b/bin/play.cmd deleted file mode 100644 index f1737d5..0000000 --- a/bin/play.cmd +++ /dev/null @@ -1,30 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -START /B mqnamesrv > ns.log 2>&1 -IF %ERRORLEVEL% NEQ 0 ( - echo "Failed to start name server. Please check ns.log" - EXIT /B 1 -) - -START /B mqbroker -n localhost:9876 > bk.log 2>&1 - -IF %ERRORLEVEL% NEQ 0 ( - ECHO "Failed to start broker. Please check bk.log" - EXIT /B 1 -) - -echo "Start Name Server and Broker Successfully." \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/play.sh ---------------------------------------------------------------------- diff --git a/bin/play.sh b/bin/play.sh deleted file mode 100755 index 359d18d..0000000 --- a/bin/play.sh +++ /dev/null @@ -1,33 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -# -# Name Server -# -nohup sh mqnamesrv > ns.log 2>&1 & - -# -# Service Addr -# -ADDR=`hostname -i`:9876 - -# -# Broker -# -nohup sh mqbroker -n ${ADDR} > bk.log 2>&1 & - -echo "Start Name Server and Broker Successfully, ${ADDR}" http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/runbroker.cmd ---------------------------------------------------------------------- diff --git a/bin/runbroker.cmd b/bin/runbroker.cmd deleted file mode 100644 index 033d822..0000000 --- a/bin/runbroker.cmd +++ /dev/null @@ -1,42 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%JAVA_HOME%\bin\java.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! & EXIT /B 1 -set "JAVA=%JAVA_HOME%\bin\java.exe" - -setlocal - -set BASE_DIR=%~dp0 -set BASE_DIR=%BASE_DIR:~0,-1% -for %%d in (%BASE_DIR%) do set BASE_DIR=%%~dpd - -set CLASSPATH=.;%BASE_DIR%conf;%CLASSPATH% - -rem =========================================================================================== -rem JVM Configuration -rem =========================================================================================== -set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g" -set "JAVA_OPT=%JAVA_OPT% -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8 -XX:+DisableExplicitGC" -set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:%USERPROFILE%\mq_gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy" -set "JAVA_OPT=%JAVA_OPT% -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m" -set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow" -set "JAVA_OPT=%JAVA_OPT% -XX:+AlwaysPreTouch" -set "JAVA_OPT=%JAVA_OPT% -XX:MaxDirectMemorySize=15g" -set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages -XX:-UseBiasedLocking" -set "JAVA_OPT=%JAVA_OPT% -Djava.ext.dirs=%BASE_DIR%lib" -set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%" - -"%JAVA%" %JAVA_OPT% %* \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/runbroker.sh ---------------------------------------------------------------------- diff --git a/bin/runbroker.sh b/bin/runbroker.sh deleted file mode 100755 index 3405d39..0000000 --- a/bin/runbroker.sh +++ /dev/null @@ -1,61 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -#=========================================================================================== -# Java Environment Setting -#=========================================================================================== -error_exit () -{ - echo "ERROR: $1 !!" - exit 1 -} - -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java -[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!" - -export JAVA_HOME -export JAVA="$JAVA_HOME/bin/java" -export BASE_DIR=$(dirname $0)/.. -export CLASSPATH=.:${BASE_DIR}/conf:${CLASSPATH} - -#=========================================================================================== -# JVM Configuration -#=========================================================================================== -JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g" -JAVA_OPT="${JAVA_OPT} -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8 -XX:+DisableExplicitGC" -JAVA_OPT="${JAVA_OPT} -verbose:gc -Xloggc:/dev/shm/mq_gc_%p.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy" -JAVA_OPT="${JAVA_OPT} -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m" -JAVA_OPT="${JAVA_OPT} -XX:-OmitStackTraceInFastThrow" -JAVA_OPT="${JAVA_OPT} -XX:+AlwaysPreTouch" -JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=15g" -JAVA_OPT="${JAVA_OPT} -XX:-UseLargePages -XX:-UseBiasedLocking" -JAVA_OPT="${JAVA_OPT} -Djava.ext.dirs=${BASE_DIR}/lib" -#JAVA_OPT="${JAVA_OPT} -Xdebug -Xrunjdwp:transport=dt_socket,address=9555,server=y,suspend=n" -JAVA_OPT="${JAVA_OPT} -cp ${CLASSPATH}" - -numactl --interleave=all pwd > /dev/null 2>&1 -if [ $? -eq 0 ] -then - if [ -z "$RMQ_NUMA_NODE" ] ; then - numactl --interleave=all $JAVA ${JAVA_OPT} $@ - else - numactl --cpunodebind=$RMQ_NUMA_NODE --membind=$RMQ_NUMA_NODE $JAVA ${JAVA_OPT} $@ - fi -else - $JAVA ${JAVA_OPT} $@ -fi http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/runserver.cmd ---------------------------------------------------------------------- diff --git a/bin/runserver.cmd b/bin/runserver.cmd deleted file mode 100644 index e157d55..0000000 --- a/bin/runserver.cmd +++ /dev/null @@ -1,37 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - - -if not exist "%JAVA_HOME%\bin\java.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! & EXIT /B 1 -set "JAVA=%JAVA_HOME%\bin\java.exe" - -setlocal - -set BASE_DIR=%~dp0 -set BASE_DIR=%BASE_DIR:~0,-1% -for %%d in (%BASE_DIR%) do set BASE_DIR=%%~dpd - -set CLASSPATH=.;%BASE_DIR%conf;%CLASSPATH% - -set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:PermSize=128m -XX:MaxPermSize=320m" -set "JAVA_OPT=%JAVA_OPT% -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:+DisableExplicitGC -XX:-UseParNewGC" -set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:"%USERPROFILE%\rmq_srv_gc.log" -XX:+PrintGCDetails" -set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow" -set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages" -set "JAVA_OPT=%JAVA_OPT% -Djava.ext.dirs=%BASE_DIR%lib" -set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%"" - -"%JAVA%" %JAVA_OPT% %* \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/runserver.sh ---------------------------------------------------------------------- diff --git a/bin/runserver.sh b/bin/runserver.sh deleted file mode 100755 index e85991c..0000000 --- a/bin/runserver.sh +++ /dev/null @@ -1,48 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -#=========================================================================================== -# Java Environment Setting -#=========================================================================================== -error_exit () -{ - echo "ERROR: $1 !!" - exit 1 -} - -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java -[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!" - -export JAVA_HOME -export JAVA="$JAVA_HOME/bin/java" -export BASE_DIR=$(dirname $0)/.. -export CLASSPATH=.:${BASE_DIR}/conf:${CLASSPATH} - -#=========================================================================================== -# JVM Configuration -#=========================================================================================== -JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m" -JAVA_OPT="${JAVA_OPT} -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:+DisableExplicitGC -XX:-UseParNewGC" -JAVA_OPT="${JAVA_OPT} -verbose:gc -Xloggc:/dev/shm/rmq_srv_gc.log -XX:+PrintGCDetails" -JAVA_OPT="${JAVA_OPT} -XX:-OmitStackTraceInFastThrow" -JAVA_OPT="${JAVA_OPT} -XX:-UseLargePages" -JAVA_OPT="${JAVA_OPT} -Djava.ext.dirs=${BASE_DIR}/lib" -#JAVA_OPT="${JAVA_OPT} -Xdebug -Xrunjdwp:transport=dt_socket,address=9555,server=y,suspend=n" -JAVA_OPT="${JAVA_OPT} -cp ${CLASSPATH}" - -$JAVA ${JAVA_OPT} $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/setcache.sh ---------------------------------------------------------------------- diff --git a/bin/setcache.sh b/bin/setcache.sh deleted file mode 100755 index 27633f3..0000000 --- a/bin/setcache.sh +++ /dev/null @@ -1,40 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -export PATH=$PATH:/sbin - -# -# GB -# -function changeFreeCache() -{ - EXTRA=$1 - MIN=$2 - sysctl -w vm.extra_free_kbytes=${EXTRA}000000 - sysctl -w vm.min_free_kbytes=${MIN}000000 - sysctl -w vm.swappiness=0 -} - - -if [ $# -ne 2 ] -then - echo "Usage: $0 extra_free_kbytes(GB) min_free_kbytes(GB)" - echo "Example: $0 3 1" - exit -fi - -changeFreeCache $1 $2 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/startfsrv.sh ---------------------------------------------------------------------- diff --git a/bin/startfsrv.sh b/bin/startfsrv.sh deleted file mode 100755 index f7ba188..0000000 --- a/bin/startfsrv.sh +++ /dev/null @@ -1,45 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -if [ -z "$ROCKETMQ_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - ROCKETMQ_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` - - cd "$saveddir" -fi - -export ROCKETMQ_HOME - -nohup sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.filtersrv.FiltersrvStartup $@ & http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/tools.cmd ---------------------------------------------------------------------- diff --git a/bin/tools.cmd b/bin/tools.cmd deleted file mode 100644 index 28ce765..0000000 --- a/bin/tools.cmd +++ /dev/null @@ -1,35 +0,0 @@ -@echo off -rem Licensed to the Apache Software Foundation (ASF) under one or more -rem contributor license agreements. See the NOTICE file distributed with -rem this work for additional information regarding copyright ownership. -rem The ASF licenses this file to You under the Apache License, Version 2.0 -rem (the "License"); you may not use this file except in compliance with -rem the License. You may obtain a copy of the License at -rem -rem http://www.apache.org/licenses/LICENSE-2.0 -rem -rem Unless required by applicable law or agreed to in writing, software -rem distributed under the License is distributed on an "AS IS" BASIS, -rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -rem See the License for the specific language governing permissions and -rem limitations under the License. - -if not exist "%JAVA_HOME%\bin\java.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! & EXIT /B 1 - -set "JAVA=%JAVA_HOME%\bin\java.exe" - -setlocal -set BASE_DIR=%~dp0 -set BASE_DIR=%BASE_DIR:~0,-1% -for %%d in (%BASE_DIR%) do set BASE_DIR=%%~dpd - -set CLASSPATH=.;%BASE_DIR%conf;%CLASSPATH% - -rem =========================================================================================== -rem JVM Configuration -rem =========================================================================================== -set "JAVA_OPT=%JAVA_OPT% -server -Xms1g -Xmx1g -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m" -set "JAVA_OPT=%JAVA_OPT% -Djava.ext.dirs="%BASE_DIR%\lib";"%JAVA_HOME%\jre\lib\ext"" -set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%"" - -"%JAVA%" %JAVA_OPT% %* \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/bin/tools.sh ---------------------------------------------------------------------- diff --git a/bin/tools.sh b/bin/tools.sh deleted file mode 100755 index 66862ca..0000000 --- a/bin/tools.sh +++ /dev/null @@ -1,43 +0,0 @@ -#!/bin/sh - -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -#=========================================================================================== -# Java Environment Setting -#=========================================================================================== -error_exit () -{ - echo "ERROR: $1 !!" - exit 1 -} - -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java -[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java -[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!" - -export JAVA_HOME -export JAVA="$JAVA_HOME/bin/java" -export BASE_DIR=$(dirname $0)/.. -export CLASSPATH=.:${BASE_DIR}/conf:${CLASSPATH} - -#=========================================================================================== -# JVM Configuration -#=========================================================================================== -JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m" -JAVA_OPT="${JAVA_OPT} -Djava.ext.dirs=${BASE_DIR}/lib:${JAVA_HOME}/jre/lib/ext" -JAVA_OPT="${JAVA_OPT} -cp ${CLASSPATH}" - -$JAVA ${JAVA_OPT} $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7e37799e/conf/2m-2s-async/broker-a-s.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-async/broker-a-s.properties b/conf/2m-2s-async/broker-a-s.properties deleted file mode 100644 index 10d1555..0000000 --- a/conf/2m-2s-async/broker-a-s.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-a -brokerId=1 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SLAVE -flushDiskType=ASYNC_FLUSH
