besily 2009-09-03
我们现在做的系统,要在两台机器间使用HTTP发送XML报文的方式来通讯。在压力很大的情况下,需要做拥塞控制的考虑,目前我们的想法是这样的:
客户机发送报文到A,A接到报文后,放入一个LinkedBlockingQueue,然后应答客户机。
从线程池中起另一个线程,到LinkedBlockingQueue中取排头的报文,发送给B机。
B机同样将收到的报文放入LinkedBlockingQueue,在放入之前,判断拥塞情况,如果Queue中已经超过500个报文,就在应答A的HTTP响应中设置status为900。
这样,A就需要在收到900的HTTP应答后,调整发送间隔时间,比如等待10分钟再发下一个,直到B机的应答返回的是200了,才恢复正常速度发送。
这个是我的初步设想,请问大家还有没有更好的建议?