请批评我的服务器设计

我在用Java设计一个服务器,用来交易债券。此服务器将充当客户端UI和分析服务器之间的中介。分析服务器就是大脑,我的服务器只需与之交互(使用TCP套接字),并将响应转发给客户机。

服务器应同时处理大约500个客户端。它必须具有可扩展性和高效性,以每秒处理大约500条消息。

客户机UI和分析服务器之间的消息流如下:

1. Client through the UI requests for price.
2. My server accepts the message, formats it and then asynchronously
   sends to the analytical server.
3. When the response from the analytical server arrives, format and send
   the response to the client UI.
4. If the client likes the price, he/she will request to trade.
5. Repeat steps 2 & 3.

我利用现有的框架来处理身份验证和发送 服务器和客户机UI之间的消息。我已经对服务器和分析服务器之间的消息位进行了编码。

在设计服务器的其余部分时,我考虑使用4个阻塞队列。当请求价格时,我立即将请求插入队列(队列1)。然后我有了一个处理器,它从队列1中取出消息,对其进行格式化,并将其放入另一个队列(队列2)。处理器类内部包含一个线程池(executors.FixedThreadPool),每个消息的格式都在一个单独的线程中出现。

然后我有一个包含另一个线程池的调度程序类。此调度程序类负责从队列2接收消息并将其写入分析服务器。

当我从分析服务器收到消息时,我将它插入另一个队列(队列3)。我有另一个线程池,它将消息出列并格式化,然后将其放入另一个线程池(队列4)。最后,我还有一个线程池,其中有来自队列4的pops消息,并将其发布到客户机。

我之所以选择4个不同的队列,是因为如果我愿意,我可以编写一个工具来观察这些队列的大小。有关这些队列大小的信息将

1. Allow me to tune the size of the thread pools. 
2. Further, if needed, I can publish the messages contained in these queues
   thus allowing me to monitor all the messages that flows through my server.

你们觉得呢?任何想法,提示都是最受欢迎的。

干杯