update rocketmq example

spring-cloud-alibaba-examples/rocketmq-example/readme-zh.md

@@ -122,12 +122,12 @@ spring.cloud.stream.bindings.output.destination=test-topic
 spring.cloud.stream.bindings.output.content-type=application/json
 
 spring.cloud.stream.bindings.input1.destination=test-topic
-spring.cloud.stream.bindings.input1.content-type=application/json
+spring.cloud.stream.bindings.input1.content-type=text/plain
 spring.cloud.stream.bindings.input1.group=test-group1
 spring.cloud.stream.rocketmq.bindings.input1.consumer.orderly=true
 
 spring.cloud.stream.bindings.input2.destination=test-topic
-spring.cloud.stream.bindings.input2.content-type=application/json
+spring.cloud.stream.bindings.input2.content-type=text/plain
 spring.cloud.stream.bindings.input2.group=test-group2
 spring.cloud.stream.rocketmq.bindings.input2.consumer.orderly=false
 spring.cloud.stream.rocketmq.bindings.input2.consumer.tags=tagStr
@@ -195,7 +195,7 @@ Spring Boot 应用支持通过 Endpoint 来暴露相关信息，RocketMQ Stream
 * Spring Boot 1.x 中添加配置 `management.security.enabled=false`
 * Spring Boot 2.x 中添加配置 `management.endpoints.web.exposure.include=*`
 
-Spring Boot 1.x 可以通过访问 http://127.0.0.1:18083/rocketmq-binder 来查看 RocketMQ Binder Endpoint 的信息。Spring Boot 2.x 可以通过访问 http://127.0.0.1:28081/acutator/rocketmq-binder 来访问。
+Spring Boot 1.x 可以通过访问 http://127.0.0.1:18083/rocketmq_binder 来查看 RocketMQ Binder Endpoint 的信息。Spring Boot 2.x 可以通过访问 http://127.0.0.1:28081/actuator/rocketmq-binder 来访问。
 
 这里会统计消息最后一次发送的数据，消息发送成功或失败的次数，消息消费成功或失败的次数等数据。
 
@@ -249,6 +249,14 @@ Spring Boot 1.x 可以通过访问 http://127.0.0.1:18083/rocketmq-binder 来查
 }
 ```
 
+注意：要想查看统计数据需要在pom里加上 [metrics-core依赖](https://mvnrepository.com/artifact/io.dropwizard.metrics/metrics-core) 。如若不加，endpoint将会显示warning信息而不会显示统计信息：
+
+```json
+{
+    "warning": "please add metrics-core dependency, we use it to metrics"
+}
+```
+
 ## More
 
 RocketMQ 是一款功能强大的分布式消息系统，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

spring-cloud-alibaba-examples/rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Foo.java

@@ -6,14 +6,14 @@ package org.springframework.cloud.alibaba.cloud.examples;
 public class Foo {
 
 	private int id;
-	private String tag;
+	private String bar;
 
 	public Foo() {
 	}
 
-	public Foo(int id, String tag) {
+	public Foo(int id, String bar) {
 		this.id = id;
-		this.tag = tag;
+		this.bar = bar;
 	}
 
 	public int getId() {
@@ -24,16 +24,16 @@ public class Foo {
 		this.id = id;
 	}
 
-	public String getTag() {
-		return tag;
-	}
+    public String getBar() {
+        return bar;
+    }
 
-	public void setTag(String tag) {
-		this.tag = tag;
-	}
+    public void setBar(String bar) {
+        this.bar = bar;
+    }
 
-	@Override
+    @Override
 	public String toString() {
-		return "Foo{" + "id=" + id + ", tag='" + tag + '\'' + '}';
+		return "Foo{" + "id=" + id + ", bar='" + bar + '\'' + '}';
 	}
 }

spring-cloud-alibaba-examples/rocketmq-example/src/main/resources/application.properties

@@ -6,13 +6,13 @@ spring.cloud.stream.bindings.output.destination=test-topic
 spring.cloud.stream.bindings.output.content-type=application/json
 
 spring.cloud.stream.bindings.input1.destination=test-topic
-spring.cloud.stream.bindings.input1.content-type=application/json
+spring.cloud.stream.bindings.input1.content-type=text/plain
 spring.cloud.stream.bindings.input1.group=test-group1
 spring.cloud.stream.rocketmq.bindings.input1.consumer.orderly=true
 spring.cloud.stream.bindings.input1.consumer.maxAttempts=1
 
 spring.cloud.stream.bindings.input2.destination=test-topic
-spring.cloud.stream.bindings.input2.content-type=application/json
+spring.cloud.stream.bindings.input2.content-type=text/plain
 spring.cloud.stream.bindings.input2.group=test-group2
 spring.cloud.stream.rocketmq.bindings.input2.consumer.orderly=false
 spring.cloud.stream.rocketmq.bindings.input2.consumer.tags=tagStr