Getting setup to run the lab

presented by Pete
5 minutes

• Using Infinispan 5.1.0.FINAL

• Download the lab zip from

  [...]

• Unzip the lab to your disk to a location of your choice

• If you are a git user, you can clone the repository:

git clone git://github.com/infinispan/infinispan-labs.git

• each stage of this lab has a checkpoint which is a branch, you can check out the code for each Checkpoint using. Checkpoints are mentioned in these instructions:

git checkout -b checkpointX checkpointX

• Download JBoss AS 7.1.0.CR1b from http://jboss.org/jbossas/downloads

• Unzip JBoss AS to your disk to a location of your choice

Use cases, key features and benefits of Infinispan

slides, presented by Pete
20 minutes

Explanation of sample project architecture

presented by Pete
5 minutes

• The lab is a simple ticket allocation and booking system

• lab1 contains a project skeleton with the relevant dependencies available. It is a war, that can be deployed on JBoss AS 7. It also use CDI to wire together the app, and JSF for the view layer. JMS is used to provide messaging and EJB to provide a listener for messages we send via JMS.

• In another console, start JBoss AS - $JBOSS_HOME/bin/standalone.sh

• Deploy the project to JBoss AS 7 using mvn clean package jboss-as:deploy

• visit http://localhost:8080/lab1

• All cache operations hidden by service layer to allow us to swap out caching impls

• Starts with a HashMap and builds on that

• Import the project into your IDE, we use Eclipse with m2eclipse installed.

• Show project

Checkpoint 1

107 (JCACHE) and JSR-347 (Datagrids for Java)

presented by Pete
5 minutes

Topics covered include:

• TODO

Make sure your nodes can see each other

• In LAB_HOME/nic_test there is the the test-network script. Run it.

• If all goes well, you'll get two windows in which you can draw up on your screen. Draw on one, see it in both.

How does JGroups work? Why do you need it?

Topics covered include:

• what is JGroups? library for reliable multicasting ...

• main features: fragmentation, retransmission, flow control, reordering, group membership (notifications)

• LAN/WAN based: multicast or TCP for transport

Adding Infinispan to the demo

Use Case: Take advantage of the features of Infinispan

• Uncomment the Infinispan dependencies in pom.xml

• Copy in Resources.java and TicketAllocationCache.java and explain what they are doing; you will find them in LAB_HOME/lab1/src/samples/java

• Explain about configuring caches programmatically with qualifier

• Copy SimpleTicketService to InfinispanTicketService

• Make SimpleTicketService an alternative

private final List<TicketAllocation> tickets = new ArrayList<TicketAllocation>();

with

@Inject @TicketAllocationCache
private Cache<String, TicketAllocation> tickets;

to inject the Infinispan cache. Change the allocateTicket method to:

TicketAllocation allocation = new TicketAllocation(allocatedTo, event);
tickets.put(allocation.getId(), allocation);

and change the getAllocatedTickets() method to

return new ArrayList<TicketAllocation>(tickets.values());

and change the getTicketAllocation(String id) method to:

return tickets.get(id);

Implement getNodeId() properly:

if (tickets.getConfiguration().getCacheMode() != CacheMode.LOCAL)
   return tickets.getAdvancedCache().getCacheManager().getAddress().toString();
else
   return "local cache";

Implement getOwners() properly:

if (tickets.getConfiguration().getCacheMode() != CacheMode.LOCAL) {
   return asCommaSeparatedList(tickets.getAdvancedCache().getDistributionManager().locate(key));
} else {
   return "local";
}

Show Infinispan in use with basic monitoring

Use Case: Can see how our cache is performing

• Enable JMX - add .jmxStatistics().enable() to the fluent configuration in Resources.

• Redeploy, and use the app

• We can see the cache starting in the console

• Run jconsole or jvisualvm, and select the "jboss-modules" process

• Open up the Infinispan statistics (via MBeans tab in jvisualvm - you might need to install the MBeans plugin first)

• Allocate a ticket, show the stores change

Checkpoint 2

Interlude - What is expiration? What is eviction?

Topics covered include:

• API

• Configuration

• Use cases

• Available eviction mechanisms

Demo

• Use Case: Have ticket allocations freed up after a period of time*

