• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java LocalNode类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中i5.las2peer.p2p.LocalNode的典型用法代码示例。如果您正苦于以下问题:Java LocalNode类的具体用法?Java LocalNode怎么用?Java LocalNode使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



LocalNode类属于i5.las2peer.p2p包,在下文中一共展示了LocalNode类的16个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called before the tests start.
 * <p>
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 *
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

    // start node
    node = LocalNode.newNode();
    testAgent = MockAgentFactory.getAdam();
    testAgent.unlockPrivateKey(testPass); // agent must be unlocked in order to be stored
    node.storeAgent(testAgent);
    node.launch();

    ServiceAgent testService = ServiceAgent.createServiceAgent(activityTrackerService, "a pass");
    testService.unlockPrivateKey("a pass");

    node.registerReceiver(testService);

    // start connector
    logStream = new ByteArrayOutputStream();

    connector = new WebConnector(true, HTTP_PORT, false, 1000);
    connector.setLogStream(new PrintStream(logStream));
    connector.start(node);
    Thread.sleep(1000); // wait a second for the connector to become ready
    testAgent = MockAgentFactory.getAdam(); // get a locked agent
}
 
开发者ID:rwth-acis,项目名称:las2peer-ActivityTracker,代码行数:32,代码来源:ActivityTrackerTest.java


示例2: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {
	
	//start node
	node = LocalNode.newNode();
	node.storeAgent(MockAgentFactory.getAdam());
	node.launch();
	
	ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
	testService.unlockPrivateKey("a pass");
	
	node.registerReceiver(testService);
	
	//start connector
	logStream = new ByteArrayOutputStream ();
	
	connector = new WebConnector(true,HTTP_PORT,false,1000);
	connector.setSocketTimeout(10000);
	connector.setLogStream(new PrintStream (logStream));
	connector.start ( node );
       Thread.sleep(1000); //wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();
	
       connector.updateServiceList();
       //avoid timing errors: wait for the repository manager to get all services before continuing
       try
       {
           System.out.println("waiting..");
           Thread.sleep(10000);
       }
       catch(InterruptedException e)
       {
           e.printStackTrace();
       }
	
}
 
开发者ID:rwth-acis,项目名称:LAS2peer-AnnotationService,代码行数:44,代码来源:ServiceTest.java


