需求：坐席排隊(duì)? 五秒之內(nèi)沒請求接口認(rèn)為用戶不在排隊(duì) 從內(nèi)存移除

redis用作消息隊(duì)列

1)實(shí)現(xiàn)過程： 用戶請求接口??查詢坐席有沒有空閑，坐席沒有空閑 繼續(xù)排隊(duì)???如果有 查詢r(jià)edis中有沒有預(yù)先排隊(duì)的用戶??如果有 判斷是否是隊(duì)列中第一請求的用戶，如果是分配坐席，如果不是 更新隊(duì)列中的時(shí)間

2)添加一個(gè)定時(shí)任務(wù)類 每三百毫秒刷新一次? 查詢隊(duì)列中有沒有超時(shí)的用戶 超時(shí)之后將其移除

檢測坐席是否為空閑狀態(tài)

如果有空閑坐席 通過websocket 發(fā)送給客戶端消息 將坐席狀態(tài)修改為2,請查看 ocatedseat 方法

比較麻煩的幾點(diǎn)：

1)添加用戶到隊(duì)列中返回添加隊(duì)列的值(這個(gè)是lpush返回的)然后吧當(dāng)前的值 和用戶請求過來的唯一id存到redis 中 以備 刷新時(shí)間用

long userindex = redisTemplate.opsForList().leftPush("GROUP_SEQUEUE_" + agent_group,JSONObject.toJSONString(map));

redisTemplate.opsForValue().set(uniqueid, String.valueOf(userindex));

2)刷新用戶時(shí)間：取出隊(duì)列的size 減去 第一步 存到redis中的值? 然后修改隊(duì)列中用戶的時(shí)間

long size = redisTemplate.opsForList().size("GROUP_SEQUEUE_" + agent_group);

String index = redisTemplate.opsForValue().get(uniqueid);

long sub = size - Integer.parseInt(index);

redisTemplate.opsForList().set("GROUP_SEQUEUE_" + agent_group,sub, JSONObject.toJSONString(map));

3)坐席狀態(tài)同步問題

weibsocket 心跳 必須與 狀態(tài)分開來發(fā)送否則會出現(xiàn)， 服務(wù)端發(fā)送給客戶端狀態(tài)為分配中時(shí) 而 客戶端在接受到的時(shí)候會有時(shí)間間隔，在這個(gè)間隔的時(shí)候 客戶端會發(fā)送之前的狀態(tài)給服務(wù)端 造成狀態(tài)不一致問題

public void handleMessage(WebSocketSession session,WebSocketMessage>message){

//解析message 修改坐席狀態(tài)

try{

User user = (User)session.getAttributes().get("user");

String state = message.getPayload().toString();

JSONObject json = JSONObject.parseObject(state);

String type = (String) json.get("type");

Object state1 = json.get("status");

String name = (String) json.get("name");

if("0".equals(type)){

//修改狀態(tài)

if(Integer.parseInt(state1.toString())==0){

redisTemplate.opsForSet().remove("OCATED", user.getUserid().toString());

}

redisTemplate.opsForList().remove("GROUP_"+user.getGroupid(), 0, JSONObject.toJSONString(user));

user.setState(Integer.parseInt(state1.toString()));

user.setNext_hop("123.57.144.26:9060/udp");

user.setTo("");

redisTemplate.opsForList().leftPush("GROUP_"+user.getGroupid(), JSONObject.toJSONString(user));

logger.info("收到坐席{}發(fā)來得消息！當(dāng)前狀態(tài)為：{} ",user.getUserid(),state1,DateUtil.formateDate(new Date(), "yyyy-MM-dd HH:mm:ss"));

}else if("1".equals(type)){

//只檢測坐席是否掉線

this.hart.put(user, new Date());

// session.sendMessage(new TextMessage(JSONObject.toJSONString(user)+" "+new Date()));

}else if("2".equals(type)){

//會話接通 保存到redis中 定時(shí)插入數(shù)據(jù)庫

boolean flag = false;

Conversation con = new Conversation();

String reportnum = (String) json.get("reportnum");

String carnum = (String) json.get("carnum");

List str = redisTemplate.opsForList().range("conversation", 0, -1);

for(String s : str){

JSONObject j = JSONObject.parseObject(s);

con = JSONObject.toJavaObject(j,Conversation.class);

if(con.getCarnum().equals(carnum) && con.getReportnum().equals(reportnum)){

flag = true;

}

}

if(flag){

//已經(jīng)保存過一次

Long endtime = (Long) json.get("endtime");

con.setEndtime(DateUtil.timestampToDate(endtime.toString()));;

}else{

Long starttime = (Long) json.get("starttime");

con.setUserid(user.getUserid());

con.setCarnum(carnum);

con.setStarttime(DateUtil.timestampToDate(starttime.toString()));

con.setReportnum(reportnum);

}

redisTemplate.opsForList().leftPush("conversation", JSONObject.toJSONString(con));

}else{

session.sendMessage(new TextMessage("參數(shù)錯(cuò)誤！"));

}

}catch(Exception e){

logger.error(e.getMessage(),e);

}

}

