`
tianzhihehe
  • 浏览: 20442 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

netty大并发请求问题

 
阅读更多

多线程并发使用同一个channel

java.nio.BufferOverflowException: null

at java.nio.HeapByteBuffer.put(HeapByteBuffer.java:183) ~[na:1.7.0_60-ea]

at java.nio.ByteBuffer.put(ByteBuffer.java:832) ~[na:1.7.0_60-ea]

at org.asynchttpclient.netty.NettyResponse.getResponseBodyAsByteBuffer(NettyResponse.java:81) ~[classes/:na]

at org.asynchttpclient.netty.NettyResponse.getResponseBodyAsBytes(NettyResponse.java:69) ~[classes/:na]

 

请求太多了,导致select key不足??

 这是由于nginx打开了太多文件导致,即并发量太大了。

java.net.ConnectException: connection timed out: /192.168.216.11:80

at org.asynchttpclient.netty.channel.NettyConnectListener.onFutureFailure(NettyConnectListener.java:137) [classes/:na]

at org.asynchttpclient.netty.channel.NettyConnectListener.operationComplete(NettyConnectListener.java:147) [classes/:na]

at org.asynchttpclient.netty.channel.NettyConnectListener.operationComplete(NettyConnectListener.java:1) [classes/:na]

at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:222) [netty-transport-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) [netty-transport-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) [netty-common-4.0.29.Final.jar:4.0.29.Final]

at java.lang.Thread.run(Thread.java:745) [na:1.7.0_60-ea]

分享到:
评论

相关推荐

    sprint boot整合netty5实现高并发websocket,不过netty5官网已经不推荐

    spring boot demo,整合netty5实现高并发websocket,并引入slf4g+lombok,采用maven形式; 直接导入运行,有测试页面也有实现代码及详细注释,src/main/webapps/TestNettyWebSocket.html里第十行改成 ws://localhost...

    浅析Netty,让高并发来的更猛烈些吧

    netty简单介绍,希望对你有所帮助

    Netty性能测试

    从测试结果看,Netty性能是非常高的,在所有使用默认配置的情况下,单台服务器能够达到4万次请求解析,作为RPC框架是足够用的。

    Netty结合SpringBoot 处理http请求示例源码

    Netty结合SpringBoot 处理http请求示例源码,适合对Netty有学习兴趣的同学,这种技术的组合充分利用Netty技术特点,提高项目的并发量以及性能

    高清Netty5.0架构剖析和源码解读

    当并发访问量增大、响应时间延迟变大后, 采用JAVABIO作为服务端的软件只有通过硬件不断的扩容来满足访问量的激 增,它大大增加了企业的成本,随着集群的膨胀,系统的可维护性也面临巨大 的挑战,解决这个问题已经...

    Sekhemet:高并发聊天室(Netty +WebSocket)

    Netty 和 WebSocket 实现的即时聊天服务聊天协议versionheadbodyextend版本头部消息内容其它协议字段实现功能登录WebSocket长连接,实时更新消息多人在线文本和表情消息发送定时心跳检测服务器逻辑客户端/用户连接到...

    基于springboot+netty+mybatis+hbase+kafka实现的socket server+源代码+文档说明

    - [ ] socket client接受到请求数据的命令后,从mysql中读取假数据,伪造成真实设备传输的数据格式,并发送给socket server - [ ] socket server接收到返回的数据后,分别写入到hbase数据库和kafka队列中 - [ ] 最后...

    netty-starter:Netty权威指南学习之旅

    同步阻塞式I/O存在的问题:每当有一个新的客户端请求接入时,服务端必须创建一个新的线程处理新接入的客户端链路,一个线程只能处理一个客户端连接。在高性能服务器应用领域,往往需要成千上万个客户端的并发连接,

    Netty 是如何支撑高性能网络通信的.docx

    该架构最大的问题就是不具备弹性伸缩能力,当并发访问量增加后,服务端的线程个数和并发访问数成线性正比,由于线程是 Java 虛拟机 非常宝贵的系统资源,当线程数膨胀之后,系统的性能急剧下降,随着并发量的继续...

    nettythrift:Netty节俭,在同一端口上支持TCPHTTPWebSocket。 同时支持多种协议。 具有连接池的多个简单客户端

    nettythrift en: A Java Server IO framework use netty and thrift. ...or send compactProtocol thrift data ...项目经过了线上高并发的考验. Server Example public void startServer() { // different from nify,

    BIO,NIO,AIO,Netty面试题 35道.pdf

    BIO:同步并阻塞,服务器实现一个连接一个线程,即客户端有连接请求时服务器端就需要启动一 个线程进行处理,没处理完之前此线程不能做其他操作(如果是单线程的情况下,我传输的文件很 大呢?),当然可以通过...

    http-client:基于Netty的Java高性能面向吞吐量的HTTP客户端库

    建立在 Netty 之上,专为高并发场景而设计,其中多个线程可以使用同一个客户端实例,而无需担心外部或内部同步,它可以帮助您减少初始化和/或准备时间以及资源浪费。 在许多小的优化中,只要有可能就重用连接,这...

    Unirest轻量级的HTTP开发库 v3.14.2

    Unirest是一个轻量级的HTTP请求库,...7.自定义超时,并发级别和代理设置。 8.为每个请求自定义默认请求头。 9.自定义HttpClient和HttpAsyncClient 10.自动解析JSON 11.自定义的将返回的json数据转换成Java对象。

    moja:moja(熔岩流)是一个跨平台,支持高并发,可集群部署的日志消息队列系统。使用到了Netty,Protobuf,JSON,MongoDB,HDFS,Zookeeper等技术

    1.使用Netty来处理消息生产者的socket请求 2.使用Netty的PB模块处理protobuf协议 3.日志消息队列使用多线程消费,当到达警告数量,持久化部分日志到本地,定时扫描本地日志目录,将日志载入到消息队列中 3.存储端可...

    煤矿设备状态监测系统设计-论文

    采用Netty网络传输模型避免空轮询导致的服务器负载增加,提高监测数据传输效率:在数据采集过程中,多个设备同时作业导致数据采样频率和传感器终端的并发请求数量升高,Netty模型中的Epoll模式优先处理已就绪的I/O...

    dabao-netty:用于远程数据传输的网络项目

    用于远程数据传输的Netty项目 值得关注的事情 稳定-服务器将始终处于联机状态 并发-用例表明,许多用户可能在流量高峰期并发发送数据服务器 持久性-最后需要安全地持久存储数据以进行进一步分析(离线和在线) 协议...

    java开源包3

    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...

    2019年毕业设计-一款情侣APP 附论文、作品视频演示、代码

    关键技术 1、Spring Boot是目前主流的以...4、为提供后端接口服务机器之间共享Session,为增强系统并发访问,降低请求延时,对热点数据进行缓存,本系统引入Redis提供数据缓存层。 5、即时在线聊天选择Netty框架。

    java卡牌游戏源码-HTTPServer:基于Netty、JSON-RPC的分布式弱联网游戏服务端

    java卡牌游戏源码 ...我们项目没有采用Tomcat开发HTTP服务端,而是采用Netty开发HTTP服务端,Netty作为开源NIO框架,提供异步的、事件驱动的网络应用程序框架,能够支持大量用户并发行为。 架构发展 1

    PrimitiveBank:简单的并发HTTP服务

    作为测试项目写在Netty上。 接受的请求: “ GET / account / 111”以请求余额,其中“ 111”是数字帐户标识符; “ POST /帐户/ 111 /存款”-用于存款到帐户,“ 111”-数字帐户标识符; “ POST /帐户/ 111 /...

Global site tag (gtag.js) - Google Analytics