Rails goes SOA

Rails goes SOARails-Konferenz 2009 – Frankfurt/Offenbach

Dirk Breuer – pkw.de

02. September 2009

View

Model(enthält Business Logik + Daten)

Controller (nur lesend)

View

Model(enthält Business Logik)

Controller

BusinessLogik

(nur lesend)

View

Model(Datenhaltung)

Controller(nur lesend)Business

Logikextract

Vorteile der Transformation

Entwickler erhalten Kontrolle über Source Code zurück

Bessere Verständlichkeit für die Fachseite

Grafik © by Martin Laksman, 2003

Vorteile der Transformation

Entwickler erhalten Kontrolle über Source Code zurück

Bessere Verständlichkeit für die Fachseite

Bessere Time-to-Market

Grafik © by Martin Laksman, 2003

Service-Orientierte Architekturen

View

Model(Datenhaltung)

Controller(nur lesend)Services

(enthalten Business Logik)

How To SOA?

Fahrzeuge Suchen

Fahrzeuge fürdie Startseite

anzeigen

Suchauftrag fürSuche anlegen

Benutzerauthentifizieren

Statistiken fürein Fahrzeug

anzeigen

Statistiken fürein Fahrzeug

anzeigen

StatistikenSchreiben

get_startpage_carsget_startpage_dealerget_startpage_teasersearch_carscreate_temporary_customercreate_temporary_carsave_temporary_customersave_temporary_carauthenticate_customeradd_image_to_cargenerate_captchaverify_captchaaccept_customerpublish_carnotify_customer_about_published_car

get_statistics_of_carget_number_of_cars_of_customerget_cars_of_customerget_number_of_car_imagesget_car_imagesdelete_cardelete_customerget_search_orders_of_customerdelete_search_ordersearch_cars_by_search_orderauthenticate_customerauthenticate_dealergenerate_passwordsend_new_password…

Vorteile von SOA

Services werden von Fachseite gefunden

Fachseite versteht IT besser

Fachseite versteht Komplexität besser

Fachliche Sicht sehr langlebig, dadurch Services sehr langlebig

Vorteile von SOA

Services werden von Fachseite gefunden

Fachseite versteht IT besser

Fachseite versteht Komplexität besser

Fachliche Sicht sehr langlebig, dadurch Services sehr langlebig

Langlebigkeit ...?

Gra

fik ©

by

Mar

tin L

aksm

an, 2

003

Langlebigkeit der Datenbank?

Änderung von Spalten

Änderung des CRM-Systems

Anbindung an SAP

Zusammenlegung von StartUps

Langlebigkeit der GUI?

Änderung der Anordnung von Elementen

Änderung von Dialogen

Änderung von Texten

Redesign der gesamten Plattform

Langlebigkeit von Services

Fachseite definiert Geschäftsprozesse

Fahrzeuge suchen

Benutzer authentifizieren

Statistiken schreiben

Änderungen auf dieser Ebene sehr viel unwahrscheinlicher

Und was genau ist ein Service Jetzt?!

Grafik © by Martin Laksman, 2003

Ein Service ist …

… technologie- und plattformunabhängig

… dynamische lokalisier- und ausführbar

… in sich abgeschlossen

… durch eine wohl-definierte und formale Schnittstelle beschrieben

… stateless

Dienstbeschreibungveröffentlichen

Dienstimplementierungbinden

Dienstbeschreibungfinden

Service Registry

Service Provider

Service Client

Basic SOA

Aber kosten diese SOA Lösungen von IBM & Co nicht

sehr viel Geld?

Grafik © by Martin Laksman, 2003

Ja ...

Aber kosten diese SOA Lösungen von IBM & Co nicht

sehr viel Geld?

Grafik © by Martin Laksman, 2003

Das können wir uns nicht leisten!

Ja ...

Aber kosten diese SOA Lösungen von IBM & Co nicht

sehr viel Geld?

Grafik © by Martin Laksman, 2003

SOA ist doch nur ein Konzept. Das können

wir auch selbst umsetzen.

Grafik © by Martin Laksman, 2003

SOA ist doch nur ein Konzept. Das können

wir auch selbst umsetzen.

Und zwar passendfür uns!

Grafik © by Martin Laksman, 2003