示例3: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
    * Called before the tests start.
    * 
    * Sets up the node and initializes connector and users that can be used
    * throughout the tests.
    * 
    * @throws Exception
    */
   @BeforeClass
   public static void startServer() throws Exception {

// start node
node = LocalNode.newNode();
node.storeAgent(MockAgentFactory.getAdam());
node.launch();

ServiceAgent testService = ServiceAgent.createServiceAgent(testServiceClass, "a pass");
testService.unlockPrivateKey("a pass");

node.registerReceiver(testService);

// start connector
logStream = new ByteArrayOutputStream();

connector = new WebConnector(true, HTTP_PORT, false, 1000);
connector.setLogStream(new PrintStream(logStream));
connector.start(node);
Thread.sleep(1000); // wait a second for the connector to become ready
testAgent = MockAgentFactory.getAdam();

connector.updateServiceList();
// avoid timing errors: wait for the repository manager to get all
// services before continuing
try {
    System.out.println("waiting..");
    Thread.sleep(10000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

   }
 
开发者ID:learning-layers,项目名称:Expert-Identification-Service,代码行数:42,代码来源:ServiceTest.java


示例4: testSetup

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
@Before
public void testSetup() throws Exception
{

    // start Node
    node = LocalNode.newNode();
    node.storeAgent(MockAgentFactory.getEve());
    node.storeAgent(MockAgentFactory.getAdam());
    node.storeAgent(MockAgentFactory.getAbel());
    node.storeAgent( MockAgentFactory.getGroup1());
    node.launch();

    ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");

    testService.unlockPrivateKey("a pass");


    node.registerReceiver(testService);


    // start connector

    logStream = new ByteArrayOutputStream ();

    //String xml=RESTMapper.mergeXMLs(new String[]{RESTMapper.getMethodsAsXML(TestService.class),RESTMapper.getMethodsAsXML(TestService2.class)});
    //System.out.println(xml);
    /*System.out.println(RESTMapper.getMethodsAsXML(TestService.class));
    System.out.println(RESTMapper.getMethodsAsXML(TestService2.class));*/

    connector = new WebConnector(true,HTTP_PORT,false,1000);
    connector.setSocketTimeout(5000);
    connector.setLogStream(new PrintStream ( logStream));
    connector.start ( node );

    // eve is the anonymous agent!
    testAgent = MockAgentFactory.getAdam();

}
 
开发者ID:rwth-acis,项目名称:LAS2peer-iStarMLModel-Service,代码行数:39,代码来源:IStarMLModelServiceRESTTest.java


示例5: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
@AfterClass
public static void shutDownServer() throws Exception {
	connector.stop();
	node.shutDown();

	connector = null;
	node = null;

	LocalNode.reset();

	System.out.println("Connector-Log:");
	System.out.println("--------------");
	System.out.println(logStream.toString());
}
 
开发者ID:rwth-acis,项目名称:las2peer-WebConnector,代码行数:15,代码来源:WebConnectorTest.java


示例6: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
    * Called before the tests start.
    * 
    * Sets up the node and initializes connector and users that can be used
    * throughout the tests.
    * 
    * @throws Exception
    */
   @BeforeClass
   public static void startServer() throws Exception {

// start node
node = LocalNode.newNode();
node.storeAgent(MockAgentFactory.getAdam());
node.launch();

ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
testService.unlockPrivateKey("a pass");

node.registerReceiver(testService);

// start connector
logStream = new ByteArrayOutputStream();

connector = new WebConnector(true, HTTP_PORT, false, 1000);
connector.setSocketTimeout(10000);
connector.setLogStream(new PrintStream(logStream));
connector.start(node);
Thread.sleep(1000); // wait a second for the connector to become ready
testAgent = MockAgentFactory.getAdam();

connector.updateServiceList();
// avoid timing errors: wait for the repository manager to get all
// services before continuing
try {
    System.out.println("waiting..");
    Thread.sleep(10000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

   }
 
开发者ID:rwth-acis,项目名称:Expert-Recommender-Service,代码行数:43,代码来源:ServiceTest.java


示例7: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used
 * throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

	// start node
	node = LocalNode.newNode();
	testAgent = MockAgentFactory.getAdam();
	testAgent.unlockPrivateKey(testPass); // agent must be unlocked in order
											// to be stored
	node.storeAgent(testAgent);
	node.launch();

	// during testing, the specified service version does not matter
	ServiceAgent testService = ServiceAgent
			.createServiceAgent(ServiceNameVersion.fromString(ServiceClass.class.getName() + "@1.0"), "a pass");
	testService.unlockPrivateKey("a pass");

	node.registerReceiver(testService);

	// start connector
	logStream = new ByteArrayOutputStream();

	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);
	Thread.sleep(1000); // wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();

	/*
	 * Sets up the database environment for testing.
	 */

	setupDatabase();

}
 
开发者ID:rwth-acis,项目名称:REST-OCD-Services,代码行数:43,代码来源:ServiceTest.java


示例8: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

	// start node
	node = LocalNode.newNode();
	node.storeAgent(MockAgentFactory.getAdam());
	node.launch();

	ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
	testService.unlockPrivateKey("a pass");

	node.registerReceiver(testService);

	// start connector
	logStream = new ByteArrayOutputStream();

	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);
	Thread.sleep(1000); // wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();

	connector.updateServiceList();
	// avoid timing errors: wait for the repository manager to get all services before continuing
	try
	{
		System.out.println("waiting..");
		Thread.sleep(10000);
	} catch (InterruptedException e)
	{
		e.printStackTrace();
	}

}
 
