WSO2 Web Services Framework for PHP 2.1.0 Released

WSO2 just released a newer version of the popular web services framework for php (WSF/PHP). It has lot of bug fixes + performance improvement.  And it now support PHP 5.3. So you can use wsf/php with the latest php version.

You can download the new release from http://wso2.org/downloads/wsf/php.

WSO2 Stratos: WSO2 Brings The Whole SOA Stack to The Cloud

WSO2 announced that the SOA stack that they provided as downloadable packages are now available in the cloud as hosted instances with the code name WSO2 Stratos. You can try them out for free from https://cloud.wso2.com. You can register your organization for an account in the WSO2 Stratos by clicking the 'Register' button in the home page. You can find a detail guide on 'How to register for WSO2 Stratos' from Charitha's blog, http://charithaka.blogspot.com/2010/06/wso2-stratos-introducing-wso2.html.

At the registration, you will be asked to provide a username and password for the admin account. Use this credential to login as admin for the Stratos services and surf through the products. Here is a brief introduction on all the products currently available.

• Stratos Governance: Store and govern your services, wsdls, schemas, policies and other SOA artifacts


• Stratos Identity: Manage user bases, authentication mechanisms, permissions and all the identity aspects of your enterprise.


• Stratos Application Server: Host your web apps, web services and manage their QoS aspects like security, reliability.


• Stratos Gadgets Server: Write and host gadgets complaint with Google gadget standards.


• Stratos Mashup Server: Write mashup using scripting languages like javascript.


• Stratos Business Activity Monitor: Monitor activities of your services.


• Stratos Enterprise Service Bus: Coming soon with message routing, intermediate message transformations, task scheduling and many more features.

With this release WSO2 bring complete SOA stack to the cloud, Now your enterprise can enjoy the power of SOA without the hassle of maintaining your own SOA infrastructure.

PHP Web Services: Webinar From WSO2 And Zend

WSO2 and Zend jointly present a webinar titling "PHP Web Services: Why You Should Care" on 26th of May, 2010. The webinar will mainly focus on the following aspects,
• Understand Web services development best practices
• Discuss Web service myths and pitfalls
• Learn about prominent PHP Web services extensions
• Watch a demo of building Web Services with both the Zend Framework and WSO2 Web Services Framework for PHP.

You can find more information about the webinar and the link to registration here, http://wso2.org/library/webinars/2010/05/webinar-php-web-services-you-should-care.

Metering Java Reader and Writer Objects

Last few days I was working on measuring the bandwidth consumed by different java objects passed to our remote interfaces. It was simple task to do it with 'String' objects, byte arrays as we can directly get the sizes of them using String.length and byte[].size() methods.

But there were objects of type Reader and Writer, which is supposed to transfer big chunk of data. There also we could load all the data to memory and measure the sizes.

// measuring reader size - memory inefficient method

// read all data to buffer and measure the length
StringReader stringReader = new StringReader(reader);
int size = stringReader.toString().length;

doRealWork(stringReader);

But that will consume lot of memory (even possible to exceed available heap size). So it is wrong to use the above method to measure the size of reader or writer.

Anyway there is an easy solution for the problem. We can use the design of Reader API itself to measure it size. The Reader interface has a method that read the data by small chunks. We just need to intercept that call and measure the size of each small chunk and add them all. For that we need to implement the Reader interface in to a custom class (say 'MonitoredReader'). Here is how it is implemented.

import java.io.IOException;
import java.io.Reader;

/**
 * The class to intercept the read method and calculate
 * the number of reads
 */
public class MonitoredReader extends Reader {

    Reader reader;
    int totalReadSize;

    /**
     * constructor that wraps the original reader object
     */
    public MonitoredReader(Reader reader) {
        this.reader = reader;
        totalReadSize = 0;
    }

    /**
     * The method to call by the user to read the data. We will just calculate the amount
     * of data read here.
     *
     * @param cBuf destination buffer
     * @param off  offset at which to start storing characters
     * @param len  maximum number of characters to read
     *
     * @return the number of characters read, or -1 if the end of the stream has been reached
     * @throws IOException if an I/O error occurs
     */
    public int read(char cbuf[], int off, int len) throws IOException {

        int read = reader.read(cbuf, off, len);
        totalReadSize += read;
        return read;
    }