+ SOA

class SearchService

def self.search_cars(search_criteria) # Calling the Car class which is just # a ActiveRecord::Base subclass end

end

found_cars = SearchService.search_cars(some_criteria)

class SearchService

def self.search_cars(search_criteria) # Calling the Car class which is just # a ActiveRecord::Base subclass end

end

found_cars = SearchService.search_cars(some_criteria)

Aber moment, das sieht

class Car < ActiveRecord::Base

def self.search(criteria) find(:all, :conditition => criteria) end

end

found_cars = Car.search(params[:criteria])

class Car < ActiveRecord::Base

def self.search(criteria) find(:all, :conditition => criteria) end

end

found_cars = Car.search(params[:criteria])Aber ...

Echte Businesslogik ist in der Regel deutlich komplexer

Bisher: ActiveRecord::Base = Businesslogik + Daten

Jetzt: ActiveRecord::Base = Daten, Service = Businesslogik

Echte Businesslogik ist in der Regel deutlich komplexer

Bisher: ActiveRecord::Base = Businesslogik + Daten

Jetzt: ActiveRecord::Base = Daten, Service = Businesslogik

inkl. einfacher Validierung etc.

Verteilung

Statistic Service

Such Service

SuchauftragService

AuthentifizierungsService

RailsFrontend

Verteilung

Statistic Service

Such Service

SuchauftragService

AuthentifizierungsService

RailsFrontend

?

?

?

Verteilung

Statistic Service

Such Service

SuchauftragService

AuthentifizierungsService

RailsFrontend

?

?

?Thrift-RPC

Thrift-RPC?!?

Grafik © by Martin Laksman, 2003

Thrift-RPC

RPC-Framework von Facebook entwickelt

Mittlerweile Apache Incubator Projekt: http://incubator.apache.org/thrift/

Ziel: Verlässliche und effiziente Kommunikation verteilter Systemkomponenten

Thrift-Architektur

Transport

Protocol

Processor

Service-Implementierung

Thrift-Architektur

Transport

Protocol

Processor

Service-Implementierung

Thrift-Compiler

Thrift-Gem

Thrift ServiceDefinitionerstellen

Thrift ServiceDefinitionerstellen

Service Stubsgenerieren

Thrift ServiceDefinitionerstellen

Service Stubsgenerieren

Serviceimplementieren

Thrift ServiceDefinitionerstellen

Transport-Schicht

realisierenService Stubsgenerieren

Serviceimplementieren

Thrift ServiceDefinitionerstellen

Transport-Schicht

realisierenService Stubsgenerieren

Serviceimplementieren

Serviceansprechen

Thrift ServiceDefinitionerstellen

Transport-Schicht

realisierenService Stubsgenerieren

Serviceimplementieren

Serviceansprechen

Thrift Service-Definition

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespacesnamespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespaces

✓Enums

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespaces

✓Enums

✓Primitive Datentypen

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespaces

✓Enums

✓Primitive Datentypen

✓Komplexe Typen

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespaces

✓Enums

✓Primitive Datentypen

✓Komplexe Typen

✓Exceptions

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Thrift Service-Definition

✓Namespaces

✓Enums

✓Primitive Datentypen

✓Komplexe Typen

✓Exceptions

✓Services

namespace rb UserService

enum UserStates { VERIFIED = 1, UNVERIFIED = 2, BLOCKED = 3}

struct User { 1: string firstname, 2: string lastname, 3: i32 age, 4: string email, 5: string username, 6: UserStates state}

exception AuthenticationError { 1: string message, 2: list<string> backtrace}

service AuthenticationService { User authenticate_user(1:string username, 2:string password)throws (1:AuthenticationError ae)}

Walkthrough: Statistik-Service

namespace rb Pkwde.StatisticsModule

struct Statistic { 1:string name, 2:i32 count}

service StatisticsService { list<Statistic> statistic_for(1:list<string> element_names), oneway void increment(1:list<string> elements)}

$> thrift --gen rb:rails -o ./app/thrift config/statistics_service.thrift

app/thrift`-- gen-rb `-- pkwde `-- statistics_module |-- statistics_service.rb |-- statistics_service_constants.rb `-- statistics_service_types.rb

