Sur d’autres sites (2912)

• Matomo analytics for wordpress

  15 octobre 2019, par Matomo Core Team — Community
  Self-hosting web analytics got a whole lot easier ! Introducing Matomo for WordPress

  Be the first to try it out ! Your feedback is much needed and appreciated

  Get a fully functioning Matomo (which is comparable to Google Analytics) in seconds ! How ? With the new Matomo Analytics for WordPress plugin. 

  Web analytics in WordPress has never been easier to get, or more powerful. Matomo Analytics for WordPress is the one-stop problem solver. It’ll save you time, money and give you the insights to help your website or business succeed. 

  Best of all, we get to further the goal of decentralising the internet. Our hope is for Matomo Analytics for WordPress to spread far and wide. We’re so excited that more and more people can now get their hands on this powerful, free, open-source analytics platform, in a few clicks !

  Download now and check it out !

  Get Matomo for WordPress

  What do you get ?

  • No more signing up to third party analytics service (like Google)
  • No more sending away your valuable data to a third party service (like Google)
  • Easy setup – install with a few clicks, no tracking code installation or developer knowledge needed
  • 100% accurate data – no data sampling and no data limits 
  • Full data ownership – all data is stored on your servers and no one else can see your data
  • Privacy protection / GDPR compliance
  • Ecommerce tracking out-of-the-box (Woocommerce, Easy Digital Downloads, and MemberPress) and we’re keen to add many more over time
  • Powerful features – segmenting, comparing reports, different visualisations, real-time reports, visit logs and visitor profiles, Matomo Tag Manager, dashboards, data export, APIs, and many more
  • Compared to other WordPress solutions we don’t charge you extra for basic features that should work out-of-the-box
  • Just like Matomo On-Premise, Matomo Analytics for WordPress is free

  We need your feedback !

  We all know and love the versatility of WordPress – with over 55,000 plugins and all the different ways of hosting it. However, with this great versatility comes the potential for things to be missed, so we’re keen to hear your feedback.

  • Is our plugin breaking anything on your WordPress, or, not compatible with something ? Please create an issue on our repository.
  • Is something not working ? If so, what ? Please create an issue on our repository.
  • How does running Matomo impact the performance of your WordPress server ? Also, if you have any other feedback for us – whether good or bad – please email us at wordpress@matomo.org. We’d love to hear what you think !
  • Can you perform a security review of the plugin ? Security issues are best reported to security@matomo.org
  • Do you have any questions ? Questions are best asked in our forum

  Thank you ! We really appreciate your help on this ❤️

  How do you get Matomo Analytics for WordPress ?

  Get Matomo for WordPress

  Log in to your WordPress and go to “Plugins => Add New”, search for “Matomo Analytics – Ethical Stats. Powerful Insights”, click on “Install” and then “Activate”.

  All you need is at least WordPress 4.8 and PHP 7.0 or later. MySQL 5.1+ is recommended. 

  The source code is available at : https://github.com/matomo-org/wp-matomo/. 
  

  In perfect harmony : Matomo and WordPress

  

  The idea for this started two years ago when we realised the similarities between the Matomo and WordPress project. 

  Not only from a technological point of view – where both are based on PHP and MySQL and can be extended using plugins – but also from a philosophical, license and values point of view. We both believe in privacy, security, data ownership, openness, transparency, having things working out-of-the-box, simplicity etc. 

  WordPress is currently used on approximately 30% of all websites. Many of them use the self-hosted open-source WordPress version. Giving everyone in this market the opportunity to easily get a powerful web analytics platform for free, means a lot to us. We believe WordPress users get a real choice besides the standard solution of Google Analytics, and it furthers our effort and goal of decentralising the internet. 

  We’re hoping more people will be empowered to protect user privacy, have access to a great free and open-source tool, and keep control of data in their own hands.

  We hope you feel the same. Help us spread the word to your friends and get them in on this awesome new project !

  Share on facebook

  Share on twitter

  Share on linkedin

  FAQs

  Isn’t there already a WP-Matomo plugin for WordPress available ?

  Yes, the existing WP-Matomo (WP-Piwik) plugin is an awesome plugin to connect your existing Matomo On-Premise or Matomo Cloud account with WordPress. The difference is that this new plugin installs Matomo Analytics fully in your WordPress. So you get the convenience of having a powerful analytics platform within your WordPress.

  We highly recommend you install this new plugin if you use WordPress and are not running Matomo yet. 

  If you are already using Matomo on our Cloud or On-Premise, we’d still highly recommend you use WP-Matomo (WP-Piwik). So that you get an easier way of inserting the tracking code into your WordPress site and get insights faster.

  I have a high traffic website, will it be an issue ?

  If you have a lot of traffic, we’d advise you to install Matomo On-Premise separately. There’s no specific traffic threshold we can give you on when it’s better to use Matomo On-Premise. It really depends on your server. 

  We reckon if you have more than 500,000 page views a month, you may want to think about using Matomo On-Premise with WP-Matomo instead, but this is just an estimate. In general, if the load on your server is already quite high, then it might be better to install Matomo on a separate server. See also recommended server sizing for running Matomo.

  How do I report a bug or request a new feature in Matomo for WordPress ?

  Please create an issue, on our repository whenever you find a bug or if you have any suggestion or ideas of improvement. We want to build an outstanding analytics experience for WordPress !

  Have another question you’re dying to ask ? The Matomo for WordPress FAQ page might have the answer you need. 

  Matomo Analytics for WordPress newsletter

  Get ahead of the crowd – signup to our exclusive Matomo for WordPress newsletter to get the latest updates on this exciting new project.

  &lt;script type=&quot;text/javascript&quot;&gt;<br />