    /**
     * Method to call after finishing reading the data. We will just pass the call to the
     * original reader
     */

    public void close() throws IOException {
        reader.close();
    }

    /**
     * Custom method that will return the total size of read data
     *
     * @return the size of the data read
     */
    public int getTotalReadSize() {
        return totalReadSize;
    }
}

So our code to measure the size will simple reduce to the following piece of code.

// measuring reader size - memory efficient method

// just wrap the original reader with our custom reader
MonitoredReader monitoredReader = new MonitoredReader(reader);

// pass our custom reader to the real work
doRealWork(monitoredReader);

// get the size read in the real work
int size = monitoredReader.getTotalReadSize();

Similarly we can use this method to get the data size of the writer. (amount of data written to the writer).

import java.io.IOException;
import java.io.Writer;

/**
 * The class to intercept the write method and calculate
 * the number of writes
 */
public class MonitoredWriter extends Writer {

    Writer writer;
    int totalWrittenSize;

    /**
     * constructor that wraps the original writer object
     */
    public MonitoredWriter(Writer writer) {
        this.writer = writer;
        totalWrittenSize = 0;
    }

    /**
     * The method to call by the user to write the data. We will just calculate the amount
     * of data written here.
     *
     * @param  cBuf  Array of characters
     * @param  off   Offset from which to start writing characters
     * @param  len   Number of characters to write
     *
     * @throws java.io.IOException  If an I/O error occurs
     */
    public void write(char cbuf[], int off, int len) throws IOException {
        totalWrittenSize += (len - off);
        writer.write(cbuf, off, len);
    }

    /**
     * Method to call after finishing writing the data. We will just pass the call to the
     * original writer
     */
    public void close() throws IOException {
        writer.close();
    }

    /**
     * flush already written data. Here also we just pass the call to the original writer
     */
    public void flush() throws IOException {
        writer.flush();
    }

    /**
     * Custom method that will return the total size of written data
     *
     * @return the size of the data written
     */
    public int getTotalWrittenSize() {
        return totalWrittenSize;
    }
}

Here is how it is used in measuring the writer size.

// measuring writer size - memory efficient method

// just wrap the original writer with our custom writer
MonitoredWriter monitoredWriter = new MonitoredWriter(writer);

// pass our custom wrter to the real work

doRealWork(monitoredWriter);

// get the size written in the real work
int size = monitoredWriter.getTotalWrittenSize();

Anyway like every good methods, there are drawbacks of using these methods to measure the data size on Reader and Writer objects.

If we take measuring the bandwidth consumed by a reader in a remote interface, this gives a slightly low value because this particular code only provide the size of the data read by the end user application and not by the network hardware layers. But actually these low layers read more data and keep it in a buffer which is not measured here. But if we assume that most of the time the end user application read all the data from the reader (and very rarely read portion of data and give up), this give nearly accurate value.

The other drawback could be the performance degradation  by wrapping the reader/writer with our custom implementation. But mostly reader and writers are used in IO bound operations (like to read through network or files), so going through an another layer does really little effect to the overall performance. And after all the 'Observer effect theory' says we can't measure anything without causing any effect to the actual cause...

WSO2 Governance Registry, WSO2 Identity Server, WSO2 ESB, WSO2 Web Service Application Server Released

WSO2 has released new versions of their SOA platform products including WSO2 Governance Registry, WSO2 Identity Server, WSO2 ESB, WSO2 Web Service Application Server. This is a major version upgrade of these products introducing many features.


ESB:

• Priority based mediation through priority executors


• WS-Discovery support and dynamic endpoint discovery


• Message Relay for efficient pass through of messages


• Component manager to install and uninstall features (provisioning support)


• Common Internet File System (CIFS) support through the VFS transport


• File locking functionality in the VFS transport to support concurrent polling


• Smooks mediator for efficient message transformation


• Enrich mediator for smart message manipulation


• OAuth mediator for 2-legged OAuth support


• Default endpoint UI


• Hot deploy and hot update configuration elements (sequences, endpoints, proxy services etc)


• Transport level statistics collection and monitoring


• POX security support


• Dependency detection and alerting for mediation configuration elements


• Mediation statistics API and custom mediation statistics consumers


• Multiple certificate/identity support in the NHTTP transport sender


• Improved logging capabilities for the NHTTP transport