class StatisticsHandler def statistic_for(element_names) Statistic.find_all_by_name(element_names).map do |statistic| Pkwde::StatisticsModule::Statistic.new(:name => statistic.name, :count => statistic.count) end end def increment(elements) elements.each do |element| Statistic.find_or_create_by_name(element).increment!(:count) end end end

require 'thrift/server/rack_middleware'

ActionController::Dispatcher.middleware.insert_before(Rails::Rack::Metal, Thrift::RackMiddleware, { :processor => Pkwde::StatisticsModule::StatisticsService::Processor.new(StatisticsHandler.new), :hook_path => "/statistics" })

Service Provider

StatisticsHandler.new

require 'thrift/server/rack_middleware'

ActionController::Dispatcher.middleware.insert_before(Rails::Rack::Metal, Thrift::RackMiddleware, { :processor => Pkwde::StatisticsModule::StatisticsService::Processor.new(StatisticsHandler.new), :hook_path => "/statistics" })

Service Provider

StatisticsHandler.new

require 'thrift/server/rack_middleware'

ActionController::Dispatcher.middleware.insert_before(Rails::Rack::Metal, Thrift::RackMiddleware, { :processor => Pkwde::StatisticsModule::StatisticsService::Processor.new(StatisticsHandler.new), :hook_path => "/statistics" })

statistics_client = ThriftClient.new(:url => "http://localhost:3000/statistics", :client_class => Pkwde::StatisticsModule::StatisticsService::Client)

Service Provider

Service Client

StatisticsHandler.new

require 'thrift/server/rack_middleware'

ActionController::Dispatcher.middleware.insert_before(Rails::Rack::Metal, Thrift::RackMiddleware, { :processor => Pkwde::StatisticsModule::StatisticsService::Processor.new(StatisticsHandler.new), :hook_path => "/statistics" })

statistics_client = ThriftClient.new(:url => "http://localhost:3000/statistics", :client_class => Pkwde::StatisticsModule::StatisticsService::Client)

Service Provider

Service Client

http://github.com/railsbros/thrift4rails

http://github.com/railsbros/thrift

StatisticsHandler.new

Was ist Eigentlich mit einer Lösung die mehr

Ruby ist …?

Grafik © by Martin Laksman, 2003

Hoth::Services.define do service :increment_statistics, :params => [[:element]], :returns => nil, :endpoint => :statistics_module service :statistic_for, :params => [[:element_name]], :returns => [:statistic], :endpoint => :statistics_module end

Sneak Preview

Service-Definition

Hoth::ServiceDeployment.define do service_module :statistics_module do env :test, { :endpoint => Hoth::Endpoint.new(:host => 'localhost', :port => 3000), :mongrel_servers => 2, :mongrel_start_port => 9001 }

path "services/search_service" endend

Sneak Preview

Deployment-Definition

ENV["LOCAL"] = "false"

require 'hoth'require 'deployment_definition'require 'service_definition'

Hoth::Services.increment_statistics([statistic_object], event)Hoth::Services.statistic_of_cars([23]).inspect

Sneak Preview

Service-Client

ENV["LOCAL"] = "true"

require 'hoth'require 'deployment_definition'require 'service_definition'

class IncrementStatisticsImpl def self.execute(elements) elements.each do |element| Statistic.find_or_create_by_name(element).increment!(:count) end endend

class StatisticForImpl def self.execute(element_names) Statistic.find_all_by_name(element_names) endend

app = lambda {|env| [200, {'Content-Type' => 'text/plain'}, ""]}run Hoth::ServiceProvider.new(app)

Service-Provider

About Me …

Rubyist und Rails-Enthusiast seit Ende 2005

Software-Entwickler bei pkw.de seit 2007

Twitter: @railsbros_dirk

GitHub: http://github.com/pkwde

Blog: http://railsbros.de

Kann ich das gleiche nicht durch ein

gutes OO-Design realisieren?

Grafik © by Martin Laksman, 2003

SOA vs. OOP

SOA ersetzt OOP nicht!

SOA setzt auf einer anderen Ebene an

OOP Design Prinzipien finden jedoch keine Anwendung für SOA

Fokus auf die Abbildung von Geschäftsprozessen

Ein Service kann intern immer noch OOP sein