InfoQ

InfoQ

News

My Bookmarks

Login or Register to enable bookmarks for unlimited time.

The content has been bookmarked!

There was an error bookmarking this content! Please retry.

Reliable Messaging in Ruby with AP4R

Posted by Sebastien Auvray on Jun 18, 2007

Sections
Architecture & Design,
Development,
Enterprise Architecture
Topics
Ruby ,
Messaging
Tags
JMS ,
DRb ,
Ruby on Rails
Shun'ichi Shinohara and Kiwamu Kato have been  working on bringing reliable messging to Ruby with their own API & protocol project, based on previous experiences designing a Java-based high volume messaging framework.   AP4R, Asynchronous Processing for Ruby, is an implementation of reliable asynchronous message processing, providing message queuing and message dispatching.  Shun'ichi and Kiwamu gave a presentation at RubyKaigi 2007(pdf slides) about their API emphasizing it's key design philosophies: Robustness and Lightweight.

The project is just a year old, and already supports:
  1. Business logic can be implemented as simple Web apps or ruby code, whether it's called asynchronously or synchronously.
  2. RBMS (MySQL) or file-based message persistance
  3. Load balancing over multiple AP4R processes on single/multiple server(s) is supported.
  4. Multiple protocol support: XML-RPC, SOAP, HTTP POST, and more.
Shun'ichi and Kiwamu had previously implemented their own Java-based API and protocol (called RtFA), which was used in a large app with 100 servers processing over 100 million messages a day. Shun'ichi and Kiwamu claim to have improved upon their previous work with AP4R, while also focusing on on the ease of use. AP4R comes with a comprehensive documentation.

Integrated into rails, a typical process flow for using AP4R is:
  1. A client(e.g. a web browser) makes a request to a web server (Apache, Lighttpd, etc...).
  2. A rails application is synchronously executed on mongrel via mod_proxy or something.
  3. Rails app sends a message via AP4R APIs and can then immediatley respond to the client.
  4. AP4R queues the message and requests it to the web server asynchronously.
  5. The asynchronous business logic, implemented as usual rails action, is executed.
The focus for 0.3.x was Daemonization, URL-rewrite filter, DLQ / SAF recovery, and support for Stomp and HTTP has underlying protocols. Future versions will include support for Monitoring & management (e.g. thread status, web frontend), Coordination with Cacti, Nagios, etc, multi-process, Dynamic configurability, Automatic recovery, Blocking queues, and more.
Very cool by Andrew Kuklewicz Posted
  1. Back to top

    Very cool

    by Andrew Kuklewicz

    kudos to the ap4r folks, great to see this project coming along.

    Nice to see more messaging interest in rails - and the reliable messaging ruby lib + drb is a great way to get something going using good existing solutions.

    For an alternative, folks might also want to look at activemessaging
    Here's an intro on infoq about it

    Cheers,
    Andrew Kuklewicz

Educational Content

New-age Transactional Systems - Not Your Grandpa's OLTP

John Hugg discusses high volume transaction processing applications with high and low frequency profiles, and how VoltDB can be used for that purpose.

Cool Code

Kevlin Henney examines code samples to see what can be learned from them starting from the premise that one won’t write great code unless he knows how to read it.

Collaboration: At the Extremities of Extreme

Jason Ayers share the observations he made watching a team of developers collaborating in real time on the same code base, pushing XP, pair programming and continuous integration to their extremes.

Yesod Web Framework

Michael Snoyman presents Yesod, a web framework written in Haskell and containing a web server, templating, ORM, libraries (templating, gravatar, etc.).

Transactions without Transactions

Richard Kreuter and Kyle Banker on how to avoid classical RDBMS transactional systems by using compensation mechanisms, transactional messaging or transactional procedures.

Attila Szegedi on JVM and GC Performance Tuning at Twitter

Attila Szegedi talks about performance tuning Java and Scala programs at Twitter: how to approach GC problems, the importance of asynchronous I/O, when to use MySQL/Cassandra/Redis, and much more.

10 tips on how to prevent business value risk

One category of risk that project teams need to ensure they address is business value failure – delivering a product that fails to provide value for the business investor.

Interview: Software Systems Architecture: Working With Stakeholders Using Viewpoints and Perspectives

InfoQ spoke to the authors of Software Systems Architecture on a couple of new topics, the System Context viewpoint and Agile, which have been added to the second edition.