Java TcpDiscoverySpi类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

本文整理汇总了Java中org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi类的典型用法代码示例。如果您正苦于以下问题：Java TcpDiscoverySpi类的具体用法？Java TcpDiscoverySpi怎么用？Java TcpDiscoverySpi使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

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

示例1: createIgnite

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
@Bean
@Scope("singleton")
@Qualifier("operationIgniteClient")
@ConditionalOnMissingBean(KafkaOperationRepository.class)
public Ignite createIgnite(ApplicationContext applicationContext) throws IgniteCheckedException {
    IgniteConfiguration cfg = new IgniteConfiguration();
    cfg.setClientMode(true);
    cfg.setPeerClassLoadingEnabled(false);
    TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
    TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
    ipFinder.setAddresses(Arrays.asList(clientAddress.split(",")));
    discoSpi.setIpFinder(ipFinder);
    cfg.setDiscoverySpi(discoSpi);
    cfg.setMetricsLogFrequency(0);
    return IgniteSpring.start(cfg,applicationContext);
}

开发者ID:kloiasoft，项目名称:eventapis，代码行数:17，代码来源:StoreApi.java

示例2: startIgnite_send

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
public static Ignite startIgnite_send(Map<String, String> group_attrs)
{

	IgniteConfiguration cfg = new IgniteConfiguration ();
	cfg.setPeerClassLoadingEnabled (true);
	// 设置群组
	cfg.setUserAttributes(group_attrs);
	//配置断点自动重连
	TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi();
	
	discoverySpi.setNetworkTimeout (5000);
	
	discoverySpi.setClientReconnectDisabled(true);
	
	cfg.setDiscoverySpi(discoverySpi);
	
	return Ignition.start(cfg);
}

开发者ID:Luodian，项目名称:Higher-Cloud-Computing-Project，代码行数:19，代码来源:SayHelloUtil.java

示例3: build

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
@Override
public IgniteConfiguration build() {
    IgniteConfiguration config = new IgniteConfiguration();
    config.setPeerClassLoadingEnabled(true);
    config.setClientMode(false);
    TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
    TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
    ArrayList<String> addrs = new ArrayList<>();
    addrs.add("127.0.0.1:47500..47509");
    ipFinder.setAddresses(addrs);
    discoSpi.setIpFinder(ipFinder);
    config.setDiscoverySpi(discoSpi);


    CacheConfiguration accountCacheCfg = new CacheConfiguration()
            .setName("BREED")
            .setAtomicityMode(TRANSACTIONAL)
            .setIndexedTypes(
                    String.class, Breed.class
            );

    config.setCacheConfiguration(accountCacheCfg);
    return config;
}

开发者ID:srecon，项目名称:ignite-jpa，代码行数:25，代码来源:ConfigurationMaker.java

示例4: getDefaultIgniteConfig

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
private IgniteConfiguration getDefaultIgniteConfig(IgniteResource gridResource) {
    IgniteConfiguration igniteConfiguration = new IgniteConfiguration();
    igniteConfiguration.setGridName(getGridName(gridResource));
    igniteConfiguration.setClientMode(getClientMode(gridResource));
    igniteConfiguration.setPeerClassLoadingEnabled(getPeerClassLoadingEnabled(gridResource));

    TcpDiscoverySpi tcpDiscoverySpi = new TcpDiscoverySpi();
    TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
    ipFinder.setAddresses(Collections.singletonList(getIpDiscoveryRange(gridResource)));
    tcpDiscoverySpi.setIpFinder(ipFinder);
    tcpDiscoverySpi.setLocalAddress(getLocalAddress(gridResource));
    igniteConfiguration.setDiscoverySpi(tcpDiscoverySpi);

    TcpCommunicationSpi communicationSpi = new TcpCommunicationSpi();
    communicationSpi.setLocalAddress(props.getLocalAddress());
    igniteConfiguration.setCommunicationSpi(communicationSpi);

    return igniteConfiguration;
}

开发者ID:minlia，项目名称:ignite-spring-boot，代码行数:20，代码来源:IgniteSpringBootConfiguration.java

示例5: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/**
 * Enhances the default configuration with the {#TcpDiscoveryRedisIpFinder}.
 *
 * @param gridName Grid name.
 * @return Ignite configuration.
 * @throws Exception If failed.
 */
