Posts
QBit is a microservice framework and queuing system.
You can easily expose services via JSON/WebSocket or JSON/REST.
You can also create high-speed, in-memory, in-proc services that can be used internally.
This example shows how to create in-process services.
To learn more about QBit after you read the example here are some links:
https://github.com/advantageous/qbit/wiki
http://rick-hightower.blogspot.com/2015/01/high-speed-soa.html
http://rick-hightower.blogspot.com/2015/01/quick-start-qbit-programming.html
http://rick-hightower.blogspot.com/2014/12/rise-of-machines-writing-high-speed.html
http://rick-hightower.blogspot.com/2015/01/high-speed-soa.html
http://rick-hightower.blogspot.com/2015/01/quick-start-qbit-programming.html
http://rick-hightower.blogspot.com/2014/12/rise-of-machines-writing-high-speed.html
Here is the inproc example.
package io.advantageous.qbit.example.inproc;
import io.advantageous.qbit.service.Callback;
import io.advantageous.qbit.service.Service;
import org.boon.core.Sys;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import static io.advantageous.qbit.queue.QueueBuilder.queueBuilder;
import static io.advantageous.qbit.service.ServiceBuilder.serviceBuilder;
/**
* Created by rhightower on 1/30/15.
*/
public class InProcExample {
public static void main(String... args) throws Exception {
example1(args);
example2(args);
}
/**
* You can use services in process
*/
public static void example1(String... args) throws Exception {
/* Synchronous service. */
final TodoManager todoManagerImpl = new TodoManager();
/*
Create the service which manages async calls to todoManagerImpl.
*/
final Service service = serviceBuilder()
.setServiceObject(todoManagerImpl)
.build();
/* Create Asynchronous proxy over Synchronous service. */
final TodoManagerClientInterface todoManager = service.createProxy(TodoManagerClientInterface.class);
service.startCallBackHandler();
System.out.println("This is an async call");
/* Asynchronous method call. */
todoManager.add(new Todo("Call Mom", "Give Mom a call"));
AtomicInteger countTracker = new AtomicInteger(); //Hold count from async call to service
System.out.println( "This is an async call to count" );
todoManager.count(count -> {
System.out.println( "This lambda expression is the callback " + count);
countTracker.set(count);
});
todoManager.clientProxyFlush(); //Flush all methods. It batches calls.
Sys.sleep(100);
System.out.printf("This is the count back from the server %d\n", countTracker.get());
System.out.printf("END EXAMPLE 1\n", countTracker.get());
System.out.printf("END EXAMPLE 1\n", countTracker.get());
System.out.printf("END EXAMPLE 1\n", countTracker.get());
System.out.printf("END EXAMPLE 1\n", countTracker.get());
}
/**
* You can use services in process
*/
public static void example2(String... args) throws Exception {
/* Synchronous service. */
final TodoManager todoManagerImpl = new TodoManager();
/*
Create the service which manages async calls to todoManagerImpl.
You can control the batch size of methods.
After it hits so many, it sends those methods to the service.
This allows threads to handle many method calls with on access of the queue.
Here we set it to 1 so it will flush with every call.
Setting invoke dynamic false turns off auto type conversion which is mainly for JSON REST calls
and WebSocket calls.
This means that you can execute the service more efficiently when it is in proc.
*/
final Service service = serviceBuilder()
.setQueueBuilder(queueBuilder().setBatchSize(1))
.setServiceObject(todoManagerImpl).setInvokeDynamic(false)
.build();
/* Create Asynchronous proxy over Synchronous service. */
final TodoManagerClientInterface todoManager = service.createProxy(TodoManagerClientInterface.class);
service.startCallBackHandler();
System.out.println("This is an async call");
/* Asynchronous method call. */
todoManager.add(new Todo("Call Mom", "Give Mom a call"));
AtomicInteger countTracker = new AtomicInteger(); //Hold count from async call to service
System.out.println( "This is an async call to count" );
todoManager.count(count -> {
System.out.println( "This lambda expression is the callback " + count);
countTracker.set(count);
});
/*
We don't need this now.
*/
//todoManager.clientProxyFlush(); //Flush all methods. It batches calls.
Sys.sleep(100);
System.out.printf("This is the count back from the service %d\n", countTracker.get());
todoManager.list(todos -> {
todos.forEach( item -> System.out.println(item) );
});
}
/**
* Example service class
*/
public static class TodoManager {
private List<Todo> list = new ArrayList<>();
public void add(Todo todo) {
System.out.println( "Add Todo" );
list.add(todo);
}
public List<Todo> list() {
System.out.println( "List Todo" );
return new ArrayList<>(list);
}
public int count() {
System.out.println( "Count Todo" );
return list.size();
}
}
interface TodoManagerClientInterface {
void add(Todo todo);
void list(Callback<List<Todo>> list);
void count(Callback<Integer> count);
void clientProxyFlush();
}
public static class Todo {
private final String name;
private final String description;
public Todo(String name, String description) {
this.name = name;
this.description = description;
}
public String getName() {
return name;
}
public String getDescription() {
return description;
}
@Override
public String toString() {
return "Todo{" +
"name='" + name + '\'' +
", description='" + description + '\'' +
'}';
}
}
}
Learn more about QBit:
[Detailed Tutorial] QBit microservice example[Doc] Queue Callbacks for QBit queue based services
[Quick Start] Building a simple Rest web microservice server with QBit
[Quick Start] Building a TODO web microservice client with QBit
[Quick Start] Building a TODO web microservice server with QBit
[Quick Start] Building boon for the QBit microservice engine
[Quick Start] Building QBit the microservice lib for Java
[Rough Cut] Delivering up Single Page Applications from QBit Java JSON Microservice lib
[Rough Cut] Working with event bus for QBit the microservice engine
[Rough Cut] Working with inproc MicroServices
[Rough Cut] Working with private event bus for inproc microservices
[Rough Cut] Working with strongly typed event bus proxies for QBit Java Microservice lib
[Rough Cut] Working with System Manager for QBit Mircoservice lib
[Z Notebook] More benchmarking internal
[Z Notebook] Performance testing for REST
[Z Notebook] Roadmap
Home
Introduction to QBit
Local Service Proxies
QBit Boon New Wave of JSON HTTP and Websocket
QBit Docs
[Detailed Tutorial] QBit microservice example
No comments:
Post a Comment