collect的功能是什么?其底层如何实现的?_如何优雅地执行dubboquot;单测quot;

public class DubboAppContextFilterTest extends BaseTest {private DubboAppContextFilter filter &＃61; new DubboAppContextFilter();&＃64;Beforepublic void setUp() {cleanUpAll();}&＃64;Afterpublic void cleanUp() {cleanUpAll();}&＃64;Testpublic void testInvokeApplicationKey() {Invoker invoker &＃61; mock(Invoker.class);Invocation invocation &＃61; mock(Invocation.class);URL url &＃61; URL.valueOf("test://test:111/test?application&＃61;serviceA");when(invoker.getUrl()).thenReturn(url);filter.invoke(invoker, invocation);verify(invoker).invoke(invocation);String application &＃61; RpcContext.getContext().getAttachment(DubboUtils.SENTINEL_DUBBO_APPLICATION_KEY);assertEquals("serviceA", application);}
}

&＃64;AllArgsConstructor(access &＃61; AccessLevel.PRIVATE)
public class DubboTelnetProxy implements MethodInterceptor {private String ip;private Integer port;&＃64;Overridepublic Object intercept(Object obj, Method method, Object[] params, MethodProxy proxy) throws Throwable {if ("toString".equals(method.getName())) {return obj.getClass().getName();}TelnetClient telnetClient &＃61; new TelnetClient();telnetClient.setConnectTimeout((int) TimeUnit.SECONDS.toMillis(5));telnetClient.connect(ip, port);try {InputStream in &＃61; telnetClient.getInputStream();PrintStream out &＃61; new PrintStream(telnetClient.getOutputStream());// 1. 发送dubbo telnet请求StringBuffer request &＃61; new StringBuffer("invoke ");request.append(method.getDeclaringClass().getTypeName()).append(".");request.append(method.getName()).append("(");request.append(StringUtils.join(Arrays.stream(params).map(JSON::toJSONString).collect(Collectors.toList()), ",")).append(")");out.println(request.toString());out.flush();// 2. 结果处理int len &＃61; 0;byte[] buffer &＃61; new byte[512];String result &＃61; "";while (!result.contains(StringUtils.LF) && (len &＃61; in.read(buffer)) > 0) {result &＃43;&＃61; new String(ArrayUtils.subarray(buffer, 0, len));}result &＃61; StringUtils.substringBefore(result, StringUtils.LF);if (StringUtils.isBlank(result) || !result.startsWith("{")) {throw new RuntimeException(result);}// 3. 反序列化return JSON.parseObject(result, method.getGenericReturnType());} finally {telnetClient.disconnect();}}/*** mockDubboIpPortFormat&＃xff1a;配置格式为 -Dmock.dubbo.%s&＃61;127.0.0.1:8080&＃xff0c;%s为当前dubbo接口的名字&＃xff0c;class.getSimpleName()*/private final static String mockDubboIpPortPrefix &＃61; "mock.dubbo.";public final static String mockDubboIpPortFormat &＃61; mockDubboIpPortPrefix &＃43; "%s";/*** dubbo telnet建造者*/public static class Builder {final static String DEFAULT_IP &＃61; "127.0.0.1";final static Integer DEFAULT_PORT &＃61; 20880;/*** 创建dubbo telnet代理*/public static T enhance(Class clazz) {return enhance(clazz, null, null);}public static T enhance(Class clazz, String ip) {return enhance(clazz, ip, null);}public static T enhance(Class clazz, Integer port) {return enhance(clazz, null, port);}&＃64;SuppressWarnings("unchecked")public static T enhance(Class object, String ip, Integer port) {// 优先尝试从properties解析ip:port配置String ipPort &＃61; System.getProperties().getProperty(String.format(mockDubboIpPortFormat, object.getSimpleName()));if (StringUtils.isNotEmpty(ipPort)) {String[] array &＃61; StringUtils.split(ipPort, ",");ip &＃61; array[0];port &＃61; Integer.valueOf(array[1]);}Enhancer enhancer &＃61; new Enhancer();enhancer.setSuperclass(object);enhancer.setCallback(new DubboTelnetProxy(ObjectUtils.defaultIfNull(ip, DEFAULT_IP), ObjectUtils.defaultIfNull(port, DEFAULT_PORT)));return (T) enhancer.create();}}
}

&＃64;Test
public void test() {// OrderQueryService为dubbo服务的一个API接口System.setProperty("mock.dubbo.OrderQueryService", "127.0.0.1:20880");OrderQueryService orderQueryService1 &＃61; DubboTelnetProxy.Builder.enhance(OrderQueryService.class);OrderQueryService orderQueryService2 &＃61; DubboTelnetProxy.Builder.enhance(OrderQueryService.class, "127.0.0.1");OrderQueryService orderQueryService3 &＃61; DubboTelnetProxy.Builder.enhance(OrderQueryService.class, "127.0.0.1", 20880);OrderDTO result &＃61; orderQueryService1.query("订单号");System.out.println(result);
}

&＃64;RunWith(MockitoJUnitRunner.class)
public class DemoServiceClientTest {&＃64;InjectMocksDemoServiceClient demoServiceClient;&＃64;Beforepublic void before() throws IllegalAccessException {FieldUtils.writeField(demoServiceClient, "demoServiceFacade",DubboTelnetProxy.Builder.enhance(DemoServiceFacade.class), true);}&＃64;Testpublic void hello() throws IllegalAccessException {// 调用远程服务&＃xff0c;DubboTelnetProxy方式demoServiceClient.hello("world");// 如果需要打桩&＃xff0c;则使用Mock类DemoServiceFacade demoServiceFacade &＃61; Mockito.mock(DemoServiceFacade.class);Mockito.when(demoServiceFacade.hello("world")).thenReturn("zzz");FieldUtils.writeField(demoServiceClient, "demoServiceFacade", demoServiceFacade, true);Assert.assertEquals(demoServiceClient.hello("world"), "zzz");}
}&＃64;Component
public class DemoServiceClient {&＃64;Resourceprivate DemoServiceFacade demoServiceFacade;public String hello(String world) {return demoServiceFacade.hello(world);}
}// dubbo api
public interface DemoServiceFacade {String hello(String world);
}

/*** 默认的dubbo属性构造器&＃xff0c;如果是非本工程内属性类型并且是接口类型&＃xff0c;直接进行DubboTelnetProxy构建*/
public static Function DEFAULT_DUBBO_FC &＃61; field -> {try {assert Objects.nonNull(targetContext.get());Class fieldClass &＃61; field.getType();if (fieldClass.isInterface()) {// 本工程内的加载其实现类&＃xff0c;非本工程内的按照DubboTelnetProxy构建if (!isSameProjectPath(targetContext.get().getClass(), fieldClass)) {return DubboTelnetProxy.Builder.enhance(fieldClass);} else if (fieldClass.getSimpleName().endsWith("Dao")) {return Mockito.mock(fieldClass);} else {String packagePath &＃61; fieldClass.getPackage().getName() &＃43; ".impl.";return Class.forName(packagePath &＃43; fieldClass.getSimpleName() &＃43; "Impl").newInstance();}} else if (isSameProjectPath(targetContext.get().getClass(), fieldClass)) {return fieldClass.newInstance();} else {// 非工程内的类直接mock掉return Mockito.mock(fieldClass);}} catch (Exception e) {System.err.println("DEFAULT_DUBBO_FC 发生异常 field&＃61;" &＃43; field);e.printStackTrace();System.exit(-1);return null;}
};

void doWithFieldsInternal(&＃64;NonNull Object target, &＃64;Nullable Function fc, &＃64;Nullable Boolean recursive) {assert !(target instanceof Class);// 默认fc回调直接调用默认无参构造方法fc &＃61; ObjectUtils.defaultIfNull(fc, DEFAULT_FC);recursive &＃61; ObjectUtils.defaultIfNull(recursive, false);List fieldList &＃61; new ArrayList<>();do {Object finalTarget &＃61; target;Function finalFc &＃61; fc;ReflectionUtils.doWithFields(finalTarget.getClass(), field -> {Object value &＃61; finalFc.apply(field));DubboReflectionUtils.setField(finalTarget, field, value);if (Objects.nonNull(value) && DEFAULT_FF.matches(field)) {fieldList.add(value);}}, filterField -> {// 默认只注入非基本类型并且为null的属性return DEFAULT_FF.matches(filterField) && DubboReflectionUtils.isNullFieldValue(finalTarget, filterField);});} while (recursive && !fieldList.isEmpty() && Objects.nonNull(target &＃61; fieldList.remove(0)));
}