@Override
protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
    IgniteConfiguration configuration = getDefaultConfiguration(gridName);

    TcpDiscoveryRedisIpFinder redisIpFinder = new TcpDiscoveryRedisIpFinder();
    redisIpFinder.setServiceName(REDIS_SERVICE_NAME);

    // first node => configure with redisConnectionString; second and subsequent
    // shall be configured through system property
    if (gridName.equals(getTestGridName(0)))
        redisIpFinder.setRedisConnectionString("localhost:16379");

    TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
    // Increase max missed heartbeats to avoid unexpected node fails.
    discoSpi.setMaxMissedHeartbeats(30);
    // Set heartbeat interval to 1 second to speed up tests.
    discoSpi.setHeartbeatFrequency(1000);
    // Set clean frequency to 500 milliseconds to speed up address unregistering
    discoSpi.setIpFinderCleanFrequency(500);
    discoSpi.setIpFinder(redisIpFinder);

    configuration.setDiscoverySpi(discoSpi);
    return configuration;
}

开发者ID:aalda，项目名称:ignite-redis，代码行数:32，代码来源:TcpDiscoveryRedisIpFinderTest.java

示例6: setUp

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
@Before
public void setUp() {
  TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
  ipFinder.setAddresses(Collections.singletonList(HOST));

  TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
  discoSpi.setIpFinder(ipFinder);

  IgniteConfiguration cfg = new IgniteConfiguration();
  cfg.setDiscoverySpi(discoSpi);

  cfg.setGridName("test");

  ignite = Ignition.start(cfg);

  Properties props = new Properties();
  props.setProperty(IgniteSqlInterpreter.IGNITE_JDBC_URL, "jdbc:ignite:cfg://[email protected]");
  props.setProperty(IgniteInterpreter.IGNITE_CLIENT_MODE, "false");
  props.setProperty(IgniteInterpreter.IGNITE_PEER_CLASS_LOADING_ENABLED, "false");

  intp = new IgniteInterpreter(props);
  intp.open();
}

开发者ID:lorthos，项目名称:incubator-zeppelin-druid，代码行数:24，代码来源:IgniteInterpreterTest.java

示例7: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = new IgniteConfiguration();

    TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();

    discoSpi.setIpFinder(IP_FINDER);

    cfg.setIgniteInstanceName(igniteInstanceName);
    cfg.setMarshaller(new BinaryMarshaller());
    cfg.setDiscoverySpi(discoSpi);
    cfg.setFileSystemConfiguration(igfsConfiguration(igniteInstanceName));
    cfg.setIncludeEventTypes(EVT_TASK_FAILED, EVT_TASK_FINISHED, EVT_JOB_MAPPED);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:17，代码来源:IgniteHadoopFileSystemAbstractSelfTest.java

示例8: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(ipFinder);

    CacheConfiguration cacheCfg = new CacheConfiguration()
        .setName(CACHE1)
        .setGroupName(GROUP)
        .setCacheMode(CacheMode.PARTITIONED)
        .setAtomicityMode(CacheAtomicityMode.ATOMIC);

    cfg.setCacheConfiguration(cacheCfg);

    if (persistence)
        cfg.setDataStorageConfiguration(new DataStorageConfiguration()
            .setDefaultDataRegionConfiguration(new DataRegionConfiguration().setPersistenceEnabled(true))
            .setWalMode(WALMode.LOG_ONLY)
        );

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:24，代码来源:CacheMetricsEnableRuntimeTest.java

示例9: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(ipFinder);

    if (cache) {
        CacheConfiguration ccfg = new CacheConfiguration(DEFAULT_CACHE_NAME);

        ccfg.setCacheMode(CacheMode.PARTITIONED);
        ccfg.setBackups(1);
        ccfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);

        ccfg.setNearConfiguration(null);

        ccfg.setAffinity(new RendezvousAffinityFunction(false, PARTS));

        cfg.setCacheConfiguration(ccfg);
    }
    else
        cfg.setClientMode(true);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:25，代码来源:IgniteClientAffinityAssignmentSelfTest.java