下面奉上代碼

1、controller

package com.cloudunicomm.controller;

import java.io.IOException;

import java.io.OutputStream;

import java.text.ParseException;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Bean;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.socket.WebSocketSession;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.cloudunicomm.interceptor.MySocketHandler;

import com.cloudunicomm.utils.DateUtil;

import com.cloudunicomm.vo.User;

@Controller

public class FreeController {

private static final Logger logger = LoggerFactory.getLogger(FreeController.class);

@Autowired

private RedisTemplate redisTemplate;

@Bean

public MySocketHandler mySorketHandle() {

return new MySocketHandler();

}

@RequestMapping(value = "agent_service", method = RequestMethod.GET)

@ResponseBody

public void agentservice(HttpServletRequest request, HttpServletResponse response,

@RequestParam(name = "customer_id", required = false) String customer_id,

@RequestParam(name = "agent_group", required = false) String agent_group,

@RequestParam(name = "uniqueid", required = false) String uniqueid) throws IOException, ParseException {

//logger.info("組:{}---用戶:{}----唯一id:{}過來請求接口！",agent_group,customer_id,uniqueid);

StringBuffer sb = new StringBuffer();

OutputStream out = response.getOutputStream();

response.setHeader("Content-Disposition", "attachment; filename=" + DateUtil.getDate() + ".ini");

sb.append("reply_code=200\r\n").append("reply_reason='OK'\r\n");

//查詢有沒有空閑坐席

List users = redisTemplate.opsForList().range("GROUP_" + agent_group, 0, -1);

for (String s : users) {

User user = (User) JSONObject.toJavaObject(JSONObject.parseObject(s), User.class);

Boolean aa = redisTemplate.opsForSet().isMember("OCATED", user.getUserid().toString());

if (user.getState() == 0 && aa==false) {

//查詢有沒有排隊(duì)用戶

List lists = redisTemplate.opsForList().range("GROUP_SEQUEUE_" + agent_group, 0, -1);

if (lists.size() > 0) {

String str = lists.get(lists.size() - 1);

Set> obj = JSON.parseObject(str).entrySet();

for (Entry s1 : obj) {

if (s1.getKey().split("_")[1].equals(uniqueid)) {

redisTemplate.opsForList().remove("GROUP_SEQUEUE_"+agent_group, 0, JSONObject.toJSONString(s1));

this.ocatedseat(agent_group, user, customer_id, uniqueid);

sb.append("next_hop="+user.getNext_hop()+"\r\n");

sb.append("To="+user.getTo());

out.write(sb.toString().getBytes());

out.flush();

out.close();

return ;

//return ResultMessage.getSuccess().setMessage("已分配作息！");

}

}

}else{

this.ocatedseat(agent_group, user, customer_id, uniqueid);

sb.append("next_hop="+user.getNext_hop()+"\r\n");

sb.append("To="+user.getTo());

out.write(sb.toString().getBytes());

out.flush();

out.close();

return ;

}

}

}

String exit = redisTemplate.opsForValue().get(agent_group+"_"+uniqueid);

if(null == exit){

//沒有

this.adduserqueue(agent_group, uniqueid);

//return ResultMessage.getSuccess().setMessage("請等待！");

sb.append("retry_wait=5s");

out.write(sb.toString().getBytes());

out.flush();

out.close();

return;

}else{

//return ResultMessage.getSuccess().setMessage("繼續(xù)等待");

this.resettime(agent_group, uniqueid);

sb.append("retry_wait=5s");

out.write(sb.toString().getBytes());

out.flush();

out.close();

return;

}

}

/**

* 重置時(shí)間

* @param agent_group

* @param uniqueid

*/

public void resettime(String agent_group,String uniqueid){

Map map = new HashMap<>();

map.put(agent_group + "_" + uniqueid, new Date());

long size = redisTemplate.opsForList().size("GROUP_SEQUEUE_" + agent_group);

String index = redisTemplate.opsForValue().get(agent_group+"_"+uniqueid);

long sub = size - Integer.parseInt(index);

redisTemplate.opsForList().set("GROUP_SEQUEUE_" + agent_group,sub, JSONObject.toJSONString(map));

}

/**

* 添加用戶到隊(duì)列中

* @param map

* @param agent_group

* @param uniqueid

*/

public void adduserqueue(String agent_group,String uniqueid){

logger.info("組{}唯一{} 加入隊(duì)列",agent_group,uniqueid);

Map map = new HashMap<>();

map.put(agent_group + "_" + uniqueid, new Date());

long userindex = redisTemplate.opsForList().leftPush("GROUP_SEQUEUE_" + agent_group,JSONObject.toJSONString(map));

redisTemplate.opsForValue().set(agent_group+"_"+uniqueid, String.valueOf(userindex));

}

public void ocatedseat(String agent_group,User user ,String customer_id,String uniqueid) throws ParseException{

redisTemplate.opsForSet().add("OCATED", user.getUserid().toString());

user.setState(2);

WebSocketSession session = MySocketHandler.sessionid.get(user.getUserid().toString());

mySorketHandle().pushMsg(session.getId(), "2");

updateIndex(agent_group,uniqueid);

//sb.append(user.getNext_hop() + "\r\n").append(user.getTo());

logger.info("坐席{}正在被分配給{} ！ {}", user.getUserid(),uniqueid,DateUtil.formateDate(new Date(), "yyyy-MM-dd HH:mm:ss"));

}

/**

* 更新索引值

* @param agent_group

* @param uniqueid

*/

private void updateIndex(String agent_group, String uniqueid) {

Set index = redisTemplate.keys(agent_group+"_*");

//比較的value

String comvalue = redisTemplate.opsForValue().get(agent_group+"_"+uniqueid);

for(String s : index ){

int l = Integer.parseInt(redisTemplate.opsForValue().get(s));

if(l>Integer.parseInt(comvalue)){

int reslu = l-1;

redisTemplate.opsForValue().set(s,String.valueOf(reslu));

}

}

redisTemplate.delete(agent_group+"_"+uniqueid);

}

}