• Add expiration to allocateTicket(), so you end up with

tickets.put(allocation.getId(), allocation, 10, TimeUnit.SECONDS);

• Run the demo, and you can see that entries disappear after 10s

Checkpoint 3

Interlude. What can you listen to in Infinispan?

Transactions in action

Use Case: When ticket is booked, need to atomically take payment and book ticket, and rollback if any errors

• The webapp collects all the data from the user to process the booking, and then sends the booking to the backend using JMS.

• JBoss comes with a "test" queue, we'll abuse that so we don't have to configure messaging (not what we are here to talk about).

• Go to the pom.xml and uncomment JMS dependency

• Copy the PaymentProcessor into .services

• Inject JMS into InfinispanTicketService

@Resource(mappedName="/ConnectionFactory")
private ConnectionFactory cf;

@Resource(mappedName = "queue/test")
private Queue queue;

• Implement the bookTicket method

try {
       Connection connection = cf.createConnection();
       Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
       MessageProducer publisher = session.createProducer(queue);
       connection.start();
       TextMessage message = session.createTextMessage("Book ticket for " + id);
       publisher.send(message);
       connection.close();
       session.close();
    } catch (JMSException e) {
       throw new RuntimeException(e);
    }

This code is in bookTicket.txt in the samples

• Run the example, show it in action.

Checkpoint 5a

Use case: Introduce XA transactions

• Add to the configuration (Resources.configureCache):

.transaction().transactionMode(TransactionMode.TRANSACTIONAL)
.transaction().transactionManagerLookup(new GenericTransactionManagerLookup())

• Replace the injection of the Connection Factory with

@Resource(mappedName="/JmsXA")
private XAConnectionFactory cf;

@Resource(mappedName = "java:jboss/TransactionManager")
private TransactionManager tm;

finally, upgrade the bookTicket method:

try {
   XAConnection connection = null;
   try {
      connection = cf.createXAConnection();
      connection.start();

      XASession xaSession = connection.createXASession();

      Session session = xaSession.getSession();
      MessageProducer publisher = session.createProducer(queue);

      TextMessage message = session.createTextMessage("Book ticket for " + id);

      tm.begin();

      tm.getTransaction().enlistResource(xaSession.getXAResource());

      //following two ops need to be atomic (XA)
      tickets.remove(id);
      publisher.send(message);

      tm.commit();
   } finally {
      if (connection != null) connection.close();
   }
} catch (Throwable e) {
   // ignore - don't do this at home :)
   e.printStackTrace();
}

• Interlude - Transactions deep dive

Topics discussed include

• Transaction types

• Locking

• Deadlock detection

Show the cache running in distributed mode

• Start up 4 JBoss AS 7 nodes with domain.sh. Why? See the JBoss 7 Getting Started guide

• Build latest using mvn package and in another terminal change into the project and bring up JBoss AS CLI $JBOSS_HOME/bin/jboss-admin.sh --connect

• Deploy app from console using deploy target/lab1.war --server-groups=main-server-group

• App now deployed to each node

• bring up all 4 nodes in a web browser (port offset 100)

• show each node starting in the console log

• the contents list now just shows whats locally in the cache

• explain that as each node comes up, the entries are rehashed to distribute the contents, so we see entries disappear from a node

• show that we can still find any entry, it's just not local any more

• show that we can put an entry, and then find it in one of the caches in Infinispan (10 mins)

Interlude - What modes can Infinispan run in? When would you want to use them?

Topics discussed include:

• What are the different modes?

• When would you use the modes?

• How does distribution work?

• Explain CH, benefits and problems

• Talk about vnodes to even distribution

Interlude - what client-server modes does Infinispan offer?

Topics discussed include:

• various server endpoints

• benefits of Hot Rod

Interlude - What Cache Stores are available? In what scenarios can they be used?

Topics discussed include:

• Modes of cache store usage

• CacheStores available as built in

Querying Infinispan

presented by Sanne
8 minutes

Topics discussed include:

• TODO

Hibernate OGM

presented by Sanne
2 minutes

Topics discussed include:

• TODO

Reduce

presented by Pete
5 minutes

Topics discussed include:

• TODO

Benchmarking data girds - Radargun

Introducing project Radargun

presented by Mircea
5 minutes