示例10: readCfgFromFileAndDeleteFile

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/**
 * Reads configuration from given file and delete the file after.
 *
 * @param fileName File name.
 * @return Readed configuration.
 * @throws IOException If failed.
 * @see #storeToFile(IgniteConfiguration, boolean)
 * @throws IgniteCheckedException On error.
 */
private static IgniteConfiguration readCfgFromFileAndDeleteFile(String fileName)
    throws IOException, IgniteCheckedException {
    try(BufferedReader cfgReader = new BufferedReader(new FileReader(fileName))) {
        IgniteConfiguration cfg = (IgniteConfiguration)new XStream().fromXML(cfgReader);

        if (cfg.getMarshaller() == null) {
            Marshaller marsh = IgniteTestResources.getMarshaller();

            cfg.setMarshaller(marsh);
        }

        X.println("Configured marshaller class: " + cfg.getMarshaller().getClass().getName());

        if (cfg.getDiscoverySpi() == null) {
            TcpDiscoverySpi disco = new TcpDiscoverySpi();
            disco.setIpFinder(GridCacheAbstractFullApiSelfTest.LOCAL_IP_FINDER);
            cfg.setDiscoverySpi(disco);
        }

        return cfg;
    }
    finally {
        new File(fileName).delete();
    }
}

开发者ID:apache，项目名称:ignite，代码行数:35，代码来源:IgniteNodeRunner.java

示例11: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);
    TcpDiscoverySpi spi = (TcpDiscoverySpi)cfg.getDiscoverySpi();
    spi.setIpFinder(IP_FINDER);

    CacheConfiguration<Integer, String> ccfg = new CacheConfiguration<>(DEFAULT_CACHE_NAME);
    ccfg.setIndexedTypes(Integer.class, String.class);

    cfg.setCacheConfiguration(ccfg);

    if ("client".equals(igniteInstanceName))
        cfg.setClientMode(true);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:17，代码来源:IgniteCacheDistributedQueryStopOnCancelOrTimeoutSelfTest.java

示例12: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    CacheConfiguration cache = defaultCacheConfiguration();

    cache.setName(CACHE_NAME);
    cache.setCacheMode(PARTITIONED);
    cache.setBackups(1);
    cache.setWriteSynchronizationMode(FULL_SYNC);
    cache.setIndexedTypes(
        Byte.class, Byte.class
    );

    cfg.setCacheConfiguration(cache);

    TcpDiscoverySpi disco = new TcpDiscoverySpi();

    disco.setIpFinder(IP_FINDER);

    cfg.setDiscoverySpi(disco);

    cfg.setConnectorConfiguration(new ConnectorConfiguration());

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:27，代码来源:JdbcEmptyCacheSelfTest.java

示例13: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    CacheConfiguration cacheCfg = new CacheConfiguration(DEFAULT_CACHE_NAME);

    cacheCfg.setCacheMode(getCacheMode());
    cacheCfg.setAtomicityMode(getAtomicMode());
    cacheCfg.setNearConfiguration(nearConfiguration());
    cacheCfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
    cacheCfg.setRebalanceMode(SYNC);
    cacheCfg.setAffinityMapper(AFFINITY_MAPPER);

    cfg.setCacheConfiguration(cacheCfg);

    TcpDiscoverySpi spi = new TcpDiscoverySpi();

    spi.setIpFinder(IP_FINDER);

    cfg.setDiscoverySpi(spi);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:24，代码来源:GridCacheAbstractUsersAffinityMapperSelfTest.java

示例14: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    // Default cache configuration.
    CacheConfiguration cacheCfg = defaultCacheConfiguration();

    cacheCfg.setCacheMode(PARTITIONED);
    cacheCfg.setAtomicityMode(TRANSACTIONAL);
    cacheCfg.setNearConfiguration(new NearCacheConfiguration());
    cacheCfg.setWriteSynchronizationMode(FULL_SYNC);
    cacheCfg.setBackups(backups);
    cacheCfg.setRebalanceMode(SYNC);

    cfg.setCacheConfiguration(cacheCfg);

    TcpDiscoverySpi spi = new TcpDiscoverySpi();

    spi.setIpFinder(ipFinder);

    cfg.setDiscoverySpi(spi);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:25，代码来源:GridCacheNearTxMultiNodeSelfTest.java

