This is an automated email from the ASF dual-hosted git repository. aiceflower pushed a commit to branch release-0.9.4 in repository https://gitbox.apache.org/repos/asf/linkis.git
commit d68bf3dd8cbcb1d2f4aa282c478c152881a45501 Author: chaogefeng <[email protected]> AuthorDate: Wed Jun 3 18:14:49 2020 +0800 To add support for CS Listener close #374 --- .../cs/listener/test/TestListenerManager.java | 201 ++++++++++----------- 1 file changed, 93 insertions(+), 108 deletions(-) diff --git a/contextservice/cs-listener/src/test/java/com/webank/wedatasphere/linkis/cs/listener/test/TestListenerManager.java b/contextservice/cs-listener/src/test/java/com/webank/wedatasphere/linkis/cs/listener/test/TestListenerManager.java index 4c44722c7b..08af5cd207 100644 --- a/contextservice/cs-listener/src/test/java/com/webank/wedatasphere/linkis/cs/listener/test/TestListenerManager.java +++ b/contextservice/cs-listener/src/test/java/com/webank/wedatasphere/linkis/cs/listener/test/TestListenerManager.java @@ -1,108 +1,93 @@ -//package com.webank.wedatasphere.linkis.cs.listener.test; -// -//import com.webank.wedatasphere.linkis.common.listener.Event; -//import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextID; -//import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextKey; -//import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextKeyValue; -//import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextValue; -//import com.webank.wedatasphere.linkis.cs.listener.ListenerBus.ContextAsyncListenerBus; -//import com.webank.wedatasphere.linkis.cs.listener.callback.imp.ClientSource; -//import com.webank.wedatasphere.linkis.cs.listener.callback.imp.ContextKeyValueBean; -//import com.webank.wedatasphere.linkis.cs.listener.callback.imp.DefaultContextIDCallbackEngine; -//import com.webank.wedatasphere.linkis.cs.listener.callback.imp.DefaultContextKeyCallbackEngine; -//import com.webank.wedatasphere.linkis.cs.listener.event.enumeration.OperateType; -//import com.webank.wedatasphere.linkis.cs.listener.event.impl.DefaultContextIDEvent; -//import com.webank.wedatasphere.linkis.cs.listener.event.impl.DefaultContextKeyEvent; -//import com.webank.wedatasphere.linkis.cs.listener.manager.ListenerManager; -//import com.webank.wedatasphere.linkis.cs.listener.manager.imp.DefaultContextListenerManager; -//import org.junit.Test; -// -//import java.util.ArrayList; -//import java.util.List; -// -///** -// * @Author: chaogefeng -// * @Date: 2020/2/22 -// */ -//public class TestListenerManager { -// @Test -// public void testGetContextAsyncListenerBus() { -// DefaultContextListenerManager defaultContextListenerManager = DefaultContextListenerManager.getInstance(); -// -// ContextAsyncListenerBus contextAsyncListenerBus = defaultContextListenerManager.getContextAsyncListenerBus(); -// -// DefaultContextIDCallbackEngine contextIDCallbackEngine = defaultContextListenerManager.getContextIDCallbackEngine(); -// -// DefaultContextKeyCallbackEngine contextKeyCallbackEngine = defaultContextListenerManager.getContextKeyCallbackEngine(); -// //client1的contextID -// TestContextID testContextID1 = new TestContextID(); -// testContextID1.setContextId("18392881376"); -// -// //client2的contextID -// TestContextID testContextID2 = new TestContextID(); -// testContextID2.setContextId("13431335441"); -// -// //client1的cskeys,监听key1,key2 -// List<ContextKey> csKeys1 = new ArrayList<>(); -// TestContextKey testContextKey1 = new TestContextKey(); -// testContextKey1.setKey("key1"); -// TestContextKey testContextKey2 = new TestContextKey(); -// testContextKey2.setKey("key2"); -// csKeys1.add(testContextKey1); -// csKeys1.add(testContextKey2); -// -// //client2的cskeys，监听key3,key4 -// List<ContextKey> csKeys2 = new ArrayList<>(); -// TestContextKey testContextKey3 = new TestContextKey(); -// testContextKey3.setKey("key3"); -// TestContextKey testContextKey4 = new TestContextKey(); -// testContextKey4.setKey("key4"); -// csKeys2.add(testContextKey3); -// csKeys2.add(testContextKey4); -// -// -// //client1的 name及instance -// ClientSource clientSource1 = new ClientSource(); -// -// //client2的 name及instance -// ClientSource clientSource2 = new ClientSource(); - -// -// contextKeyCallbackEngine.registerClient(testContextID1, csKeys1, clientSource1); -// System.out.println("+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++"); -// -// contextKeyCallbackEngine.registerClient(testContextID2, csKeys2, clientSource2); -// //同一个client可监听多个contextID，同一个contextID 可以监听多个cskey -// contextKeyCallbackEngine.registerClient(testContextID1, csKeys1, clientSource2); -// -// -// //传递的事件，赋值 contextId:183292881376 ,ContextKeyValue:key1:chaogefeng,operateType的类型 -// DefaultContextKeyEvent defaultContextKeyEvent = new DefaultContextKeyEvent(); -// //1、设置ID -// defaultContextKeyEvent.setContextID(testContextID1); -// //2、设置操作类型 -// defaultContextKeyEvent.setOperateType(OperateType.UPDATE); -// TestContextKeyValue testContextKeyValue = new TestContextKeyValue(); -// //更新key1对应的值，修改为chaogefeng -// testContextKeyValue.setContextKey(testContextKey1); -// TestContextValue testContextValue = new TestContextValue(); -// testContextValue.setValue("chaogefeng"); -// testContextKeyValue.setContextValue(testContextValue); -// //3、设置key value值 -// defaultContextKeyEvent.setContextKeyValue(testContextKeyValue); -// //4、给listener contextKeyCallbackEngine投递事件 -// contextAsyncListenerBus.doPostEvent(contextKeyCallbackEngine, defaultContextKeyEvent); -// //5、cleint2 心跳,因为它也监听了 contextID1，则应该返回 contextID1 中最新的key value值给它 -// ArrayList<ContextKeyValueBean> clientSource2ListenerCallback = contextKeyCallbackEngine.getListenerCallback(clientSource2); -// //遍历 这个bean，检查是否更新。 -// System.out.println("----------------------------------------------------------------------"); -// for (ContextKeyValueBean contextKeyValueBean : clientSource2ListenerCallback) { -// System.out.println("返回的bean里面对应的contexID: " + contextKeyValueBean.getCsID().getContextId()); -// System.out.println("返回的bean里面对应的cskeys: " + contextKeyValueBean.getCsKey().getKey()); -// if (contextKeyValueBean.getCsValue() != null) { -// System.out.println("返回的bean里面对应的value: " + contextKeyValueBean.getCsValue().getValue()); -// } -// } -// } -// -//} +package com.webank.wedatasphere.linkis.cs.listener.test; + +import com.webank.wedatasphere.linkis.common.listener.Event; +import com.webank.wedatasphere.linkis.cs.common.entity.listener.ListenerDomain; +import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextID; +import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextKey; +import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextKeyValue; +import com.webank.wedatasphere.linkis.cs.common.entity.source.ContextValue; +import com.webank.wedatasphere.linkis.cs.listener.ListenerBus.ContextAsyncListenerBus; +import com.webank.wedatasphere.linkis.cs.listener.callback.imp.ClientSource; +import com.webank.wedatasphere.linkis.cs.listener.callback.imp.ContextKeyValueBean; +import com.webank.wedatasphere.linkis.cs.listener.callback.imp.DefaultContextIDCallbackEngine; +import com.webank.wedatasphere.linkis.cs.listener.callback.imp.DefaultContextKeyCallbackEngine; +import com.webank.wedatasphere.linkis.cs.listener.event.enumeration.OperateType; +import com.webank.wedatasphere.linkis.cs.listener.event.impl.DefaultContextIDEvent; +import com.webank.wedatasphere.linkis.cs.listener.event.impl.DefaultContextKeyEvent; +import com.webank.wedatasphere.linkis.cs.listener.manager.ListenerManager; +import com.webank.wedatasphere.linkis.cs.listener.manager.imp.DefaultContextListenerManager; +import org.junit.Test; + +import java.util.ArrayList; +import java.util.List; + +/** + * @Author: chaogefeng + * @Date: 2020/2/22 + */ +public class TestListenerManager { + @Test + public void testGetContextAsyncListenerBus() { + DefaultContextListenerManager defaultContextListenerManager = DefaultContextListenerManager.getInstance(); + + ContextAsyncListenerBus contextAsyncListenerBus = defaultContextListenerManager.getContextAsyncListenerBus(); + + DefaultContextIDCallbackEngine contextIDCallbackEngine = defaultContextListenerManager.getContextIDCallbackEngine(); + + DefaultContextKeyCallbackEngine contextKeyCallbackEngine = defaultContextListenerManager.getContextKeyCallbackEngine(); + //client1的contextID + TestContextID testContextID1 = new TestContextID(); + testContextID1.setContextId("18392881376"); + + //client2的contextID + TestContextID testContextID2 = new TestContextID(); + testContextID2.setContextId("13431335441"); + + List<ContextKey> csKeys1 = new ArrayList<>(); + TestContextKey testContextKey1 = new TestContextKey(); + testContextKey1.setKey("key1"); + TestContextKey testContextKey2 = new TestContextKey(); + testContextKey2.setKey("key2"); + csKeys1.add(testContextKey1); + csKeys1.add(testContextKey2); + + List<ContextKey> csKeys2 = new ArrayList<>(); + TestContextKey testContextKey3 = new TestContextKey(); + testContextKey3.setKey("key3"); + TestContextKey testContextKey4 = new TestContextKey(); + testContextKey4.setKey("key4"); + csKeys2.add(testContextKey3); + csKeys2.add(testContextKey4); + + + ListenerDomain ListenerDomain1; + + ListenerDomain ListenerDomain2; + + ListenerDomain ListenerDomain3; + + + + + DefaultContextKeyEvent defaultContextKeyEvent = new DefaultContextKeyEvent(); + defaultContextKeyEvent.setContextID(testContextID1); + defaultContextKeyEvent.setOperateType(OperateType.UPDATE); + TestContextKeyValue testContextKeyValue = new TestContextKeyValue(); + testContextKeyValue.setContextKey(testContextKey1); + TestContextValue testContextValue = new TestContextValue(); + testContextValue.setValue("chaogefeng"); + testContextKeyValue.setContextValue(testContextValue); + defaultContextKeyEvent.setContextKeyValue(testContextKeyValue); + contextAsyncListenerBus.doPostEvent(contextKeyCallbackEngine, defaultContextKeyEvent); + ArrayList<ContextKeyValueBean> clientSource2ListenerCallback = contextKeyCallbackEngine.getListenerCallback(""); + System.out.println("----------------------------------------------------------------------"); + for (ContextKeyValueBean contextKeyValueBean : clientSource2ListenerCallback) { + System.out.println("返回的bean里面对应的contexID: " + contextKeyValueBean.getCsID().getContextId()); + System.out.println("返回的bean里面对应的cskeys: " + contextKeyValueBean.getCsKey().getKey()); + if (contextKeyValueBean.getCsValue() != null) { + System.out.println("返回的bean里面对应的value: " + contextKeyValueBean.getCsValue().getValue()); + } + } + } + +} --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
