springcloud/springboot 集成rabbitm

直接上干货：

    环境：centeros7  docker  

安装启动rabbitmq 

docker内 下载rabbitmq镜像  docker pull rabbitmq:3.7.7-management

启动rabbitmq: docker run -d --name rabbitmq3.7.7 -p 5672:5672 -p 15672:15672 --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost -e RABBITMQ_DEFAULT_USER=admin RABBITMQ_DEFAULT_PASS=admin df80af9ca0c9（这个是镜像id）

RABBITMQ_DEFAULT_USER 设置默认登陆名  RABBITMQ_DEFAULT_PASS 设置默认登陆密码 ，也可以删掉默认，rabbitmq默认用户名  guest-guest

安装启动好后访问  localhost:15672 看到解面即可成功  

1、执行命令：docker pull sebp/elk 将镜像pull到本地来；

2、执行命令：docker run -p 5601:5601 -p 9200:9200 -p 5044:5044 -e ES_MIN_MEM=128m  -e ES_MAX_MEM=1024m -it --name elk sebp/elk 将镜像运行为容器，由于我本机内存不符合安装要求，为了保证ELK能够正常运行，加了-e参数限制使用最小内存及最大内存。

3、打开浏览器，输入：http://<your-host>:5601，看到图形化解面即安装成功

4 配置  docker exec -it elk /bin/bash  进入后 cd etc/logstash/conf.d ，然后 vi 02-beats-input.conf

input {

  rabbitmq {

      type =>"all"

      durable => true

      exchange => "ex_logstash"

      exchange_type => "direct"

      key => "logstash"

      host => "localhost:5672"

      user => "root"

      password => "admin"

      queue => "faceJob-logstash"

      auto_delete => false

  }

}

output{

    elasticsearch {

    hosts => ["localhost:9200"]

    }

}

保存，退出容器，重启elk。

es 查看日志：http://{ip}:9200/_search?pretty

kibana   :    http://192.168.72.128:5601 

如果访问都有结果那么elk集成rabbitmq就大功告成。

springboot 配置 rabbitmq 

maven引入：

  <dependency>

<groupId>org.springframework.amqp</groupId>

<artifactId>spring-rabbit</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

logback.xml:

<?xml version="1.0" encoding="UTF-8"?>

<configuration>

<!--日志存储位置（读取配置文件的路径） -->

<!-- 控制台日志 -->

<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">

　　　　　 <encoder>

　　　　　　　　　<pattern>%-4relative [%thread] %-5level %logger{35} - %msg %n</pattern>

　　　　　 </encoder>

　　　</appender>

<appender name="AMQP"

class="org.springframework.amqp.rabbit.logback.AmqpAppender">

<layout>

<pattern>

{

"time": "%date{ISO8601}",

"thread": "%thread",

"level":

"%level",

"class": "%logger{60}",

"message": "%msg"

}

</pattern>

</layout>

<host>192.168.72.128</host>

<port>5672</port>

<username>root</username>

<password>admin</password>

<routingKeyPattern>logstash</routingKeyPattern>

<declareExchange>false</declareExchange>

<exchangeType>direct</exchangeType>

<exchangeName>ex_logstash</exchangeName>

<generateId>true</generateId>

<charset>UTF-8</charset>

<durable>true</durable>

<deliveryMode>NON_PERSISTENT</deliveryMode>

</appender>

<root level="INFO">

<appender-ref ref="STDOUT" />

<appender-ref ref="AMQP" />

</root>

</configuration>

启动项目即可看到效果