2、定時(shí)任務(wù)

package com.cloudunicomm.task;

import java.text.ParseException;

import java.util.Date;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Set;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;

/**

* 檢測redis中過期的key

* @Title： CheckRedisKeyExpireTask.java

* @date： 2018年6月29日

* @author： zhangdong

* @version： v1.0

* @Description

*/

@Component

public class CheckRedisKeyExpireTask {

private static final Logger logger = LoggerFactory.getLogger(CheckRedisKeyExpireTask.class);

@Autowired

private RedisTemplate redisTemplate;

@Scheduled(cron="0/2 * * * * ? ") //每秒執(zhí)行一次

//@Scheduled(fixedRate=3000)

public void job() throws ParseException {

//logger.info("開始檢測有沒有過期的key "+DateUtil.formateDate(new Date(), "yyyy-MM-dd HH:mm:ss"));

Set set = redisTemplate.keys("GROUP_SEQUEUE_*");

for(String s:set){

List sss = (List) redisTemplate.opsForList().range(s, 0, -1);

for(String m : sss){

Map maps = (Map)JSON.parse(m);

for(Entry entry : maps.entrySet()){

long start = entry.getValue();

long end = new Date().getTime();

if(end-entry.getValue()>500000){

//超時(shí) 從redis中移除

String[] keys = entry.getKey().toString().split("_");

redisTemplate.opsForList().remove("GROUP_SEQUEUE_"+keys[0], 0, maps.toString());

redisTemplate.delete(entry.getKey());

logger.info("組{}中的值{}已超過{}秒,將其移除！","GROUP_SEQUEUE_"+keys[0],maps.toString(),50);

}

}

}

}

}

}

總結(jié)

以上是生活随笔為你收集整理的坐席排序java_坐席排队功能 - osc_sd6j22mg的个人空间 - OSCHINA - 中文开源技术交流社区...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。