线程安全扫盲贴四中,改了异常消息发送的方法,把调用客户端发送消息改成了直接写消息到接收消息队列中,这样虽然接收消息线程池的线程飘红,但总能堵塞堵塞着执行完。为什么客户端并发socket请求会一直卡住了呢?我也不知道。
客户端发送socket的代码如下
/** * 发送消息 * @param msg消息 * @param encoding 消息的编码格式 * @throws Exception */ public void sendMessage(final String msg,String encoding) throws ClientException{ SocketFactory sf = (SocketFactory) SocketFactory.getDefault(); String reqMsg = null; Socket socket = null; try { reqMsg = new String(msg.getBytes(encoding),Encoding.UTF8); socket = getSocket(sf); BufferedWriter bw = new BufferedWriter( new OutputStreamWriter(socket.getOutputStream(),Encoding.UTF8)); PrintWriter tOut = new PrintWriter(bw); log.debug("正在发送报文:"+reqMsg); tOut.write(reqMsg); tOut.println(); tOut.flush(); log.debug("客户端消息发送完毕!等待服务器端确认: "+reqMsg); int totalBytesRcvd = 0; int bytesRcvd = 0; byte[] response = new byte["OK".length()]; InputStream in = socket.getInputStream(); while(totalBytesRcvd<response.length){ bytesRcvd = in.read(response, totalBytesRcvd, response.length-totalBytesRcvd); if(bytesRcvd==-1){ throw new ClientException("发送失败,服务器端异常关闭了socket连接: "+reqMsg); } totalBytesRcvd = totalBytesRcvd+bytesRcvd; } //增加验证服务器端返回的消息,增加之前可以并发到5w String rsp = new String(response,Encoding.UTF8); log.debug("收到服务器端返回消息:"+rsp); if(!rsp.equals("OK")){ throw new ClientException("发送失败,服务器端返回消息错误: "+rsp); } socket.close(); socket = null; } catch (Exception e1) { log.error(e1); throw new ClientException("向服务器端发送报文失败"+reqMsg,e1); } finally { if (socket != null) { try { socket.close(); } catch (IOException e) { log.error(e); } } } }
客户端的线程,并发1000个,总有最后2个就停住不执行了。
CyclicBarrier相当于一个拦截器,要指定的线程数都一起到了,再同时让他们run并发。
public class ClientRunnable implements Runnable{ private int index = -1; private String msg = null; private CyclicBarrier barrier = null; public ClientRunnable(int i,CyclicBarrier barrier){ this.index=i; this.msg = getMessage(i); this.barrier = barrier; } public void run() { IIPayrelayClient client = null; try { client = new Client(); barrier.await(); client.sendMessage(msg,"UTF-8"); } catch (Exception e) { e.printStackTrace(); } } }
这个问题下次再说,先下班了~~除了解决问题,就是下班最快乐咯^_^
相关推荐
内容概要:本文详细介绍了LabVIEW控件的设计与实现,尤其是一些由经验丰富的老工程师精心打造的控件。LabVIEW是一款图形化编程语言,广泛应用于数据采集、仪器控制和工业自动化领域。文中通过具体实例展示了如何利用LabVIEW创建美观且功能强大的控件,如滑动条、波形图、金属质感旋钮、动态波形图表以及智能选项卡等。作者强调了LabVIEW控件在灵活性和美观度方面的优势,并分享了许多实用的技术细节和优化方法。 适合人群:具有一定编程基础并希望深入了解LabVIEW控件设计的开发者和技术爱好者。 使用场景及目标:适用于需要进行高效的数据展示和交互设计的应用场景,如工业控制系统、实验室设备操作界面等。目标是帮助用户掌握LabVIEW控件的高级特性,提高开发效率和用户体验。 其他说明:文章不仅提供了具体的代码示例,还探讨了控件美学背后的设计理念和技术实现,鼓励读者探索更多可能性。
Delphi 12.3控件之unidac_10.4.0_d27pro.exe
11.盛趣自闭面(还是自己太菜).txt
58面经面试过程和题目.txt
电大操作系统课后习题解答
人工智能技术与应用演讲【61页PPT】
chromedriver-mac-arm64-135.0.7049.41.zip
内容概要:本文详细介绍了QPSK(四相移键控)调制方法及其在瑞利信道和高斯白噪声信道下的误码率(BER)性能分析。首先展示了QPSK星座图的绘制方法,接着构建了一个简化的QPSK发射机模型,用于将二进制比特流映射到相应的星座点。随后,分别实现了两种信道模型:高斯白噪声信道(AWGN)和瑞利信道,并解释了它们的工作原理以及如何向传输信号添加噪声。文中还提供了详细的误码率测试脚本,通过大量随机比特进行仿真,最终得到了不同信噪比条件下的误码率曲线。此外,作者还讨论了QPSK与其他调制方式如BPSK、16QAM之间的性能差异,强调了频谱效率与抗噪能力之间的权衡关系。 适合人群:对无线通信系统感兴趣的科研人员、研究生以及从事通信工程领域的工程师。 使用场景及目标:①帮助读者理解QPSK的基本原理及其在不同信道环境中的行为特性;②提供实用的Python代码片段,便于快速搭建仿真环境并验证理论结果;③探讨各种调制方式的选择依据,指导实际应用中的优化决策。 其他说明:文中多次提到‘骚操作’,意指一些巧妙但非传统的编程技巧,有助于提高代码执行效率或简化复杂度。同时提醒读者注意仿真过程中可能出现的问题,如
新建 Microsoft Word 文档 (9).docx
计算机科学与技术- 软件开发工具 培训资料
bitcount统计每个元素中设置的位数 B = bitcount(A) Counts the number '1' bits in each element B = bitcount(A, bitValue) "bitValue" = 1 = default = counts the occurance of '1' if bitValue = 0; counts the number '0' The total bits to verify is [8,16,32,or 64] based on the maximal value of A B = bitcount(A, bitValue, maxBits) the total # of bits to examine
MOM生产运营管理平台解决方案【35页PPT】
deli-数码录音电话机-HCD6238(28)P-TSD-使用说明书
Java项目基于ssm框架的课程设计,包含LW+ppt
Delphi 12.3控件之Tsilang 7.5.0.0 D12.7z
ios+UIButton分类+UIButton+UIButton图片文字位置
项目已获导师指导并通过的高分毕业设计项目,可作为课程设计和期末大作业,下载即用无需修改,项目完整确保可以运行。 该系统功能完善、界面美观、操作简单、功能齐全、管理便捷,具有很高的实际应用价值。 项目都经过严格调试,确保可以运行!可以放心下载
Java项目基于ssm框架的课程设计,包含LW+ppt
Delphi 12.3控件之TextEditorPro64.7z
尝试给OpenHarmony4.0增加可以在动态库中使用的日志模块 文章使用的资源,防止gitee资源丢失