开发者ID:rwth-acis,项目名称:las2peer-FileStorage-Service,代码行数:42,代码来源:DownloadServiceTest.java


示例9: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called after the tests have finished.
 * Shuts down the server and prints out the connector log file for reference.
 * 
 * @throws Exception
 */
@AfterClass
public static void shutDownServer () throws Exception {
	
	connector.stop();
	node.shutDown();
	
       connector = null;
       node = null;
       
       LocalNode.reset();
	
	System.out.println("Connector-Log:");
	System.out.println("--------------");
	
	System.out.println(logStream.toString());
	
   }
 
开发者ID:rwth-acis,项目名称:LAS2peer-AnnotationService,代码行数:24,代码来源:ServiceTest.java


示例10: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called after the tests have finished.
 * Shuts down the server and prints out the connector log file for reference.
 *
 * @throws Exception
 */
@AfterClass
public static void shutDownServer() throws Exception {

    connector.stop();
    node.shutDown();

    connector = null;
    node = null;

    LocalNode.reset();

    System.out.println("Connector-Log:");
    System.out.println("--------------");

    System.out.println(logStream.toString());

}
 
开发者ID:rwth-acis,项目名称:las2peer-ActivityTracker,代码行数:24,代码来源:ActivityTrackerTest.java


示例11: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
    * Called after the tests have finished.
    * Shuts down the server and prints out the connector log file for
    * reference.
    * 
    * @throws Exception
    */
   @AfterClass
   public static void shutDownServer() throws Exception {

connector.stop();
node.shutDown();

connector = null;
node = null;

LocalNode.reset();

System.out.println("Connector-Log:");
System.out.println("--------------");

System.out.println(logStream.toString());

   }
 
开发者ID:learning-layers,项目名称:Expert-Identification-Service,代码行数:25,代码来源:ServiceTest.java


示例12: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
@AfterClass
public static void shutDownServer () throws Exception {
    //connector.interrupt();

    connector.stop();
    node.shutDown();

    connector = null;
    node = null;

    LocalNode.reset();

    System.out.println("Connector-Log:");
    System.out.println("--------------");

    System.out.println(logStream.toString());
    //System.out.println(connector.sslKeystore);


}
 
开发者ID:rwth-acis,项目名称:LAS2peer-iStarMLModel-Service,代码行数:21,代码来源:IStarMLModelServiceRESTTest.java


示例13: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
@BeforeClass
public static void startServer() throws Exception {
	// init agents
	UserAgent eve = MockAgentFactory.getEve();
	eve.unlockPrivateKey("evespass");
	UserAgent adam = MockAgentFactory.getAdam();
	adam.unlockPrivateKey("adamspass");
	adam.setLoginName("adam");
	UserAgent abel = MockAgentFactory.getAbel();
	abel.unlockPrivateKey("abelspass");
	GroupAgent group1 = MockAgentFactory.getGroup1();
	group1.unlockPrivateKey(adam);

	// start Node
	node = LocalNode.newNode();
	node.storeAgent(eve);
	node.storeAgent(adam);
	node.storeAgent(abel);
	node.storeAgent(group1);
	node.launch();

	ServiceAgent testService1 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass1),
			"a pass");
	ServiceAgent testService2 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass2),
			"a pass");
	ServiceAgent testService3 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass3),
			"a pass");
	ServiceAgent testService4 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass4),
			"a pass");
	ServiceAgent testService5 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass5),
			"a pass");
	ServiceAgent testService6 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass6),
			"a pass");

	testService1.unlockPrivateKey("a pass");
	testService2.unlockPrivateKey("a pass");
	testService3.unlockPrivateKey("a pass");
	testService4.unlockPrivateKey("a pass");
	testService5.unlockPrivateKey("a pass");
	testService6.unlockPrivateKey("a pass");

	node.registerReceiver(testService1);
	node.registerReceiver(testService2);
	node.registerReceiver(testService3);
	node.registerReceiver(testService4);
	node.registerReceiver(testService5);
	node.registerReceiver(testService6);

	// start connector
	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setCrossOriginResourceDomain("*");
	connector.setCrossOriginResourceSharing(true);
	logStream = new ByteArrayOutputStream();
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);

	testAgent = adam;
}
 
