- 浏览: 923896 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
hw7777777:
非常感谢作者提供这么好的工具,在使用的过程中遇到一些问题?1、 ...
基于java nio的memcached客户端——xmemcached -
SINCE1978:
多久过去了时间能抹平一切
无路用的人 -
fangruanyjq:
[img][/img]引用
用osworkflow写一个请假例子(提供代码下载) -
thinkingmysky:
楼主,你确定,java memached client能处理并 ...
memcached java client性能测试的几点疑问和说明 -
hellostory:
aaa5131421 写道07年2月hibernate已经出来 ...
dozer与BeanUtils
yanf4j
发布一个0.50-beta2
版本,这个版本最重要的改进就是引入了客户端连接非阻塞AP
I,主要最近的工作要用到,所以添加了。两个核心类TCPConnectorController
和UDPConnectorController
分别用于TCP和UDP的客户端连接控制。例如,现在的UDP echo client可以写成:
class EchoClientHandler extends HandlerAdapter {
public void onReceive(Session udpSession, Object t) {
DatagramPacket datagramPacket = (DatagramPacket) t;
System.out.println( " recv: " + new String(datagramPacket.getData()));
}
@Override
public void onMessageSent(Session session, Object t) {
System.out.println( " send: " + new String(( byte []) t));
}
}
// 连接代码,并发送UDP包
UDPConnectorController connector = new UDPConnectorController();
connector.setSoTimeout( 1000 );
connector.setHandler( new EchoClientHandler());
connector.connect( new InetSocketAddress(InetAddress.getByName(host),
port));
for ( int i = 0 ; i < 10000 ; i ++ ) {
String s = " hello " + i;
DatagramPacket packet = new DatagramPacket(s.getBytes(), s.length());
connector.send(packet);
}
UDP不是面向连接的,因此connect方法仅仅是调用了底层DatagramChannel.connect方法,用来限制接收和发送的packet的远程端点。
再来看看TCPConnectorController的使用,同样看Echo Client的实现:
class EchoHandler extends HandlerAdapter < String > {
@Override
public void onConnected(Session session) {
try {
// 一连接就发送NUM个字符串
for ( int i = 0 ; i < NUM; i ++ )
session.send(generateString(i));
} catch (Exception e) {
}
}
public String generateString( int len) {
StringBuffer sb = new StringBuffer();
for ( int i = 0 ; i < MESSAGE_LEN; i ++ )
sb.append(i);
return sb.toString();
}
@Override
public void onReceive(Session session, String t) {
// 打印接收到字符串
if (DEBUG)
System.out.println( " recv: " + t);
}
}
// ...连接API,TCPConnectorController示例
Configuration configuration = new Configuration();
configuration.setTcpSessionReadBufferSize( 256 * 1024 ); // 设置读的缓冲区大小
TCPConnectorController connector = new TCPConnectorController(configuration,
new StringCodecFactory());
connector.setHandler( new EchoHandler());
connector.setCodecFactory( new StringCodecFactory());
try {
connector.Connect( new InetSocketAddress( " localhost " , 8080 ));
} catch (IOExceptione) {
e.printStackTrace();
}
注意,connect方法并不阻塞
,而是立即返回,连接是否建立可以通过TCPConnectorController.isConnected()方法来判断,因此通常你可能会这样使用:
connector.Connect( new InetSocketAddress( " localhost " , 8080 ));
while ( ! connector.isConnected())
;
} catch (Exception e) {
e.printStackTrace();
}
来强制确保后面对connector的使用是已经连接上的connector,然而更好的做法是在Handler的onConnected()回调方法中处理逻辑,因为这个方法仅仅在连接建立后才会被调用。
两个ConnectorController都有系列send方法,用于发送数据:
UDPConnectorController.send(DatagramPacket packet) throws InterruptedException
UDPConnectorController.send(SocketAddress targetAddr, Object msg) throws InterruptedException
0.50-beta2带来的另一个修改就是Session接口添加setReadBufferByteOrder
方法,用于设置session接收缓冲区的字节序,默认是网络字节序,也就是大端法。这个方法建议在Handler的onSessionStarted回调方法中调用。
在0.50-beta最重要的修改是引入了session发送队列缓冲区的流量控制选项
。默认情况下,session的发送缓冲队列是无界的,队列的push和pop也全然不会阻塞。在设置了缓冲队列的高低水位选项后即引入了发送流量控制,规则如下:
a)当发送队列中的数据总量大于高水位标记(highWaterMark),Session.send将阻塞
b)在条件a的作用下,Session.send的阻塞将持续到发送队列中的数据总量小于于低水位标记(lowWaterMark)才解除。
缓冲队列高低水位的设置通过Controller的下列方法设置:
public void setSessionWriteQueueLowWaterMark( int lowWaterMark);
缓冲队列的流量控制想法来自ACE的ACE_Message_Queue,是通过com.google.code.yanf4j.util.MessageQueue类实现的。
0.50-beta还引入了Session.send(Object msg)的重载版本 Session.send(Object msg,long timeout),在超过timeout时间后send仍然阻塞时即终止send。注意,现在Session.send的这两个方法都返回一个bool值来表示send成功与否,并且都将响应中断(仅限启动了流量控制选项)抛出InterruptedException。
发表评论
-
memcached分布测试报告(一致性哈希情况下的散列函数选择)
2009-03-10 16:30 8417一、背景资料 memcached本身是集中式的缓存系统 ... -
xmemcached 0.60 优化过程
2009-03-06 14:37 3387充分利用jprofile等 ... -
Xmemcached vs Spymemcached 3th(linux下测试结果和多节点下表现)
2009-03-07 10:43 4740翠花,上图,首先是容器类和自定义对象的get、set在不同并发 ... -
xmemcached发布1.0-BETA版
2009-03-09 15:32 3977xmemcached 发布1.0-beta ,从0.6 ... -
山寨nio框架yanf4j发布0.50-alpha
2009-02-04 19:28 4124俺的山寨nio框架yanf4j发布0.50-alpha版本,下 ... -
基于java nio的memcached客户端——xmemcached
2009-03-03 16:31 72961、xmemcached是什么? xmemcached是基于 ... -
使用yanf4j写个简单聊天室
2008-11-26 11:36 5360yanf4j 简介,请看这里 ... -
Java字符串的最大长度
2009-01-15 01:37 7521在cpp中为了可移植性,s ... -
yanf4j-0.41 beta发布
2009-01-20 14:01 1805项目名称:yanf4j (yet another nio fr ... -
再谈Selector的wakeup方法
2009-02-01 11:15 3000过去推荐过两篇blog《Java NIO类库Selector机 ... -
Yet another nio framework for java
2008-10-11 14:25 1954项目名称:Yanf4j(Yet another nio fra ... -
阻塞队列的性能对比
2008-09-08 10:06 5688阻塞队列的性能对 ... -
java package的设计原则
2008-09-06 00:15 2075典型的J2EE项目,package的设计有成熟的套路可 ... -
线程池池
2008-09-01 19:39 1955这个题目比较怪,听俺道来。俺一直在负责公司游戏服 ... -
第一个MapReduce任务
2008-08-23 11:10 2740前两天在公司内网上搭了个2个节点hadoop集群, ... -
从HDFS看分布式文件系统的设计需求
2008-08-15 22:39 8041分布式文件系统的 ... -
HDFS用户指南(翻译)
2008-08-14 20:27 2096HDFS用户指南 原文地址:http:/ ... -
Ehcache配置的overflowToDisk属性
2008-08-06 23:18 10754Ehcache的overflowToDisk属性用来配 ... -
工作的几个tip
2008-07-07 20:47 28231、如果用java6的ScriptEngineManager ... -
NIO的SelectableChannel关闭的一个问题
2008-06-18 01:53 7107SocketChannel和ServerSocket ...
相关推荐
It's nio based (using my opensource nio framework :yanf4j), and was carefully tuned to get top performance. homepage: http://code.google.com/p/xmemcached/ downloads; ...
Yanf打开一个配置文件,对其进行读取,从其上的站点中获取新闻,然后将其放在类似于slashdot的网页中。 它支持Slashdot,Freshmeat。 32bitsonline,Segfault,Packetstorm,Linuxtelephony,Linuxtoday,Ufie,RDF...
全球最高品质的音乐播放器 各种不解释 懂的下:)
免费分享。
城市GDP.npz
基于深度特征映射的语音增强方法 本项目为可以利用DNN和CNN的方法来进行语音增强,其中DNN使用的三个隐层每个隐层512个节点,CNN使用的是R-CED的网络结构并且加入了一些resnet来防止过拟合。你也可以选择是否使用dropout或者l2等。 使用: 第一步. 运行 ex_trac.sh 数据准备并将数据分成训练集和交叉验证集,然后提取 log spectragram 特征. 第二步. 运行 train.sh 来训练和测试模型. 第三步. 运行 ca_pesq.sh 使用PESQ来评价你的结果。
本期课程将继续探索iPad水彩胶带绘画技巧,以昭春落日为主题,引导学员掌握绘画技巧和色彩运用,创作独特的水彩作品。通过实践与指导,学员将提升绘画技能,感受艺术的魅力,展现个性化创作,享受绘画带来的乐趣与成就感。 课程大小:8.6G
永磁起重器使用与维护手册
机械设计测漏机sw21可编辑非常好的设计图纸100%好用.zip
纵横科技产品服务手册 FPM120TC-T 说明书
如何提升产品的广告变现效率?.docx
机械设计灯板自动插线设备sw18可编辑非常好的设计图纸100%好用.zip
pantPullDownLora_pantpulldownV1
【基于Alexnet对7种小麦叶片病害分类】 【包含代码、数据集和训练好的权重文件,可直接运行】 项目总大小:640 MB 本数据集分为以下7类别:水泡,褐色斑点等等 下载解压后的图像目录:训练集(16,149张图片)、和测试集(678张图片) data-train 训练集-每个子文件夹放同类别的图像,文件夹名为分类类别 data-test 测试集-每个子文件夹放同类别的图像,文件夹名为分类类别 【项目介绍】 网络训练的时候采用cos 学习率自动衰减,简单测试了10个epoch。模型在测试集最好的表现达到88.9%精度,加大epoch可以增加精度。在run_results 目录下存有最好的权重文件,以及训练日志和loss、精度曲线等等 预测的时候,只需要运行predict即可,代码会自动将inference下所有图片推理,并取前三个概率最大类别的绘制在左上角 【训练自己的数据参考readme文件,不需要更改,代码会自动生成,例如分类类别个数等等】
lactation_v10
httpsyy70958.com29875videoplayvid45958.m3u8..m3u
机械设计VFFS Makinesi-1包装机sw14非常好的设计图纸100%好用.zip
基于Spring Boot的医院管理系统涉及多个功能模块,如病人管理、医生管理、预约挂号、医疗记录管理。以下是一个基本的设计和实现建议: 1. 数据库设计:设计合适的数据库模式来存储医院相关的信息,如病人信息、医生信息、预约信息等。可以使用关系型数据库(如MySQL、PostgreSQL)或非关系型数据库(如MongoDB。 2. 后端(Spring Boot)部分: - 定义实体类:根据数据库设计,在后端定义实体类来映射数据库中的表结构。 - 数据访问层(DAO):使用Spring Data JPA或者MyBatis等技术,编写数据访问层代码,用与数据库进行交互,包括增删改查等操作。 - 业务逻辑层(Service):定义业务逻辑,包括对病人、医生、预约等信息的管理和操作。可以使用@Service注解标识这些服务类,并在其中注入相应的DAO层组件。 - 控制器层(Controller):使用@RestController注解标记控制器类,定义各个接口以供前端调用。在接口中处理请求、调用服务层处理业务逻辑,并返回相应的数据。 3. 前端部分: - 页
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
php-8.2.18-Win32-vs16-x64.rar