2018-11-10 17:03:06,060] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:06,163] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:06,314] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:06,517] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:06,870] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:07,778] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-11-10 17:03:08,835] WARN [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

单节点kafka进行idea连接调试时一直显示这个错误，现将我的解决办法贴出来。


首先要在kafka/config这个目录下找到server.properties这个配置文件


其次将listeners = PLAINTEXT://your.host.name:9092这个属性配置为你的IP地址

注意此时一定不要用hostname的形式，最好是使用IP地址的形式


重新启动kafka，单节点模式启动kafka/bin/kafka-server-start.sh -daemon kafka/config/server.properties


启动完成后使用jps命令查看是否启动成功

在此时如果发现不能正常启动kafka，则去/tmp这个目录下删除kafka-logs这个目录，直接用rm -rf命令


此时可以重新创建一个主题kafka/bin/kafka-topics.sh --create --zookeeper 192.168.109.190:2181 --replication-factor 1 --partitions 1 --topic test7

同样注意，此处一定要使用IP地址的形式，踩了无数坑，此处一定要使用IP地址形式！！！


先进行生产者测试kafka/bin/kafka-console-producer.sh --broker-list 192.168.109.190:9092 --topic test7

同样，此处一定要使用IP地址的形式


此时查看消费者是否能够读取消息kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.109.190:9092 --topic test7 --from-beginning

同样，此处一定要使用IP地址的形式


在你的IDEA用java代码进行测试，经过测试可以使用


综上所述，在用IDEA连接kafka进行测试时，如果遇到无法连接的问题，一定要注意IP地址，全部使用IP地址的形式进行尝试。
贴上java代码
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class ProducerDemo {
     public static void main(String args[]){
         Properties properties = new Properties();
         properties.put("bootstrap.servers","1:9092");
         properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
         properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");

         Producer producer = new KafkaProducer(properties);

             try{
                 for (int i=0;i<=99;i++){
                 producer.send(new ProducerRecord("test7","sinian","Hello Kafka"));
                 }
             }catch (Exception e){
                 e.printStackTrace();
             }
             finally {
                 producer.close();
             }
        }
}

一、背景

项目的接口方法写了单元测试后，怎么才能知道单元测试对接口的方法的调用是否执行了有效的逻辑代码呢？而且还有的接口压根就没有写单元测试，怎么自动执行测试？代码覆盖率的统计就可以比较有效解决这个问题。

二、目标

项目的接口方法写了单元测试后，需要知道单元测试对接口的方法的调用是否执行了有效的逻辑代码，而且没有写单元测试的接口也需要被统计；
	
设置代码覆盖率合格率的阈值，检测到低于这个阈值的标记结果不合格，大于或等于这个阈值的标记结果合格。
	
无论检测结果是失败还是合格，都需要一周至少发布一次检测结果告知java开发。
三、技术方案


	
市场上java主要代码覆盖率工具：Cobertura、EMMA、JaCoCo，而其中Cobertura和EMMA已停止维护，但JaCoCo社区比较活跃，官网也在不断的维护更新。jenkins上也有插件JaCoco可以统计单元测试TestNG的结果。
	
	
在java项目中添加插件jacoco-maven-plugin。
	
在Java项目中添加依赖jacoco-maven-plugin。
四、方案实施


	
java项目中的pom.xml配置
	
在Java项目中依赖jacoco-maven-plugin。
	

				
<dependency>

				
    <groupId>org.jacoco</groupId>

				
    <artifactId>jacoco-maven-plugin</artifactId>

				
    <version>0.8.3</version>

				
</dependency>
				
			
	

	
在java项目中添加插件jacoco-maven-plugin。

	

				
<!--检测代码覆盖率插件 start-->

				
<plugin>

				
    <groupId>org.jacoco</groupId>

				
    <artifactId>jacoco-maven-plugin</artifactId>

				
    <version>0.8.3</version>

				
    <executions>

				
        <execution>

				
            <goals>

				
                <goal>prepare-agent</goal>

				
            </goals>

				
        </execution>

				
        <execution>

				
            <id>report</id>

				
            <phase>prepare-package</phase>

				
            <goals>

				
                <goal>report</goal>

				
            </goals>

				
        </execution>

				
    </executions>

				
</plugin>

				
<!--检测代码覆盖率插件 end-->
				
			
 


	
jenkins部署配置
	
         1、登陆jenkins后，选择table面板“code coverage rate”, 然后点击“新建Item”, 如下图。

           

         2、接着进入新建任务名称页面，任命名称命名规范是"项目名_codeCoverageRate"，记得选中“Freestyle project”自由风格的项目，然后点击“OK”按钮创建，如下图：

          

3、接着，下一个页面有多个配置，需要特别注意，分步走：

    3.1、 “源码管理”面板配置，在标记1的地方勾选git，在标记2的地方“Repository URL”输入ssh方式的git地址），然后在标记3的地方输入分支名,注意，自动化测试分之名统一使用“test_automation”，如果变更代码也请合并到该分支。

 

4、“构建触发器”面板配置，勾选“build periodically”，表示定期触发构建，在“日程表”输入框中天蝎corn表达式，建议填写“H 9 * * 1”，表示每周一早上9点触发构建。

 

5、“构建”面板配置，选择“invoke top-level maven targets”表示maven设置，“maven版本”选择“maven”，目标填写命令行参数“clean test -Dspring.profiles.active=daily”,其中：clean 表示“删除之前编译的文件”，test“表示执行单元测试，“-Dspring.profiles.active=daily”表示选择构建的环境时“daily”。

 

 

6、点击按钮“增加构建后步骤”，选中“Publish TestNG Results”，缺少这一步，邮件中的部分值将拿不到；点击后多出一处“Publish TestNG Results”配置, 不用编辑，使用默认配置路径。



 

 

7、再次点击按钮“增加构建后步骤”，选中“Record JaCoCo coverage report”后，多出一处配置块“Record JaCoCo coverage report”；

其中“Path to class directories”是指定扫描类的包的路径，以'/'隔开，多个路径以英文','隔开；标注1的地方是值排出的类。
	
标注2的地方是指扫描的编译后的类路径。
	
标注3的地方是指定包含那些源码，查看具体的代码覆盖率时用到。
	
勾选“Change build status according the thresholds”和“Fail the build if coverage degrades more than the delta thresholds”，其中“Change build status according the thresholds”是根据阈值变更状态，我们只需改“%Method”和“%Class”对应的值，“太阳”表示良好，对应的“%Method”和“%Class”都改成80；“闪电云”表示合格阈值，对应的类覆盖率“%Class”改成100；方法覆盖率“%Method”及格线60%，良好80%；行覆盖率“%Method”及格线60%，良好80%。“Fail the build if coverage degrades more than the delta thresholds”是如果覆盖率下降超过delta阈值，则构建失败的配置，只有“闪电云”标示，对应的“%Method”为60%和“%Class”改成100。


 

6、“构建后操作”面板配置

    6.1、点击按钮“增加构建后操作步骤”，选中“Editable Email Notification Templates”，编辑邮件通知，注意，这里是选择邮件模板，模板我已配置好。选择后多出一块配置“Editable Email Notification Templates”, 这里选择“代码覆盖率检测结果邮件模板 - 代码覆盖率测试”。



 

6.2、如果需要指定某个或几个类不扫描，则在面板“Record JaCoCo coverage report”的第一行的最后一个“Exclusions”配置配置“**/类名.class”，如果多个用英文逗号隔开，如下图。

 

8、最后别忘“保存”，否则不生效。

 

1.jingdong.homefw.task.accept(物流商/服务商确认接单)接口

物流商/服务商接收到任务工单后，需要确认能否履约。

特别说明：

*对接方为商家时，由商家来调用此接口进行确认能否履约(比如：商家可在自己的物流商(服务商)确认后，再由商家系统向京东进行确认)。

*对接方为物流商(服务商)时，则物流商(服务商)通过此接口进行确认能否接单履约。

应用级别输入参数

请求类：HomefwTaskAcceptRequest


			
名称
			
			

			
类型
			
			

			
是否必填
			
			

			
示例值
			
			

			
描述
			
		

			
appid
			
			

			
String
			
			

			
是
			
			

			
 
			
			

			
宙斯平台应用appid
			
		

			
venderCode
			
			

			
String
			
			

			
否
			
			

			
 
			
			

			
识别码,可为空
			
		

			
orderNo
			
			

			
String
			
			

			
是
			
			

			
 
			
			

			
任务工单号
			
		

			
acceptType
			
			

			
Int
			
			

			
是
			
			

			
1
			
			

			
确认类型:1.物流确认接单；2.安装确认接单
			
		

			
remark
			
			

			
String
			
			

			
否
			
			

			
 
			
			

			
备注
			
		

			
handleTime
			
			

			
String
			
			

			
否
			
			

			
 
			
			

			
操作时间：格式为yyyy-MM-dd HH:mm:ss
			
		

			
isOneOrder
			
			

			
Int
			
			

			
是
			
			

			
1
			
			

			
确认类型:1.单一工单回传;2.非单一工单回传
			
		
结果集


			
名称
			
			

			
类型
			
			

			
是否必须
			
			

			
示例值
			
			

			
描述
			
		

			
returnType
			
			

			
ResultInfo
			
			

			
是
			
			

			
 
			
			

			
返回结果集,详见下面说明
			
		
ResultInfo 


			
名称
			
			

			
类型
			
			

			
是否必须
			
			

			
示例值
			
			

			
描述
			
		

			
resultCode
			
			

			
Number
			
			

			
是
			
			

			
100
			
			

			
返回码: 100:返回成功;200:返回失败
			
		

			
errMsg
			
			

			
String
			
			

			
否
			
			

			
参数不全
			
			

			
失败原因描述
			
		
​​​​​​​返回码解释


			
返回码
			
			

			
解释
			
			

			
产生原因
			
			

			
解决方式
			
		

			
100
			
			

			
执行成功
			
			

			
 
			
			

			
 
			
		

			
200
			
			

			
参数设置错误
			
			

			
参数过期或错误
			
			

			
检查参数
			
		
2.Java代码实现

官方Java代码实现

public JdClient client=new DefaultJdClient(SERVER_URL,accessToken,appKey,appSecret);

HomefwTaskAcceptRequest request=new HomefwTaskAcceptRequest();

request.setVenderCode( "jingdong" );
request.setOrderNo( "jingdong" );
request.setAcceptType( 123 );
request.setRemark( "jingdong" );
request.setHandleTime( "jingdong" );
request.setIsOneOrder( 123 );

HomefwTaskAcceptResponse response=client.execute(request);

自己写的代码实现

public class JDAPIParent {
    public static String serverUrl = "https://api-dev.jd.com/routerjson";
    public static String accessToken = "***";
    public static String appKey = "***";
    public static String appSecret = "***";

    // 物流商/服务商确认接单	jingdong.homefw.task.accept
    public static HomefwTaskAcceptResponse homefwTaskAccept(
            HomefwTaskAcceptRequest request) throws Exception {
        JdClient client=new DefaultJdClient(serverUrl,accessToken,appKey,appSecret);

        return client.execute(request);
    }
}

    // 物流商/服务商确认接单	jingdong.homefw.task.accept
    public JdResultVO homefwTaskAccept(String orderNo) {
        HomefwTaskAcceptRequest request=new HomefwTaskAcceptRequest();
        try {
            request.setVenderCode(VENDER_CODE);
            request.setOrderNo(orderNo);
            request.setAcceptType(2);//确认类型:1.物流确认接单；2.安装确认接单
            request.setRemark("");
            request.setHandleTime(DateUtil.getTime());
            request.setIsOneOrder(1);//确认类型:1.单一工单回传;2.非单一工单回传
            HomefwTaskAcceptResponse response=JDAPIParent.homefwTaskAccept(request);
            //保存明细
            jdApilogService.insert(request.getApiMethod(),
                    ReflectionToStringBuilder.toString(request),
                    ReflectionToStringBuilder.toString(response.getResultInfo()));
            return new JdResultVO();
        }catch (Exception e){
            jdApierrorService.insert(new HomefwTaskPushHandleStatRequest().getApiMethod(),
                    ReflectionToStringBuilder.toString(request),
                    StringUtil.getExceptionAllinformation(e));
        }
        return new JdResultVO("失败");
    }

源码详情参考http://www.zrscsoft.com/sitepic/12105.html

程序集名
保留
保留
备注
 rong
 
 
 
变量名
类型
数组
备注
 mobile
 文本型
 
 password
 文本型
 
 cookie
 文本型
 
 host
 文本型
 
 banker_id
 文本型
 
 banker_name
 文本型
 

子程序名
返回值类型
公开
备注
  初始化
  
  
   当基于本类的对象被创建后，此方法会被自动调用
mobile ＝ “157688740020”
password ＝ “XUANY1140”
host ＝ “http://bd.rong360.com/”

子程序名
返回值类型
公开
备注
  销毁
  
  
   当基于本类的对象被销毁前，此方法会被自动调用


子程序名
返回值类型
公开
备注
  登录
  
 √
  
变量名
类型
静态
数组
备注
 url
 文本型
 
 Form
 文本型
 
 Rundata
 文本型
 
清除Cookie ()
url ＝ host ＋ “api/v1/credit/user/login”
Form ＝ “mobile=” ＋ mobile ＋ “&password=” ＋ password ＋ “&src=iphone&app_ver=116&app_platform=ios”  ’  &time=1446130014&token=a0c43c181ba57fae1b46d0af30df0aa6
Rundata ＝ 到文本 (网页访问 (url, 1, Form, , cookie, , , , , ))
调试输出 (Rundata)
调试输出 (cookie)
banker_id ＝ 解析json (Rundata, “banker_id”)
banker_name ＝ 解析json (Rundata, “banker_name”)

子程序名
返回值类型
公开
备注
  方法1
 
 
‘ POST /api/v1/credit/user/get_banker_info HTTP/1.1
‘ Host: bd.rong360.com
‘ Content-Type: application/x-www-form-urlencoded; charset=utf-8
‘ Connection: keep-alive
‘ Cookie: utmz=1446123716.utmcsr=(direct)|utmcmd=(direct); abclass=1446092481_3; RONGID=914316abaa1cdff9515fe5c124101c76
‘ User-Agent:
‘ Content-Length: 111
‘ Accept-Encoding: gzip
‘ Connection: keep-alive
‘ banker_id=146044&src=iphone&app_ver=116&app_platform=ios&time=1446130015&token=550f32ea117017e42a9c0155f3c702cf

子程序名
返回值类型
公开
备注
  方法2
 
 
‘ bd.rong360.com/api/v1/credit/user/get_users?city=%E6%B7%B1%E5%9C%B3&app_ver=116&order=1&src=iphone&banker_id=89059&app_platform=ios&time=1446132045&token=e9f8e71b80fb7983d3318afb3472e2b1
‘ bd.rong360.com/api/v1/credit/user/get_users?city=%E5%AE%89%E5%BA%86%E5%B8%82&app_ver=116&order=1&src=iphone&banker_id=89059&app_platform=ios&time=1446132424&token=2ebed8db41678a0cdbd980dab09fb2cf

子程序名
返回值类型
公开
备注
  解析json
  文本型
 √
  
参数名
类型
参考
可空
数组
备注
  文本
  文本型
  name
  文本型
变量名
类型
静态
数组
备注
 j
 类_json
 
 errno
 text
 文本型
 
 data
j.解析 (文本)
如果 (j.取通用属性 (“errno”, 真) ＝ “0”)
    text ＝ j.取属性 (“data”).取通用属性 (name, 真)
否则
    调试输出 (文本)
如果结束
调试输出 (text)
返回 (text)

i本程序使用的支持库列表
spec
(特殊功能支持库)

i”生成
_______________