So, as maybe some of you knows that i have started to use Golang programming language for my pet projects and since to solve "Project Euler" tasks is very useful deal, but very boring in the same time, i decided to create something more closer to real life. I decided to write XMPP server in golang and in this post i will tell about one part of this server - netpool/tcp library. netpool/tcp - is a tcp based socket acceptor pool. The idea is very simple, you will launch TCP listener which will launch many acceptors besides one, in this way you no need to spend time for creating new connection acceptor.
First of all let's create new tcp package and import all libraries which will we need in this project:
Now let's define types which we will need in our acceptor pool:
Let's go by order. First enumeration defines strategies when connection listener handles more connections than we define.
Next is ListenerStruct structure. It is a main structure which we will pass to StartListener function for launching new listener. It has following fields:
Next is a Connection structure. We have it every time as second parameter in connection handler function. It has simple API for manipulating with connection:
It's a main function of this library and it launches new tcp listener and some acceptors. Let's see how it implemented.
First of all it defines some variables like: acceptorCounter for count acceptors, checks is it connection over SSL or not and launches listener which depends on this:
Next it creates 2 channels:
After this listener waits for messages from another goroutines for closing current listener, closing connection, connection removed/created and etc...:
So what about acceptors... It's pretty simple as a listener implementation, it starts from accepting new connection and waits for incoming messages from connected client. If there are any incoming data from client it call handler function and pass input data and Connection structure to it:
After this it as a listener checks incoming message from other goroutines, to stop connection and etc...
So it's end. As we can saw concurrency is a pretty simple with Golang.
As i said in previous post i'm not a golang super-hacker, if you will have any recommendations for my golang code or you want to take part in XMPP server developing with golang i will be very pleased to hear it, write me in comment or ping me in twitter.. Also i made this library primarily for future extd XMPP server but i tried to make it generic so i think it can be useful not only for me. Links:
First of all let's create new tcp package and import all libraries which will we need in this project:
Now let's define types which we will need in our acceptor pool:
Let's go by order. First enumeration defines strategies when connection listener handles more connections than we define.
- RefuseConnection - listener will refuse connections after connections amount overflow;
- IncreaseConnection - listener will start yet another 50 acceptors.
Next is ListenerStruct structure. It is a main structure which we will pass to StartListener function for launching new listener. It has following fields:
- Accnb - number of acceptors;
- Port - connection port;
- Handler - function with 2 parameters: input string and conn tcp.Connection. It will calls when client send something to server;
- Lc - listener channel, it needs for communicating with listener;
- OverFlowStrategy - It can be 0 || 1, see note about overflow strategies;
- Ssl - it is a map, we need to use it if we want to use ssl. Just create map with 2 string keys: pam and key. Next if will show how to use it.
Next is a Connection structure. We have it every time as second parameter in connection handler function. It has simple API for manipulating with connection:
- Connection.Close - close current connection;
- Connection.Send - send response.
It's a main function of this library and it launches new tcp listener and some acceptors. Let's see how it implemented.
First of all it defines some variables like: acceptorCounter for count acceptors, checks is it connection over SSL or not and launches listener which depends on this:
Next it creates 2 channels:
- connectionCounter - channel for communicating between acceptor goroutines and listener. If connection was closed it sends message to listener and listener decrease connection numbers, if new connection was accepted it increase connection number;
- closeConnection - channel for commuicating between listener and acceptor for closing current connection.
After this listener waits for messages from another goroutines for closing current listener, closing connection, connection removed/created and etc...:
So what about acceptors... It's pretty simple as a listener implementation, it starts from accepting new connection and waits for incoming messages from connected client. If there are any incoming data from client it call handler function and pass input data and Connection structure to it:
After this it as a listener checks incoming message from other goroutines, to stop connection and etc...
So it's end. As we can saw concurrency is a pretty simple with Golang.
As i said in previous post i'm not a golang super-hacker, if you will have any recommendations for my golang code or you want to take part in XMPP server developing with golang i will be very pleased to hear it, write me in comment or ping me in twitter.. Also i made this library primarily for future extd XMPP server but i tried to make it generic so i think it can be useful not only for me. Links:
- netpool/tcp
- netpool/tcp example of usage
Comments