centos7 安装 maven 和ant git 以及 rocketmq 4.2安装过程（安装成功，调用失败）

1.maven 安装

wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo

yum -y install apache-maven

2.install

yum -y install ant

3.git 安装

yum install git

#查看版本

git --version

#显示 git version +版本号 表示成功

#配置 git 名称以及邮箱

git config --global user.name "Your Name"

git config --global user.email "user@youremail"  

3.rocketmq安装（注意这里版本是4.2.0）

cd /usr/local/rocketmq(没有则创建目录)

git clone -b develop https://github.com/apache/incubator-rocketmq.git

cd incubator-rocketmq

mvn -Prelease-all -DskipTests clean install -U

------------------

一段长时间的maven 依赖下载

-------------------

cd distribution/target/apache-rocketmq

2）配置文件
 vim /etc/profile 添加 

#apache rocket-mq
export ROCKETMQ_HOME=/usr/local/rocketmq/incubator-rocketmq/distribution/target/apache-rocketmq
export PATH=$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
export NAMESRV_ADDR=自己服务器ip:9876

使profile 生效

source /etc/profile

进入到 /usr/local/rocketmq/incubator-rocketmq/distribution/target/apache-rocketmq/bin 目录下：添加权限

chmod +x mqadmin mqbroker mqfiltersrv mqshutdown mqnamesrv

启动：

nohup  mqnamesrv &

 //查看启动日志 默认在bin 目录的nohup.log下
 tail -f nohup.out显示如下信息 表示启动成功

3)由于自己的服务器使用的是阿里云的 2g 内存，启动那个 mqnamesrv后，启动mqbroker时候需要设置下内存大小，否则会报错

vim  runserver.sh（因为mqbroker脚本里面调用了runserver.sh  
 sh ${ROCKETMQ_HOME}/bin/runbroker.sh org.apache.rocketmq.broker.BrokerStartup $@）  修改下图：

之后 启动 mqbroker并将启动日志写入到指定位置.进入到target/bin目录

 nohup mqbroker & >/var/log/mq.log

启动成功后，使用ps aux|grep rocketmq如下图

4）写测试用例

1.pom.xml引入rocket包（引入的是4.1的包，4.2的引入后无法使用）

<!--4.2无法使用 -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-all</artifactId>
    <version>4.2.0</version>
    <type>pom</type>
</dependency>
<!--4.1的引用包-->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.1.0-incubating</version>
</dependency>

生产者main方法：

package cn.rocketmq;

import org.apache.rocketmq.client.exception.MQBrokerException;

import org.apache.rocketmq.client.exception.MQClientException;

import org.apache.rocketmq.client.producer.DefaultMQProducer;

import org.apache.rocketmq.client.producer.SendResult;

import org.apache.rocketmq.common.message.Message;

import org.apache.rocketmq.remoting.exception.RemotingException;

/**

 * Create by fan on 2018/4/16

 */

public class TestProductRocketMq {

    public static void main(String[] args) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {

        final DefaultMQProducer defaultMQProducer = new DefaultMQProducer("producerGroupName");

       // defaultMQProducer.setVipChannelEnabled(false);

        defaultMQProducer.setNamesrvAddr("47.98.111.19:9876");

        try {

            defaultMQProducer.start();

        } catch (MQClientException e) {

            e.printStackTrace();

        }

        Message message = new Message("testTopic","tagA","keyA","Hello RocketMq".getBytes());

        for (int i = 0 ;i<100;i++){

            if (i%2 == 0){

                SendResult sendResult = defaultMQProducer.send(message);

                Thread.sleep(100);

                System.out.println("tags send result:" + sendResult);

            }else {

                message = new Message("testTopic","tagB","keyB","Hello RocketMq.I'm your user".getBytes());

                SendResult sendResult = defaultMQProducer.send(message);

                Thread.sleep(100);

                System.out.println("tags send result:" + sendResult);

            }

        }

        Runtime.getRuntime().addShutdownHook(new Thread(() -> defaultMQProducer.shutdown()));

        System.exit(0);

    }

}

消费者方法：

package cn.rocketmq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;

import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;

import org.apache.rocketmq.client.exception.MQClientException;

import org.apache.rocketmq.common.consumer.ConsumeFromWhere;

import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

/**

 * Create by fan on 2018/4/16

 */

public class TestConsumeRocketMq {

    public static void main(String[] args) throws MQClientException {

        DefaultMQPushConsumer defaultMQPushConsumer = new DefaultMQPushConsumer("testProducerGroupName");

        defaultMQPushConsumer.setNamesrvAddr("47.98.111.19:9876");

        defaultMQPushConsumer.subscribe("testTopic","tagA || tagB");

        defaultMQPushConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);

        defaultMQPushConsumer.registerMessageListener(new MessageListenerConcurrently() {

            @Override

            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {

                System.out.println(Thread.currentThread().getName() + "Receive new message:" + list);

                MessageExt messageExt = list.get(0);

                System.out.println("messageExt:" + messageExt);

                if(messageExt!=null && "testTopic".equals(messageExt.getTopic())){

                    if("tagA".equals(messageExt.getTags())){

                        String mess = new String(messageExt.getBody());

                        System.out.println("mess tagA consume:" + mess);

                    }else if("tagB".equals(messageExt.getTags())){

                        String mess = new String(messageExt.getBody());

                        System.out.println("mess tagB consume:" + mess);

                    }

                }

                //回执确认消息

                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;

            }

        });

        defaultMQPushConsumer.start();

        System.out.println("Consume start.");

    }

}

之后运行main方法报错：

RocketMq Exception "connect to <：10909> failed"

解决办法是：centos关闭了10909以及9876防火墙端口

firewall-cmd --zone=public --add-port=10909/tcp --permanent

firewall-cmd --zone=public --add-port=9876/tcp --permanent

 

之后，又碰到下面的问题：

 

google了半天，尚未解决。。。