(function(global) {<br />
 function serialize(form){if(!form||form.nodeName!==&quot;FORM&quot;){return }var i,j,q=[];for(i=form.elements.length-1;i&gt;=0;i=i-1){if(form.elements[i].name===&quot;&quot;){continue}switch(form.elements[i].nodeName){case&quot;INPUT&quot;:switch(form.elements[i].type){case&quot;text&quot;:case&quot;hidden&quot;:case&quot;password&quot;:case&quot;button&quot;:case&quot;reset&quot;:case&quot;submit&quot;:q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].value));break;case&quot;checkbox&quot;:case&quot;radio&quot;:if(form.elements[i].checked){q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].value))}break;case&quot;file&quot;:break}break;case&quot;TEXTAREA&quot;:q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].value));break;case&quot;SELECT&quot;:switch(form.elements[i].type){case&quot;select-one&quot;:q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].value));break;case&quot;select-multiple&quot;:for(j=form.elements[i].options.length-1;j&gt;=0;j=j-1){if(form.elements[i].options[j].selected){q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].options[j].value))}}break}break;case&quot;BUTTON&quot;:switch(form.elements[i].type){case&quot;reset&quot;:case&quot;submit&quot;:case&quot;button&quot;:q.push(form.elements[i].name+&quot;=&quot;+encodeURIComponent(form.elements[i].value));break}break}}return q.join(&quot;&amp;&quot;)};<br />
<br />
<br />
 function extend(destination, source) {<br />
   for (var prop in source) {<br />
     destination[prop] = source[prop];<br />
   }<br />
 }<br />
<br />
 if (!Mimi) var Mimi = {};<br />
 if (!Mimi.Signups) Mimi.Signups = {};<br />
<br />
 Mimi.Signups.EmbedValidation = function() {<br />
   this.initialize();<br />
<br />
   var _this = this;<br />
   if (document.addEventListener) {<br />
     this.form.addEventListener('submit', function(e){<br />
       _this.onFormSubmit(e);<br />
     });<br />
   } else {<br />
     this.form.attachEvent('onsubmit', function(e){<br />
       _this.onFormSubmit(e);<br />
     });<br />
   }<br />
 };<br />
