Socket结合线程池怎么实现客户端和服务端通信demo

本篇内容主要讲解“Socket结合线程池怎么实现客户端和服务端通信demo”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Socket结合线程池怎么实现客户端和服务端通信demo”吧!可以使用 Socket 和 ServiceSocket 以及其它 API；写一个客户端和服务端之间 TCP 通信的例子；服务端处理任务需要异步处理；因为服务端处理能力很弱，只能同时处理 5 个请求，当第六个请求到达服务器时，需要服务器返回明确的错误信息：服务器太忙了，请稍后重试~。需求比较简单，唯一复杂的地方在于第四点，我们需要对客户端的请求量进行控制，首先我们需要确认的是，我们是无法控制客户端发送的请求数的，所以我们只能从服务端进行改造，比如从服务端进行限流。有的同学可能很快想到，我们应该使用 ServerSocket 的 backlog 的属性，把其设置成 5，但我们在上一章中说到 backlog 并不能准确代表限制的客户端连接数，而且我们还要求服务端返回具体的错误信息，即使 backlog 生效，也只会返回固定的错误信息，不是我们定制的错误信息。我们好好想想，线程池似乎可以做这个事情，我们可以把线程池的 coreSize 和 maxSize 都设置成 4，把队列大小设置成 1，这样服务端每次收到请求后，会先判断一下线程池中的队列有没有数据，如果有的话，说明当前服务器已经马上就要处理第五个请求了，当前请求就是第六个请求，应该被拒绝。正好线程池的加入也可以满足第三点，服务端的任务可以异步执行。客户端的代码比较简单，直接向服务器请求数据即可，代码如下：客户端代码中我们也用到了线程池，主要是为了并发模拟客户端一次性发送 6 个请求，按照预期服务端在处理第六个请求的时候，会返回特定的错误信息给客户端。以上代码主要方法是 send 方法，主要处理像服务端发送数据，并处理服务端的响应。服务端的逻辑分成两个部分，第一部分是控制客户端的请求个数，当超过服务端的能力时，拒绝新的请求，当服务端能力可响应时，放入新的请求，第二部分是服务端任务的执行逻辑。我们使用 collectPoll.getQueue().size() >= 1 来判断目前服务端是否已经到达处理的极限了，如果队列中有一个任务正在排队，说明当前服务端已经超负荷运行了，新的请求应该拒绝掉，如果队列中没有数据，说明服务端还可以接受新的请求。以上代码注释详细，就不累赘说了。服务端的处理逻辑比较简单，主要步骤是：从客户端的 Socket 中读取输入，进行处理，把响应返回给客户端。我们使用线程沉睡 2 秒来模拟服务端的处理逻辑，代码如下：测试的时候，我们必须先启动服务端，然后再启动客户端，首先我们启动服务端，打印日志如下：接着我们启动客户端，打印日志如下：我们最后看一下服务端的运行日志：从以上运行结果中，我们可以免费云主机域名看出得出的结果是符合我们预期的，服务端在请求高峰时，能够并发处理5个请求，其余请求可以用正确的提示进行拒绝。到此，相信大家对“Socket结合线程池怎么实现客户端和服务端通信demo”有了更深的了解，不妨来实际操作一番吧！这里是百云主机网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

相关推荐: html布局命名的示例分析

小编给大家分享一下html布局命名的示例分析，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！头：header 模式：content/container 尾：footer 导航：nav…