Posts

Showing posts with the label Akka

Building REST API web service using AKKA-HTTP, showing CRUD operations baked with Redis

Building REST API web service using AKKA-HTTP, showing CRUD operations baked with Redis AKKA-HTTP  is a lightweight layer that enable us to easily build our REST API over the akka actor system . In this article I will show step by step how to create simple web server with REST API Service and CRUD operations using  Rediscala  that will enable non-blocking and asynchronous I/O operations over Redis, sowing different options of completing the API response and serializing entities . And of course how to test our REST API. Full source code can be found  here Our web server will expose API for handling user passwords that will be kept in Redis (this is not a good practice to handle it like this in real life, and one might want to consider to add encryption etc’ in production). Our Rest API will expose the following functionality : Register new user Update user password Fetch user password Delete user So, let’s get our hands dirty ...

Presenting the File Tracker

Image
This project goal is to track changes in files and manage those changes as a byte array in asynchronous way using Akka actors and Java NIO library. This is done by registering directory for the  WatchService  and filtering the files using  PathMatcher  . For each change in the file the requester will receive the byte array reflecting that change. Currently this project supports only addition to file, i.e deletion of characters in file is not supported. The Complete Source Code can be found here Let's dive in. The Ingredients : FileSyncIo . This part is copied from the  FileAsyncIo project  with some adjustments, and it is very handy for reading files asynchronously. In order to read the file we use Java NIO  AsynchronousFileChannel  . Since we are only reading the file, we open the channel with the  Read  option. The AsynchronousFileChannel.read method accepts buffer, the start position and a handler : val p ...