<br />
 extend(Mimi.Signups.EmbedValidation.prototype, {<br />
   initialize: function() {<br />
     this.form         = document.getElementById('ema_signup_form');<br />
     this.submit       = document.getElementById('webform_submit_button');<br />
     this.callbackName = 'jsonp_callback_' + Math.round(100000 * Math.random());<br />
     this.validEmail   = /.+@.+\..+/<br />
   },<br />
<br />
   onFormSubmit: function(e) {<br />
     e.preventDefault();<br />
<br />
     this.validate();<br />
     if (this.isValid) {<br />
       this.submitForm();<br />
     } else {<br />
       this.revalidateOnChange();<br />
     }<br />
   },<br />
<br />
   validate: function() {<br />
     this.isValid = true;<br />
     this.emailValidation();<br />
     this.fieldAndListValidation();<br />
     this.updateFormAfterValidation();<br />
   },<br />
<br />
   emailValidation: function() {<br />
     var email = document.getElementById('signup_email');<br />
<br />
     if (this.validEmail.test(email.value)) {<br />
       this.removeTextFieldError(email);<br />
     } else {<br />
       this.textFieldError(email);<br />
       this.isValid = false;<br />
     }<br />
   },<br />
<br />
   fieldAndListValidation: function() {<br />
     var fields = this.form.querySelectorAll('.mimi_field.required');<br />
<br />
     for (var i = 0; i &lt; fields.length; ++i) {<br />
       var field = fields[i],<br />
           type  = this.fieldType(field);<br />
       if (type === 'checkboxes' || type === 'radio_buttons' || type === 'age_check') {<br />
         this.checkboxAndRadioValidation(field);<br />
       } else {<br />
         this.textAndDropdownValidation(field, type);<br />
       }<br />
     }<br />
   },<br />
<br />
   fieldType: function(field) {<br />
     var type = field.querySelectorAll('.field_type');<br />
<br />
     if (type.length) {<br />
       return type[0].getAttribute('data-field-type');<br />
     } else if (field.className.indexOf('checkgroup') &gt;= 0) {<br />
       return 'checkboxes';<br />
     } else {<br />
       return 'text_field';<br />
     }<br />
   },<br />
<br />
   checkboxAndRadioValidation: function(field) {<br />
     var inputs   = field.getElementsByTagName('input'),<br />
         selected = false;<br />
<br />
     for (var i = 0; i &lt; inputs.length; ++i) {<br />
       var input = inputs[i];<br />
       if((input.type === 'checkbox' || input.type === 'radio') &amp;&amp; input.checked) {<br />
         selected = true;<br />
       }<br />
     }<br />
<br />
     if (selected) {<br />
       field.className = field.className.replace(/ invalid/g, '');<br />
     } else {<br />
       if (field.className.indexOf('invalid') === -1) {<br />
         field.className += ' invalid';<br />
       }<br />
<br />
       this.isValid = false;<br />
     }<br />
   },<br />
<br />
   textAndDropdownValidation: function(field, type) {<br />
     var inputs = field.getElementsByTagName('input');<br />
<br />
     for (var i = 0; i &lt; inputs.length; ++i) {<br />
       var input = inputs[i];<br />
       if (input.name.indexOf('signup') &gt;= 0) {<br />
         if (type === 'text_field') {<br />
           this.textValidation(input);<br />
         } else {<br />
           this.dropdownValidation(field, input);<br />
         }<br />
       }<br />
     }<br />
     this.htmlEmbedDropdownValidation(field);<br />
   },<br />
<br />
   textValidation: function(input) {<br />
     if (input.id === 'signup_email') return;<br />
<br />
     if (input.value) {<br />
       this.removeTextFieldError(input);<br />
     } else {<br />
       this.textFieldError(input);<br />
       this.isValid = false;<br />
     }<br />
   },<br />
<br />
   dropdownValidation: function(field, input) {<br />
     if (input.value) {<br />
       field.className = field.className.replace(/ invalid/g, '');<br />
     } else {<br />
       if (field.className.indexOf('invalid') === -1) field.className += ' invalid';<br />
       this.onSelectCallback(input);<br />
       this.isValid = false;<br />
     }<br />
   },<br />
<br />
   htmlEmbedDropdownValidation: function(field) {<br />
     var dropdowns = field.querySelectorAll('.mimi_html_dropdown');<br />
     var _this = this;<br />
<br />
     for (var i = 0; i &lt; dropdowns.length; ++i) {<br />
       var dropdown = dropdowns[i];<br />
<br />
       if (dropdown.value) {<br />
         field.className = field.className.replace(/ invalid/g, '');<br />
       } else {<br />
         if (field.className.indexOf('invalid') === -1) field.className += ' invalid';<br />
         this.isValid = false;<br />
         dropdown.onchange = (function(){ _this.validate(); });<br />
       }<br />
     }<br />
   },<br />
<br />
   textFieldError: function(input) {<br />
     input.className   = 'required invalid';<br />
     input.placeholder = input.getAttribute('data-required-field');<br />
   },<br />
<br />
   removeTextFieldError: function(input) {<br />
     input.className   = 'required';<br />
     input.placeholder = '';<br />
   },<br />
<br />
   onSelectCallback: function(input) {<br />
     if (typeof Widget === 'undefined' || !Widget.BasicDropdown) return;<br />
<br />
     var dropdownEl = input.parentNode,<br />
         instances  = Widget.BasicDropdown.instances,<br />
         _this = this;<br />
<br />
     for (var i = 0; i &lt; instances.length; ++i) {<br />
       var instance = instances[i];<br />
       if (instance.wrapperEl === dropdownEl) {<br />
         instance.onSelect = function(){ _this.validate() };<br />
       }<br />
     }<br />
   },<br />
<br />
   updateFormAfterValidation: function() {<br />
     this.form.className   = this.setFormClassName();<br />
     this.submit.value     = this.submitButtonText();<br />
     this.submit.disabled  = !this.isValid;<br />
     this.submit.className = this.isValid ? 'submit' : 'disabled';<br />
   },<br />
<br />
   setFormClassName: function() {<br />
     var name = this.form.className;<br />
<br />
     if (this.isValid) {<br />
       return name.replace(/\s?mimi_invalid/, '');<br />
     } else {<br />
       if (name.indexOf('mimi_invalid') === -1) {<br />
         return name += ' mimi_invalid';<br />
       } else {<br />
         return name;<br />
       }<br />
     }<br />
   },<br />
<br />
   submitButtonText: function() {<br />
     var invalidFields = document.querySelectorAll('.invalid'),<br />
         text;<br />
<br />
     if (this.isValid || !invalidFields) {<br />
       text = this.submit.getAttribute('data-default-text');<br />
     } else {<br />
       if (invalidFields.length || invalidFields[0].className.indexOf('checkgroup') === -1) {<br />
         text = this.submit.getAttribute('data-invalid-text');<br />
       } else {<br />
         text = this.submit.getAttribute('data-choose-list');<br />
       }<br />
     }<br />
     return text;<br />
   },<br />
<br />
   submitForm: function() {<br />
     this.formSubmitting();<br />
<br />
     var _this = this;<br />
     window[this.callbackName] = function(response) {<br />
       delete window[this.callbackName];<br />
       document.body.removeChild(script);<br />
       _this.onSubmitCallback(response);<br />
     };<br />
<br />
     var script = document.createElement('script');<br />
     script.src = this.formUrl('json');<br />
     document.body.appendChild(script);<br />
   },<br />
<br />
   formUrl: function(format) {<br />
     var action  = this.form.action;<br />
     if (format === 'json') action += '.json';<br />
     return action + '?callback=' + this.callbackName + '&amp;' + serialize(this.form);<br />
   },<br />
<br />
   formSubmitting: function() {<br />
     this.form.className  += ' mimi_submitting';<br />
     this.submit.value     = this.submit.getAttribute('data-submitting-text');<br />
     this.submit.disabled  = true;<br />
     this.submit.className = 'disabled';<br />
   },<br />
<br />
   onSubmitCallback: function(response) {<br />
     if (response.success) {<br />
       this.onSubmitSuccess(response.result);<br />
     } else {<br />
       top.location.href = this.formUrl('html');<br />
     }<br />
   },<br />
<br />
   onSubmitSuccess: function(result) {<br />
     if (result.has_redirect) {<br />
       top.location.href = result.redirect;<br />
     } else if(result.single_opt_in || !result.confirmation_html) {<br />
       this.disableForm();<br />
       this.updateSubmitButtonText(this.submit.getAttribute('data-thanks'));<br />
     } else {<br />
       this.showConfirmationText(result.confirmation_html);<br />
     }<br />
   },<br />
<br />
   showConfirmationText: function(html) {<br />
     var fields = this.form.querySelectorAll('.mimi_field');<br />
<br />
     for (var i = 0; i &lt; fields.length; ++i) {<br />
       fields[i].style['display'] = 'none';<br />
     }<br />
<br />
     (this.form.querySelectorAll('fieldset')[0] || this.form).innerHTML = html;<br />
   },<br />
<br />
   disableForm: function() {<br />
     var elements = this.form.elements;<br />
     for (var i = 0; i &lt; elements.length; ++i) {<br />
       elements[i].disabled = true;<br />
     }<br />
   },<br />
<br />
   updateSubmitButtonText: function(text) {<br />
     this.submit.value = text;<br />
   },<br />
<br />
   revalidateOnChange: function() {<br />
     var fields = this.form.querySelectorAll(&quot;.mimi_field.required&quot;),<br />
         _this = this;<br />
<br />
     var onTextFieldChange = function() {<br />
       if (this.getAttribute('name') === 'signup[email]') {<br />
         if (_this.validEmail.test(this.value)) _this.validate();<br />
       } else {<br />
         if (this.value.length === 1) _this.validate();<br />
       }<br />
     }<br />
<br />
     for (var i = 0; i &lt; fields.length; ++i) {<br />
       var inputs = fields[i].getElementsByTagName('input');<br />
       for (var j = 0; j &lt; inputs.length; ++j) {<br />
         if (this.fieldType(fields[i]) === 'text_field') {<br />
           inputs[j].onkeyup = onTextFieldChange;<br />
           inputs[j].onchange = onTextFieldChange; <br />
         } else {<br />
           inputs[j].onchange = function(){ _this.validate() };<br />
         }<br />
       }<br />
     }<br />
   }<br />
 });<br />
