jruby and torquebox

Christopher Spring

+ =

Thursday 07 February 13

@autonomous

[email protected]


mailto:[email protected]

mailto:[email protected]

“Java is a DSL for converting large XML files into Stack Traces”

@ davetron5000


... and that’s all I have to say about that


Structure


BytecodeJIT

JavaInteg

CoreClassesParser

jRuby

C APINative

JITGCThreads

JVM

Charles Nutter - Euroko2012Thursday 07 February 13

BytecodeJIT

JavaInteg

CoreClassesParser

jRuby


“We could stop working on jRuby and it would continue to get faster.”


Performance


require 'benchmark'

def fib(n) return 1 if n < 2 fib(n - 2) + fib(n - 1)end

arr = []puts Benchmark.measure{ 40.times{ |i| arr << fib(i) }}puts arr.inspect# [1, 1, 2, 3, 5, 8, 13, 21, ... ]


0

15

30

45

60

Time in seconds

52.8


0

15

30

45

60

Time in seconds

52.8

10.4


0

15

30

45

60

Time in seconds

52.8

10.4

REE - 183.8


get '/' do 1_000.times do MultiJson.encode({ one: 'one', date: Date.today, two: 2 }) endend

# ruby jsonator.rb -s Puma


ab -n 1000 -c 32 http://localhost:4567/


http://localhost:4567

http://localhost:4567

0

7,5

15

22,5

30

Time in seconds

24.946


0

7,5

15

22,5

30

Time in seconds

24.946

8.489


0

7,5

15

22,5

30

Time in seconds

24.946

2.892

8.489


Runtime optimizations


method_one method_two method_three


Threading


vs.


• No GIL

• Native threads

• One process for all cores


Concurrency threshold

100 process system

100 thread system

vs.


Java Libraries


<html><head> <style type="text/css"> body{ font-family: sans-serif; text-align: center; background-color: #efefef; } h1{ color: blue; font-weight: bold;} div{ border: 4px dashed red; padding: 2em;margin: 2em; } </style> </head> <body> <h1>PDFs with Flying Saucer and jRuby</h1> <div> <p>I'm a lumberjack, and I'm ok...</p> <img src="flower.jpeg"></img> </div> </body></html>


require 'stringio'require 'itext'require 'flying_saucer'

io = StringIO.newcontent = File.read('example.html')

renderer = org.xhtmlrenderer.pdf.ITextRenderer.newrenderer.set_document_from_string(content)renderer.layoutrenderer.create_pdf(io.to_outputstream)

File.write('pdf_result.pdf', io.string)


html


pdf


A loads more....!!!

• Choice of GC

• Cross platform

• GUI apps

• Great tooling

• Massive ecosystem


Let’s take a step back...


Your App


Your App

BackgroundJobs


Your App

BackgroundJobs

ScheduledJobs


Your App

BackgroundJobs

ScheduledJobs

Cron


TorqueBox


TorqueBox

App1

App2

App3


TorqueBox

App1App2App3

BackgroundTasks

ScheduledTasks

Long runningservices

Async. Messages


TorqueBox

App1App2App3

BackgroundTasks

ScheduledTasks

Long runningservices

Async. Messages

JBoss AS

Clustering Load balancing High availability


Some of the toys...

• HornetQ

• Infinispan

• Quartz Scheduler


It’s still justbusiness as usual


AsynchronousStuffs


class Charge < ActiveRecord::Base # id :integer not null, primary key # cents :integer default(0) # state :string(255) default("pending")end


class ChargesController < ActionController::Base include TorqueBox::Injectors def create @charge = Charge.create( params[:charge] ) msg = 'Slaves turtles doing thy bidding' redirect_to( charges_url, notice: msg ) endend

fetch('/queue/charges').publish( @charge.id )


class ChargesController < ActionController::Base include TorqueBox::Injectors def create @charge = Charge.create( params[:charge] ) msg = 'Slaves turtles doing thy bidding' redirect_to( charges_url, notice: msg ) endend


'/queue/charges' ChargeProcessor



# config/torquebox.rbTorqueBox.configure do

queue '/queue/charges' do processor ChargeProcessor end

end


# app/processors/charge_processor.rbclass ChargeProcessor < TorqueBox::Messaging::MessageProcessor def on_message( charge_id ) # ... end def on_error( exception ) # optionally deal with exception # ... endend


# app/processors/charge_processor.rbclass ChargeProcessor < TorqueBox::Messaging::MessageProcessor def on_message( charge_id ) @charge = Charge.find( charge_id ) result = PaymentGateway.process( @charge ) generate_receipt if result.success? broadcast_status end

end



end

def generate_receipt fetch('queue/receipts').publish( @charge.id ) end



end

def generate_receipt fetch('queue/receipts').publish( @charge.id ) end

def broadcast_status fetch('topics/charge_status').publish( @charge.id )end


Queue

Topic

Processor

Processor

Processor

Processor


# config/torquebox.rbTorqueBox.configure do queue '/queue/charges' do # processors/charge_processor.rb processor ChargeProcessor end topic '/topic/charge_status' do processor StatusProcessor processor TesterProcessor processor AlertAdminProcessor endend


And WebSockets?


Hells yes!!


Topic/Queue

Processor

Stomplet

Client


Topic/Queue

Processor

Stomplet

Client

‘/stomp/statuses’


Topic/Queue

Processor

Stomplet

Client

‘/stomp/statuses’‘/topics/charge_status’


# config/torquebox.rbstomplet ChargeStatusStomplet do route '/stomp/status'end


# app/stomplets/charge_status_stompletclass ChargeStatusStomplet < TorqueBox::Stomp::JmsStomplet def on_subscribe( client ) topic = destination_for('/topics/charge_status', :topic) subscribe_to( client , topic ) end # configure(config) # destroy() # on_subscribe(subscriber) # on_unsubscribe(subscriber) # on_message(message)end


javascript_include_tag '/stilts-stomp'


Thanks for Listening!


Questions?


jruby and torquebox

Technology