开发者ID:rwth-acis,项目名称:las2peer-WebConnector,代码行数:59,代码来源:WebConnectorTest.java


示例14: startServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
@BeforeClass
public static void startServer() throws Exception {
	// init agents
	UserAgent eve = MockAgentFactory.getEve();
	eve.unlockPrivateKey("evespass");
	UserAgent adam = MockAgentFactory.getAdam();
	adam.unlockPrivateKey("adamspass");
	UserAgent abel = MockAgentFactory.getAbel();
	abel.unlockPrivateKey("abelspass");
	GroupAgent group1 = MockAgentFactory.getGroup1();
	group1.unlockPrivateKey(adam);

	// start Node
	node = LocalNode.newNode();
	node.storeAgent(eve);
	node.storeAgent(adam);
	node.storeAgent(abel);
	node.storeAgent(group1);
	node.launch();

	ServiceAgent testService1 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass1),
			"a pass");
	ServiceAgent testService2 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass2),
			"a pass");
	ServiceAgent testService3 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass3),
			"a pass");
	ServiceAgent testService4 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass4),
			"a pass");
	ServiceAgent testService5 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass5),
			"a pass");
	ServiceAgent testService6 = ServiceAgent.createServiceAgent(ServiceNameVersion.fromString(testServiceClass6),
			"a pass");

	testService1.unlockPrivateKey("a pass");
	testService2.unlockPrivateKey("a pass");
	testService3.unlockPrivateKey("a pass");
	testService4.unlockPrivateKey("a pass");
	testService5.unlockPrivateKey("a pass");
	testService6.unlockPrivateKey("a pass");

	node.registerReceiver(testService1);
	node.registerReceiver(testService2);
	node.registerReceiver(testService3);
	node.registerReceiver(testService4);
	node.registerReceiver(testService5);
	node.registerReceiver(testService6); // should not throw an error

	// start connector
	logStream = new ByteArrayOutputStream();
	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);

	// eve is the anonymous agent!
	testAgent = MockAgentFactory.getAdam();
}
 
开发者ID:rwth-acis,项目名称:las2peer-WebConnector,代码行数:57,代码来源:WebConnectorServiceInfoTest.java


示例15: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called after the tests have finished. Shuts down the server and prints
 * out the connector log file for reference.
 * 
 * @throws Exception
 */
@AfterClass
public static void shutDownServer() throws Exception {

	connector.stop();
	node.shutDown();

	connector = null;
	node = null;

	LocalNode.reset();

	System.out.println("Connector-Log:");
	System.out.println("--------------");

	System.out.println(logStream.toString());

}
 
开发者ID:rwth-acis,项目名称:REST-OCD-Services,代码行数:24,代码来源:ServiceTest.java


示例16: shutDownServer

import i5.las2peer.p2p.LocalNode; //导入依赖的package包/类
/**
 * Called after the tests have finished.
 * Shuts down the server and prints out the connector log file for reference.
 * 
 * @throws Exception
 */
@AfterClass
public static void shutDownServer() throws Exception {

	connector.stop();
	node.shutDown();

	connector = null;
	node = null;

	LocalNode.reset();

	System.out.println("Connector-Log:");
	System.out.println("--------------");

	System.out.println(logStream.toString());

}
 
开发者ID:rwth-acis,项目名称:las2peer-FileStorage-Service,代码行数:24,代码来源:DownloadServiceTest.java



注:本文中的i5.las2peer.p2p.LocalNode类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java LocalizationEventType类代码示例发布时间:2022-05-22
下一篇:
Java ThaiBuddhistEra类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap