Repository files navigation

General web site on Flow-Based Programming:https://jpaulm.github.io/fbp/ .

Latest release isv4.1.14. The jar file -javafbp-4.1.14.jar - can be obtained from the Releases folder, or frombuild/libs. Note: The Maven 'shield' below may show an earlier release. If you click on the Maven shield below, selectDownload, thenjar.

This implementation is a kit for building JavaFBP projects. For a number of sample networks, go tohttps://github.com/jpaulm/javafbp/tree/master/src/main/java/com/jpaulmorrison/fbp/resourcekit/examples .

For your own projects, include the JavaFBP jar file in the Build Path property for the project.

General web site for "classical" FBP:

• https://jpaulm.github.io/fbp

In computer programming, flow-based programming (FBP) is a programming paradigm that defines applications as networks of "black box" processes, which exchange data across predefined connections by message passing, where the connections are specified externally to the processes. These black box processes can be reconnected endlessly to form different applications without having to be changed internally. FBP is thus naturally component-oriented.

FBP is a particular form of dataflow programming based on bounded buffers, information packets with defined lifetimes, named ports, and separate definition of connections.

JavaFBP Syntax and Component API:

• https://jpaulm.github.io/fbp/jsyntax.htm

An automatically generated Javadoc can also be browsed athttp://jpaulm.github.io/javafbp/ . Unfortunately this isn't very useful for someone planning to use JavaFBP components, so we have built an FBP-specific Component Attributes List, which can be displayed by clicking onhttp://htmlpreview.github.io/?https://github.com/jpaulm/javafbp/blob/master/compList.html - see below.

Two components are available for reading and writing MySQL tables, respectively:ReadJDBC andWriteJDBC, incore.components.jdbc. These dynamically load the most recent MySQL jar file, and use reflection to execute SQL services.

If you are looking for an application using these components, it can be found in theFBP-ETL repository. This application of course uses the JavaFBP jar file as a dependency.

If you get a message saying "No suitable driver found", try restarting the MySQL service inservices.msc.

There is also a small GitHub project calledjavafbp-websockets, which contains two generalized components supporting WebSockets (https://developer.mozilla.org/en-US/docs/Web/API/WebSockets_API ), and a simple test component and network - it can be found athttps://github.com/jpaulm/javafbp-websockets .

JavaFBP recommends using a small connection size for debugging, and a larger one for production. In the latest version of JavaFBP, this is specified in the<user>.JavaFBPProperties.xml file - tag.

You will have downloaded the JavaFBP jar file earlier, so do agradle build for your project, to make sure the compiled classes (.class files) are in the 'bin' directory.

Now position the current directory to your own project, usingcd, and enter the following into the DOS window:

  java -cp "<JavaFBP directory>/javafbp-x.y.z.jar;." <program class name>

wherex.y.z is the version of the JavaFBP jar file. Note the final;.... or you can place.; in front of the jar file name.

Program class name must be the fully qualified network name.

You must also make sure thatjava can find any class files that your main line needs, by specifying the necessary jar files, and class directories using the-cp/-classpath parameter.

Here is a test command you can run (changing x.y.z to the current version number, of course), using networks and components provided by the JavaFBP project. Note that thebin folder is not uploaded to GitHub, so you will have to compile any networks to be tested to thebin folder (or add them to your own jar file):

Do acd command to your downloaded JavaFBP project, then enter

 java -cp ".;build/libs/javafbp-x.y.z.jar" com.jpaulmorrison.fbp.resourcekit.examples.networks.Copy1

For your own project, you will probably have to add more directories to theclasspath parameter - remember to provide the whole directory name.

Replace the ';' in the-cp parameter with ":" for *nix.

Go toProperties/Java Build Path for your project; click onAdd External Jars, add your JavaFBP jar file to the list, and then hitApply andOK.

SelectDebug for your project.

Here is a simple command-line test that can be run to test that everything is working.

Position to thejavafbp directory; then enter

java -cp ".;build/libs/javafbp-x.y.z.jar" com.jpaulmorrison.fbp.resourcekit.examples.networks.MergeandSort

wherex.y.z is the current version number of JavaFBP.

Alternatively, if you position to your ownbin folder, you might code something like

java -cp ".;C:\users\<you>\downloads\javafbp-x.y.z.jar" <name of class to be run>

Here is a picture of MergeandSort, drawn using DrawFBP:

This network contains 4 processes:

• 2 occurrences of GenerateTestData,
• a Sort process - a very simple-minded Sort, which can only handle up to 9,999 information packets
• a text display component, which invokes Java Swing to display the sorted data in a scroll pane.

The outputs of the two GenerateTestData processes are merged on a "first come, first served" basis. During the run you should see a scroll pane with the sorted data scrolling down.

At the end of the run, you should see:

Run complete.  Time: x.xxx secondsCounts: C: 150, D: 153, S: 300, R (non-null): 304, DO: 0

where the counts are respectively: creates, normal drops, sends, non-null receives, and drops done by "drop oldest".

Care must be taken if combiningLoadBalance (with substreams) andSubstreamSensitiveMerge in a divergent-convergent pattern - this pattern is one of the warning signals for deadlocks anyway. The problem is described in more detail under#8.

To trace JavaFBP services and/or lock usage, set the appropriate parameter(s) inJavaFBPProperties.xml in the<user> directory totrue:

• tracing
• tracelocks

e.g.

<?xml version="1.0"?> <properties> <tracing>true</tracing><tracelocks>false</tracelocks><defaultcapacity>...</defaultcapacity>    (as of v4.1.3)</properties>

These traces will appear in the project directory (in GitHub if running Eclipse) under the namexxxx-fulltrace.txt, wherexxxx is the name of the network being run. Subnets have their own trace output files.

Values fordefaultcapacity are as follows:

• PRODUCTION (currently 10)
• DEBUG (currently 1)
• any number
• defaultcapacity not specified - defaults to DEBUG value

Two other options are also supported in the properties file:

• deadlocktest (defaults to true, so you might set it tofalse if debugging)
• forceconsole (used if immediate console output is required during debugging - normally, console output is sent to a file)