使用 NCache 将 Java 微服务扩展到极致性能

1
// Configure Hibernate properties programmatically
2
        Properties hibernateProperties = new Properties();
3
        hibernateProperties.put("hibernate.connection.driver_class", "org.h2.Driver");
4
        hibernateProperties.put("hibernate.connection.url", "jdbc:h2:mem:testdb");
5
        hibernateProperties.put("hibernate.show_sql", "false");
6
        hibernateProperties.put("hibernate.hbm2ddl.auto", "create-drop");
7
        hibernateProperties.put("hibernate.cache.use_query_cache", "true");
8
        hibernateProperties.put("hibernate.cache.use_second_level_cache", "true");
9
        hibernateProperties.put("hibernate.cache.region.factory_class", "org.hibernate.cache.jcache.internal.JCacheRegionFactory");
10
        hibernateProperties.put("hibernate.javax.cache.provider", "com.alachisoft.ncache.hibernate.jcache.HibernateNCacheCachingProvider");
11
        // Set other Hibernate properties as needed
12
        Configuration configuration = new Configuration()
13
                .setProperties(hibernateProperties).addAnnotatedClass(Product.class);
14


15
        Logger.getLogger("org.hibernate").setLevel(Level.OFF);
16


17
        // Build the ServiceRegistry
18
        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
19
                .applySettings(configuration.getProperties()).build();
20


21
        // Build the SessionFactory
22
        SessionFactory factory = configuration.buildSessionFactory(serviceRegistry);
23


24
        // Create a List of Product objects
25
        ArrayList<Product> products = (ArrayList<Product>) getProducts();
26
        // Open a new Hibernate session to save products to the database. This also caches it
27
        try (Session session = factory.openSession()) {
28
            Transaction transaction = session.beginTransaction();
29
            // save() method saves products to the database and caches it too
30
            System.out.println("ProductID, Name, Price, Category");
31
            for (Product product : products) {
32
                System.out.println("- " + product.getProductID() + ", " + product.getName() + ", " + product.getPrice() + ", " + product.getCategory());
33
                session.save(product);
34
            }
35
            transaction.commit();
36
            System.out.println();
37


38
        // Now open a new session to fetch products from the DB.
39
        // But, these products are actually fetched from the cache
40
        try (Session session = factory.openSession()) {
41
            List<Product> productList = (List<Product>) session.createQuery("from Product").list();
42
            if (productList != null) {
43
                printProductDetails(productList);
44
            }
45
        }
46

1
   // Create a Topic in NCache.
2
        MessagingService messagingService = cache.getMessagingService();
3
        Topic topic = messagingService.createTopic(topicName);
4


5
        // Create a thread pool for publishers
6
        ExecutorService publisherThreadPool = Executors.newFixedThreadPool(2);
7
 
8
 The below code snippet used to define register the subscribers to this topic 
9
     Register subscribers to this Topic
10
        MessageReceivedListener subscriptionListener1 = new MessageReceivedListener() {
11
            @Override
12
            public void onMessageReceived(Object o, MessageEventArgs messageEventArgs) {
13
                messageReceivedSubscription1(messageEventArgs.getMessage());
14
            }
15
        };
16
        MessageReceivedListener subscriptionListener2 = new MessageReceivedListener() {
17
            @Override
18
            public void onMessageReceived(Object o, MessageEventArgs messageEventArgs) {
19
                messageReceivedSubscription2(messageEventArgs.getMessage());
20
            }
21
        };
22
        TopicSubscription subscription1 = topic.createSubscription(subscriptionListener1);
23
        TopicSubscription subscription2 = topic.createSubscription(subscriptionListener2);
24

1
        String cacheName = "demoCache";
2
        // Connect to the cache and return a cache handle
3
        Cache cache = CacheManager.getCache(cacheName);
4
        // Adds all the products to the cache. This automatically creates indexes on various
5
        // attributes of Product object by using "Custom Attributes".
6
        addSampleData(cache);
7
        // $VALUE$ keyword means the entire object instead of individual attributes that are also possible
8
        String sql = "SELECT $VALUE$ FROM com.alachisoft.ncache.samples.Product WHERE category IN (?, ?) AND price < ?";
9
        QueryCommand sqlCommand = new QueryCommand(sql);
10
        List<String> catParamList = new ArrayList<>(Arrays.asList(("Electronics"), ("Stationery")));
11
        sqlCommand.getParameters().put("category", catParamList);
12
        sqlCommand.getParameters().put("price", 2000);
13


14
        // ExecuteReader returns ICacheReader with the query resultset
15
        CacheReader resultSet = cache.getSearchService().executeReader(sqlCommand);
16
        List<Product> fetchedProducts = new ArrayList<>();
17
        if (resultSet.getFieldCount() > 0) {
18
            while (resultSet.read()) {
19
                // getValue() with $VALUE$ keyword returns the entire object instead of just one column
20
                fetchedProducts.add(resultSet.getValue("$VALUE$", Product.class));
21
            }
22
        }
23
        printProducts(fetchedProducts);
24

1
 ReadThruOptions readThruOptions = new ReadThruOptions(ReadMode.ReadThru, _readThruProviderName);
2
 product = _cache.get(_productId, readThruOptions, Product.class);
3

1
_product = new Product();
2
    WriteThruOptions writeThruOptions = new WriteThruOptions(WriteMode.WriteThru, _writeThruProviderName)
3
  CacheItem cacheItem= new CacheItem(_customer)
4
 _cache.insert(_product.getProductID(), cacheItem, writeThruOptions);
5