1、/*byte转对象* param bytes* throws Exceptionpublic static Object bytesToObject（byte bytes） throws ExceptionByteArrayInputStream in = new ByteArrayInputStream（bytes）;ObjectInputStream sIn = new ObjectInputStream（in）;return sIn.readObject（）;定义一个消息类，主要用于接收消息内容和消息下表的设置。package com.bean;import java.io.Serial
2、izable;/*定义消息类接收消息内容和设置消息的下标* author lenovo*public class Message implements Serializableprivate static final long serialVersionUID = 7792729L;private int id;private String content;public int getId（） return id;public void setId（int id） this.id = id;public String getContent（） return content;public voi
3、d setContent（String content） this.content = content;利用redis做队列，我们采用的是redis中list的push和pop操作；结合队列的特点：只允许在一端插入新元素只能在队列的尾部FIFO：先进先出原则redis中lpush（rpop）或rpush（lpop）可以满足要求，而redis中list 里要push或pop的对象仅需要转换成byte即可java采用Jedis进行redis的存储和redis的连接池设置34353637383940414243444546474849505152535455565758596061626364656
4、667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617
5、717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627
6、727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637
7、737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647
8、7478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517package com.redis.util;import java.util.List;import java.util.Map;import java.util.Set;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.j
9、edis.JedisPoolConfig;public class JedisUtil private static String JEDIS_IP;private static int JEDIS_PORT;private static String JEDIS_PASSWORD;/private static String JEDIS_SLAVE;private static JedisPool jedisPool;static Configuration conf = Configuration.getInstance（）;JEDIS_IP = conf.getString（jedis.
10、ip, 127.0.0.1）;JEDIS_PORT = conf.getInt（jedis.port, 6379）;JEDIS_PASSWORD = conf.getString（jedis.password, null）;JedisPoolConfig config = new JedisPoolConfig（）;config.setMaxActive（5000）;config.setMaxIdle（256）;/20config.setMaxWait（5000L）;config.setTestOnBorrow（true）;config.setTestOnReturn（true）;config
11、.setTestWhileIdle（true）;config.setMinEvictableIdleTimeMillis（60000l）;config.setTimeBetweenEvictionRunsMillis（3000l）;config.setNumTestsPerEvictionRun（-1）;jedisPool = new JedisPool（config, JEDIS_IP, JEDIS_PORT, 60000）;/* 获取数据* param keypublic static String get（String key） String value = null;Jedis jed
12、is = null;try jedis = jedisPool.getResource（）;value = jedis.get（key）; catch （Exception e） /释放redis对象jedisPool.returnBrokenResource（jedis）;e.printStackTrace（）; finally /返还到连接池close（jedis）;return value;public static void close（Jedis jedis） jedisPool.returnResource（jedis）;if （jedis.isConnected（） jedis.
13、quit（）;jedis.disconnect（）;* public static byte get（byte key） byte value = null;public static void set（byte key, byte value） jedis.set（key, value）;public static void set（byte key, byte value, int time） jedis.expire（key, time）;public static void hset（byte key, byte field, byte value） jedis.hset（key, field, value）;public static void hset（String key, String field, String value） public static String hget（String key, String field） value = jedis.hget（key, field）;public static byte hget（byte key, byte field） value = jedis.hg
