ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ranbir Chawla <Ranbir.Cha...@audiencescience.com>
Subject Re: Cannot connect client to new Data Grid - newbie question
Date Sun, 29 Nov 2015 14:08:56 GMT
Here is the config passed to the ‘server’ nodes

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean class="org.apache.ignite.configuration.IgniteConfiguration">
  <property name="discoverySpi">
    <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
      <property name="ipFinder">
        <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder">
          <property name="awsCredentials" ref="aws.creds"/>
          <property name="clientConfiguration" ref="aws.conf"/>
          <property name="bucketName" value="asci-ignite-dev"/>
        </bean>
      </property>
      <property name="localAddress" value="LOCALIP"/> 
    </bean>
  </property>
  <property name="peerClassLoadingEnabled" value="false"/>
</bean>
<bean id="aws.conf" class="com.amazonaws.ClientConfiguration">
        <property name="proxyHost" value="dc1-utility01.dc01.revsci.net"/>
        <property name="proxyPort" value="3128"/>
</bean>


<!-- AWS credentials. Provide your access key ID and secret access key. -->
<bean id="aws.creds" class="com.amazonaws.auth.BasicAWSCredentials">
  <constructor-arg value=“obfuscated-key-val" />
  <constructor-arg value="/9RMACVMY7PDNliPxLqpbEJfRO/KyVIlqRHerYZZ" />
</bean>
</beans>





Here are the classes used to perform the Java based config within the client


// uses this proxy mode because the CacheStore needs to be serializable
@Bean
@Scope(proxyMode = ScopedProxyMode.TARGET_CLASS)
IgniteCacheStore igniteCacheStore() {
    return new IgniteCacheStore();
}

@Bean
public TSDBCacheConfiguration tsdbCacheConfiguration() {
    return new TSDBCacheConfiguration(igniteCacheStore());
}

@Bean
IgniteCache<String, String> igniteCache() {

    ClientConfiguration clientConfiguration = new ClientConfiguration();
    clientConfiguration.setProxyHost("dc1-utility01.dc01.revsci.net");
    clientConfiguration.setProxyPort(3128);

com.amazonaws.auth.BasicAWSCredentials awsCredentials = new com.amazonaws.auth.BasicAWSCredentials(“obfuscated-key-val","/9RMACVMY7PDNliPxLqpbEJfRO/KyVIlqRHerYZZ”);


    org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder ipFinder = new
org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder();

    ipFinder.setAwsCredentials(awsCredentials);
    ipFinder.setBucketName("asci-ignite-dev");
    ipFinder.setClientConfiguration(clientConfiguration);

    org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi tcpDiscoverySpi = new org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi();
    tcpDiscoverySpi.setIpFinder(ipFinder);

    TSDBCacheConfiguration tsdbCacheConfiguration = tsdbCacheConfiguration();

    IgniteConfiguration igniteConfiguration = tsdbCacheConfiguration.getIgniteConfiguration();
    igniteConfiguration.setClientMode(true);
    igniteConfiguration.setDiscoverySpi(tcpDiscoverySpi);

     CacheConfiguration cfg = tsdbCacheConfiguration.getCfg();
    cfg.setName("myCache");

    Ignite ignite = Ignition.start(igniteConfiguration);
    Ignition.setClientMode(true);
    
    // Create cache with given name, if it does not exist.
    IgniteCache<String, String> cache = ignite.getOrCreateCache(cfg);
    return cache;
}


The TSDBCacheConfiguration is used in the core library to allow us to test the IgniteCacheStore
so we reused it in the above config

public class TSDBCacheConfiguration {

    private CacheConfiguration cfg;

    //must be set the consuming application
//    @Autowired
//    TcpDiscoverySpi tcpDiscoverySpi;

    private IgniteConfiguration igniteConfiguration;

    public TSDBCacheConfiguration(IgniteCacheStore igniteCacheStore) {

        cfg = new org.apache.ignite.configuration.CacheConfiguration();
        cfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
        cfg.setBackups(1);
        cfg.setCacheStoreFactory(new FactoryBuilder.SingletonFactory<>(igniteCacheStore));

        cfg.setReadThrough(true);
        cfg.setWriteThrough(true);
        igniteConfiguration = new IgniteConfiguration();
        igniteConfiguration.setCacheConfiguration(cfg);

    }

    /**
     * without write behind persistence store
     */
    public TSDBCacheConfiguration() {

        cfg = new org.apache.ignite.configuration.CacheConfiguration();
        cfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
        cfg.setBackups(1);
        igniteConfiguration = new IgniteConfiguration();
        igniteConfiguration.setCacheConfiguration(cfg);

    }



    public IgniteConfiguration getIgniteConfiguration() {
        return igniteConfiguration;
    }

    public void setIgniteConfiguration(IgniteConfiguration igniteConfiguration) {
        this.igniteConfiguration = igniteConfiguration;
    }

    public CacheConfiguration getCfg() {
        return cfg;
    }

    public void setCfg(CacheConfiguration cfg) {
        this.cfg = cfg;
    }
}






Ranbir Chawla | V.P. Engineering
C: (303) 868-7797
F: (425) 328-1221
Ranbir.chawla@AudienceScience.com <mailto:Gerard.Hickey@AudienceScience.com> 
www.AudienceScience.com <http://www.audiencescience.com/>


1120 112th Avenue NE, Suite 400
Bellevue, WA 98004
 <http://twitter.com/@audiencescience> <http://www.facebook.com/AudienceScience>
<http://www.linkedin.com/companies/236049>

 <http://www.linkedin.com/companies/236049>








On 11/29/15, 1:08 AM, "vkulichenko" <valentin.kulichenko@gmail.com> wrote:

>Hi,
>
>Can you please attach your cache configuration? It will be easier to tell
>the reason of the error if we have it.
>
>-Val
>
>
>
>--
>View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Cannot-connect-client-to-new-Data-Grid-newbie-question-tp2080p2083.html
>Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Mime
View raw message