• Templates based proxy service development in the UI


• Dashboard to monitor server environment and runtime


• Easy creation and management capabilities for dynamic sequences and endpoints


• Pagination to service management, endpoint management and sequence management UIs


• Obtaining resources like WSDL's through web proxy servers

Governance Registry

• Gadgets for impact analysis on services and registry resources


• WSDL custom view


• Dynamic Handler configuration


• Handler simulator


• Tree-based Resource view


• API to govern SOA artifacts


• Complete Web Services API for Registry


• Improved options for Service discovery


• WS-Discovery support


• Scripting support for lifecycle management


• Improved P2 based provisioning and feature management support


• Support for adding remote mounts


• Platform, and Group/Cluster based deployment model


• Support for multiple server instances


• E-mail verification for subscriptions


• Support for deleting tags and comments


• Support for PostgreSQL and DB2 DBMS


• Paged activity and resource search


• Hierarchical permission model with granular and extensible permissions


• Ability to upload metadata (in addition to importing)


• Governance Archive for uploading WSDLs and Schemas with imports


• Ability to update resource content by uploading


• Rich text editor for editing text resources


• XML editor for editing handler, lifecycle and service UI configurations

Web Service Application Server (WSO2 WSAS):

• Component Manager - The UI tool to install/uninstall Carbon featrues.


• Various bug fixes & enhancements including architectural improvements to Apache Axis2, Apache Rampart, Apache Sandesha2 , WSO2 Carbon & other projects.


• Equinox P2 based provisioning support - extend your WSAS instance by installin new P2 features. See P2 based provisioning in WSO2 Carbon


• Hierarchical service support for Axis2 services, JAX-WS services, Spring services & Jar services


• Report generation for deployed services

Identity Server:

• SAML 2.0 based Single Sign-on support


• OAuth Support


• Support for bulk-user import


• Various bug fixes and enhancements including architectural improvements to Apache Axis2, Apache Rampart, Apache Sandesha2 , WSO2 Carbon and other projects.

Webinar: WSO2 Business Activity Monitor for Agile Enterprises

Samisa Abeysinghe, the directory of engineering at WSO2 will present a webinar on Building an Agile Enterprise With Business Activity Monitoring today (3rd February 2010).

There he will provide an overview of WSO2 Business Activity Monitor (WSO2 BAM), the latest product from the WSO2 Carbon platform, including its built-in dashboard to view analytics , reports of past and present activities of the enterprise SOA infrastructure and how these information can be used in tactical and strategic decision making.

Access WSO2 Governance as a Service From Remote Registry

WSO2 Governance as a Service is a hosted instance of WSO2 Governance Registry with multi-tenant support. WSO2 Governance as a Service provide you almost all the functionalities provided with the Governance Registry targeting the enterprise SOA governance, same time it provides all the advantages  inherent with the Software as a Service model.

Here I'm talking about how to use a popular feature available in Governance Registry, inside WSO2 Governance as a Service. i.e. Remote Registry Client. With Remote Registry Client, you can access the resources in registry programatically. It uses atom/pub protocol to communicate with the registry server.

Here is an example of using Remote Registry Client. I assumed I have an account with domain name 'example.com' with a user name 'example_user' ('example_password'). You have to change this to valid values before running this code, You can create an account in Governance as a Service freely for a limited use.

import java.net.URL;
import org.wso2.carbon.registry.core.Registry;
import org.wso2.carbon.registry.core.Resource;
import org.wso2.carbon.registry.app.RemoteRegistry;

class RegistryDemo {
    public static void main(String[] args) throws Exception {

        // calls the registry with the authentication information
        callRemoteRegistry("http://governance.cloud.wso2.com/registry",
                   "example_username@example.com", "example_password");
    }

    public static void callRemoteRegistry(String url, String username,
                       String password) throws Exception {

        Registry myRegistry = new RemoteRegistry(new URL(url), username, password);
        if (!myRegistry.resourceExists("/demoResource")) {

            Resource r = myRegistry.newResource();
            r.setContent("demo content");
            myRegistry.put("/demoResource", r);
        }

        Resource r = myRegistry.get("/demoResource");
        byte[] contentBytes = (byte[])r.getContent();
        String content = new String(contentBytes);
        System.out.println("Content: " + content);
    }
}