In the introduction (part.1). we've pictured out the basic idea of the project abstraction(car exchange;). In this part we are going to configure Netty as the part of maven spring module (s4netty-worker).
Let's draw the agenda that allows us to start netty server under the spring ecosystem:
- initiate serverBootstrap object and configure the Netty server from properties file (worker-server.properties).
- configure the group, channel, handler and some channel options (ps: keep alive signal has been ignored in this project)
- Channel initialisation
- Netty JSON service response
- Netty JSON request handling
Let's begin and configure WorkerNettyServer which contains the instance of the serverBootstrap bean (add.1.). ServerBootstrap definition can be found in WorkerNettyConfig class.
@Bean(name = "serverBootstrap")
public ServerBootstrap bootstrap() {
All necessary properties for WorkerNettyConfig class used by serverBoostrap (add.1.) bean initialisation are taken from the config the file (worker-server.properties)
@Configuration
@ComponentScan("com.miko.s4netty")
@PropertySource("classpath:worker-server.properties")
public class WorkerNettyConfig {
To make possible reading from the *.properties file
@Value("${tcp.port}")
private int tcpPort;
we need to have access to the current Spring Context. This goal we achieve by using property sources place holder :
@Bean
public static PropertySourcesPlaceholderConfigurer propertyPlaceholderConfigurer() {
return new PropertySourcesPlaceholderConfigurer();
}
Now WorkerNettyConfig knows all values for its initiation
@Bean(name = "serverBootstrap")
public ServerBootstrap bootstrap() {
ServerBootstrap b = new ServerBootstrap();
After all those configuration steps, we get access, inside the WorkerNettyServer class, to the bean "serverBootstrap" by using Qualifier annotation for candidate Bean serverBootstrap (add.2.).
@Component
public class WorkerNettyServer {
...
@Autowired
@Qualifier("serverBootstrap")
private ServerBootstrap serverBootstrap;
...
and we can have quickly assign all serverBootstrap properties (add.2.)
@Bean(name = "serverBootstrap")
public ServerBootstrap bootstrap() {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup(), workerGroup())
.channel(NioServerSocketChannel.class)
.childHandler(workerInitializer);
So move forward and initiate the Channel and it's pipeline in the WorkerInitializer class (add.3.). Of course all according to our "master plan" to have JSON service listening on the specified port P and exchanging car list with base.
In this case we need totell Netty how it should deal with such type of the request by utilising HttpServerCodec (add.4.).
pipeline.addLast(new HttpServerCodec());
pipeline.addLast(workerProviderHandler);
Currently it looks like JSON service is listening on the port P and everything is almost ready to go. Well not exactly, there is still a some work do.
One good question could be about some missing definition :) oh, yes, where is
workerProviderHandler ? (add.5.) and here we go.
@Component
@ChannelHandler.Sharable
@Qualifier("workerProviderHandler")
public class WorkerProviderHandler extends ChannelInboundHandlerAdapter {
...
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
if (msg instanceof HttpRequest) {
HttpRequest req = (HttpRequest) msg;
...
The workerProviderHandler is the extension of ChannelInboundHandlerAdapter and it handles our request and provides the JSON response to the requestor (s4netty-web).
The request itself consists from results provided by spring service.
...
@Autowired
SimpleCarService simpleCarService;
...
Gson library has been used to serialise and deserialise POJO objects.
After defining handler and assigning to the pipeline we are done with Spring-Netty Configuration and ready to define module (s4netty-worker) Spring MVC without Web.xml usage.
Sure, in the next part (Click Next)
s4netty project GiTHub repository