示例15: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(gridName);

    cfg.setConsistentId(gridName);

    DataStorageConfiguration memCfg = new DataStorageConfiguration()
        .setDefaultDataRegionConfiguration(
            new DataRegionConfiguration().setMaxSize(100 * 1024 * 1024).setPersistenceEnabled(true))
        .setPageSize(1024)
        .setWalMode(WALMode.LOG_ONLY);

    cfg.setDataStorageConfiguration(memCfg);

    cfg.setBinaryConfiguration(new BinaryConfiguration().setCompactFooter(false));

    ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(IP_FINDER);

    if (ccfgs != null) {
        cfg.setCacheConfiguration(ccfgs);

        ccfgs = null;
    }

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:27，代码来源:IgnitePersistentStoreCacheGroupsTest.java

示例16: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    cfg.setCacheConfiguration(
        cacheConfiguration("test0", "test0"),
        cacheConfiguration("test1", "tEst1"),
        cacheConfiguration("test2", "\"TestCase\""));

    TcpDiscoverySpi disco = new TcpDiscoverySpi();

    disco.setIpFinder(IP_FINDER);

    cfg.setDiscoverySpi(disco);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:18，代码来源:JdbcThinSchemaCaseTest.java

示例17: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    cfg.setCacheStoreSessionListenerFactories(
        new SessionListenerFactory("Shared 1"),
        new SessionListenerFactory("Shared 2")
    );

    TcpDiscoverySpi disco = new TcpDiscoverySpi();

    disco.setIpFinder(IP_FINDER);

    cfg.setDiscoverySpi(disco);

    return cfg;
}

开发者ID:apache，项目名称:ignite，代码行数:18，代码来源:CacheStoreSessionListenerLifecycleSelfTest.java

示例18: startBackUpClientNodes

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/**
 * @param cnt Count.
 * @throws Exception If failed.
 */
private void startBackUpClientNodes(int cnt) throws Exception {
    for (int i = 0; i < cnt; i++) {
        String node = "node" + i;

        String name = node + backUpSuffix + clientSuffix;

        IgniteConfiguration cfg = getConfiguration(name);
        cfg.setConsistentId(node);
        cfg.setActiveOnStart(false);
        cfg.setClientMode(true);
        ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(backUpIpFinder);

        Ignite ig = startGrid(name, cfg);

        nodes.put(name, ig);
    }
}

开发者ID:apache，项目名称:ignite，代码行数:22，代码来源:IgniteChangeGlobalStateAbstractTest.java

示例19: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration c = super.getConfiguration(igniteInstanceName);

    TcpDiscoverySpi disco = new TcpDiscoverySpi();

    disco.setIpFinder(ipFinder);

    c.setDiscoverySpi(disco);

    CacheConfiguration<?,?> ccfg = new CacheConfiguration<>(DEFAULT_CACHE_NAME);

    ccfg.setName("offheap-cache");
    ccfg.setCacheMode(CacheMode.PARTITIONED);
    ccfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
    ccfg.setIndexedTypes(
        Long.class, Person.class
    );

    c.setCacheConfiguration(ccfg);

    return c;
}

开发者ID:apache，项目名称:ignite，代码行数:24，代码来源:GridCacheQuerySimpleBenchmark.java

示例20: getConfiguration

import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
    IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);

    TcpDiscoverySpi spi = new TcpDiscoverySpi();

    spi.setIpFinder(IP_FINDER);

    cfg.setDiscoverySpi(spi);

    cfg.setCacheConfiguration();
    cfg.setMetricsUpdateFrequency(500);

    CacheConfiguration<Integer, Object> ccfg = defaultCacheConfiguration();
    ccfg.setName(CACHE_NAME);
    ccfg.setStatisticsEnabled(true);

    FifoEvictionPolicy plc = new FifoEvictionPolicy();
    plc.setMaxMemorySize(MAX_VALS_AMOUNT * VAL_SIZE);
    plc.setMaxSize(0);

    ccfg.setEvictionPolicy(plc);
    ccfg.setOnheapCacheEnabled(true);

    return cfg.setCacheConfiguration(ccfg);
}

开发者ID:apache，项目名称:ignite，代码行数:27，代码来源:ClusterNodeMetricsSelfTest.java

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