本文介绍了Java利用复述,实现消息队列的示例代码,分享给大家,具体如下:
<强>应用场景
为什么要用复述,# 63;
二进制存储,java序列化传输,IO连接数高,连接频繁
这里编写了一个java序列化的工具,主要是将对象转化为字节数组,和根据字节数组反序列化成java对象;主要是用到了ByteArrayOutputStream和ByteArrayInputStream;注意:每个需要序列化的对象都要实现可序列化的接口;
其代码如下:
包跑龙套,
进口. io . *;/* *
*由Kinglf>
包模型;
进口java.io.Serializable;/* *
*由Kinglf>
包跑龙套,
进口redis.clients.jedis.Jedis;
进口redis.clients.jedis.JedisPool;
进口redis.clients.jedis.JedisPoolConfig;
进口并不知道;
进口java.util.Map;
进口java.util.Set;/* *
*由Kinglf>
包跑龙套,
进口java.io.IOException;
进口java.io.InputStream;
进口java.util.Properties;/* *
*由Kinglf>
进口Model.Message;
进口Utils.JedisUtil;
进口Utils.ObjectUtil;
进口redis.clients.jedis.Jedis;
进口java.io.IOException;/* *
*由Kinglf>
每执行一次pop()方法,结果如下:
& lt; br> 1 - - - - -这是第1个内容
& lt; br> 2 - - - - -这是第2个内容
& lt; br> 3 - - - - -这是第3个内容
& lt; br> 4 - - - - -这是第4个内容
至此,整个复述,消息队列的生产者和消费者代码已经完成
1。消息需要传送的实体类(需实现可序列化的接口)
2。配置复述的配置读取类,继承自属性
3。ObjectUtil将对象和字节数组双向转换的工具类
4。能通过消息队列的先进先出(FIFO)的特点结合复述的列表中的push和pop操作进行封装的工具类
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