<br />
 if (document.addEventListener) {<br />
   document.addEventListener(&quot;DOMContentLoaded&quot;, function() {<br />
     new Mimi.Signups.EmbedValidation();<br />
   });<br />
 }<br />
 else {<br />
   window.attachEvent('onload', function() {<br />
     new Mimi.Signups.EmbedValidation();<br />
   });<br />
 }<br />
})(this);<br />
&lt;/script&gt;

  Get Matomo for WordPress

• Revision 30775 : Installation et désinstallation plus propre

  10 août 2009, par kent1@… — Log

  Installation et désinstallation plus propre

• Working on images asynchronously

  15 décembre 2013, par Mikko Koppanen — Imagick, PHP stuff

  To get my quota on buzzwords for the day we are going to look at using ZeroMQ and Imagick to create a simple asynchronous image processing system. Why asynchronous ? First of all, separating the image handling from a interactive PHP scripts allows us to scale the image processing separately from the web heads. For example we could do the image processing on separate servers, which have SSDs attached and more memory. In this example making the images available to all worker nodes is left to the reader.

  Secondly, separating the image processing from a web script can provide more responsive experience to the user. This doesn’t necessarily mean faster, but let’s say in a multiple image upload scenario this method allows the user to do something else on the site while we process the images in the background. This can be beneficial especially in cases where users upload hundreds of images at a time. To achieve a simple distributed image processing infrastructure we are going to use ZeroMQ for communicating between different components and Imagick to work on the images.

  The first part we are going to create is a simple “Worker” -process skeleton. Naturally for a live environment you would like to have more error handling and possibly use pcntl for process control, but for the sake of brewity the example is barebones :

  php

  < view plain text >

  1. < ?php
  2.  
  3. define (’THUMBNAIL_ADDR’, ’tcp ://127.0.0.1:5000’) ;
  4. define (’COLLECTOR_ADDR’, ’tcp ://127.0.0.1:5001’) ;
  5.  
  6. class Worker {
  7.  
  8.   private $in ;
  9.   private $out ;
  10.  
  11.   public function __construct ($in_addr, $out_addr)
  12.   {
  13.     $context = new ZMQContext () ;
  14.  
  15.     $this->in = new ZMQSocket ($context, ZMQ: :SOCKET_PULL) ;
  16.     $this->in->bind ($in_addr) ;
  17.  
  18.     $this->out = new ZMQSocket ($context, ZMQ: :SOCKET_PUSH) ;
  19.     $this->out->connect ($out_addr) ;
  20.   }
  21.  
  22.   public function work () {
  23.     while ($command = $this->in->recvMulti ()) {
  24.       if (isset ($this->commands [$command [0]])) {
  25.         echo "Received work" . PHP_EOL ;
  26.  
  27.         $callback = $this->commands [$command [0]] ;
  28.  
  29.         array_shift ($command) ;
  30.         $response = call_user_func_array ($callback, $command) ;
  31.  
  32.         if (is_array ($response))
  33.           $this->out->sendMulti ($response) ;
  34.         else
  35.           $this->out->send ($response) ;
  36.       }
  37.       else {
  38.         error_log ("There is no registered worker for $command [0]") ;
  39.       }
  40.     }
  41.   }
  42.  
  43.   public function register ($command, $callback)
  44.   {
  45.     $this->commands [$command] = $callback ;
  46.   }
  47. }
  48.  ?>

  The Worker class allows us to register commands with callbacks associated with them. In our case the Worker class doesn’t actually care or know about the parameters being passed to the actual callback, it just blindly passes them on. We are using two separate sockets in this example, one for incoming work requests and one for passing the results onwards. This allows us to create a simple pipeline by adding more workers in the mix. For example we could first have a watermark worker, which takes the original image and composites a watermark on it, passes the file onwards to thumbnail worker, which then creates different sizes of thumbnails and passes the final results to event collector.

  The next part we are going to create a is a simple worker script that does the actual thumbnailing of the images :

  php

  < view plain text >

  1. < ?php
  2. include __DIR__ . ’/common.php’ ;
  3.  
  4. // Create worker class and bind the inbound address to ’THUMBNAIL_ADDR’ and connect outbound to ’COLLECTOR_ADDR’
  5. $worker = new Worker (THUMBNAIL_ADDR, COLLECTOR_ADDR) ;
  6.  
  7. // Register our thumbnail callback, nothing special here
  8. $worker->register (’thumbnail’, function ($filename, $width, $height) {
  9.                   $info = pathinfo ($filename) ;
  10.  
  11.                   $out = sprintf ("%s/%s_%dx%d.%s",
  12.                           $info [’dirname’],
  13.                           $info [’filename’],
  14.                           $width,
  15.                           $height,
  16.                           $info [’extension’]) ;
  17.  
  18.                   $status = 1 ;
  19.                   $message = ’’ ;
  20.  
  21.                   try {
  22.                     $im = new Imagick ($filename) ;
  23.                     $im->thumbnailImage ($width, $height) ;
  24.                     $im->writeImage ($out) ;
  25.                   }
  26.                   catch (Exception $e) {
  27.                     $status = 0 ;
  28.                     $message = $e->getMessage () ;
  29.                   }
  30.  
  31.                   return array (
  32.                         ’status’  => $status,
  33.                         ’filename’ => $filename,
  34.                         ’thumbnail’ => $out,
  35.                         ’message’ => $message,
  36.                     ) ;
  37.                 }) ;
  38.  
  39. // Run the worker, will block
  40. echo "Running thumbnail worker.." . PHP_EOL ;
  41. $worker->work () ;

  As you can see from the code the thumbnail worker registers a callback for ‘thumbnail’ command. The callback does the thumbnailing based on input and returns the status, original filename and the thumbnail filename. We have connected our Workers “outbound” socket to event collector, which will receive the results from the thumbnail worker and do something with them. What the “something” is depends on you. For example you could push the response into a websocket to show immediate feeedback to the user or store the results into a database.

  Our example event collector will just do a var_dump on every event it receives from the thumbnailer :

  php

  < view plain text >

  1. < ?php
  2. include __DIR__ . ’/common.php’ ;
  3.  
  4. $socket = new ZMQSocket (new ZMQContext (), ZMQ: :SOCKET_PULL) ;
  5. $socket->bind (COLLECTOR_ADDR) ;
  6.  
  7. echo "Waiting for events.." . PHP_EOL ;
  8. while (($message = $socket->recvMulti ())) {
  9.   var_dump ($message) ;
  10. }
  11.  ?>

  The final piece of the puzzle is the client that pumps messages into the pipeline. The client connects to the thumbnail worker, passes on filename and desired dimensions :

  php

  < view plain text >

  1. < ?php
  2. include __DIR__ . ’/common.php’ ;
  3.  
  4. $socket = new ZMQSocket (new ZMQContext (), ZMQ: :SOCKET_PUSH) ;
  5. $socket->connect (THUMBNAIL_ADDR) ;
  6.  
  7. $socket->sendMulti (
  8.       array (
  9.         ’thumbnail’,
  10.         realpath (’./test.jpg’),
  11.         50,
  12.         50,
  13.       )
  14. ) ;
  15. echo "Sent request" . PHP_EOL ;
  16.  ?>

  After this our processing pipeline will look like this :

  

  Now, if we notice that thumbnail workers or the event collectors can’t keep up with the rate of images we are pushing through we can start scaling the pipeline by adding more processes on each layer. ZeroMQ PUSH socket will automatically round-robin between all connected nodes, which makes adding more workers and event collectors simple. After adding more workers our pipeline will look like this :

  

  Using ZeroMQ also allows us to create more flexible architectures by adding forwarding devices in the middle, adding request-reply workers etc. So, the last thing to do is to run our pipeline and see the results :

  Let’s create our test image first :

  $ convert magick:rose test.jpg
  

  From the command-line run the thumbnail script :

  $ php thumbnail.php 
  Running thumbnail worker..
  

  In a separate terminal window run the event collector :

  $ php collector.php 
  Waiting for events..
  

  And finally run the client to send the thumbnail request :

  $ php client.php 
  Sent request
  $
  

  If everything went according to the plan you should now see the following output in the event collector window :

  array(4) 
    [0]=>
    string(1) "1"
    [1]=>
    string(56) "/test.jpg"
    [2]=>
    string(62) "/test_50x50.jpg"
    [3]=>
    string(0) ""
  
  

  Happy hacking !