微信推送消息排重解决办法

 微信公众平台开发时，微信推送消息的机制是推送过来后如果5秒内收不到响应则认为没有推送成功，会再次推送，如果5秒内仍没有收到响应继续推送，总共推送三次。

微信文档原文：

普通消息

1、关于重试的消息排重，推荐使用msgid排重。
2、微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次。假如服务器无法保证在五秒内处理并回复，可以直接回复空串，微信服务器不会对此作任何处理，并且不会发起重试。

 

事件推送：

微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次

关于重试的消息排重，推荐使用FromUserName + CreateTime 排重。

假如服务器无法保证在五秒内处理并回复，可以直接回复空串，微信服务器不会对此作任何处理，并且不会发起重试。

 

 

我的解决方案：

1.创建判断重复消息的DuplicateRemovalMessage类；

2.把微信推送的消息解析赋值给DuplicateRemovalMessage对象实例；

3.用静态变量list当缓存，判断DuplicateRemovalMessage实例是否存在于缓存list中，如果存在则为重复消息，如果不存在则不是重复消息并把消息放到缓存list中。

 

此方案弊端：

1.缓存list会无限增大，所以用setMessageToCache方法限制了list最大容量为1000；

2.解决了list最大容量依然还有弊端，就是两条重复的消息之间如果有超过999个DuplicateRemovalMessage对象依然会判断不准，只能增大list容量来缓解，由于这种情况比较极端，目前远没有那么大业务量，所以暂时这么用着了。

 

大家有什么好的解决方案一起交流，欢迎拍砖。

 

下面是具体实现代码：

注意：DuplicateRemovalMessage别忘记复写hashcode、equals方法 

 

private static final int MESSAGE_CACHE_SIZE = 1000;
	private static List<DuplicateRemovalMessage> MESSAGE_CACHE = new ArrayList<DuplicateRemovalMessage>(MESSAGE_CACHE_SIZE);

	/**
	 * @Description: 判断微信请求是否重复
	 * @return boolean 如果重复返回true
	 */
	public static boolean isDuplicate(Map<String, String> request) {
		String fromUserName = request.get("FromUserName");
		String createTime = request.get("CreateTime");
		String msgId = request.get("MsgId");

		DuplicateRemovalMessage duplicateRemovalMessage = new DuplicateRemovalMessage();

		if (msgId != null) {
			duplicateRemovalMessage.setMsgId(msgId);
		} else {
			duplicateRemovalMessage.setCreateTime(createTime);
			duplicateRemovalMessage.setFromUserName(fromUserName);
		}

		if (MESSAGE_CACHE.contains(duplicateRemovalMessage)) {
			// 缓存中存在，直接pass
			return true;
		} else {
			setMessageToCache(duplicateRemovalMessage);
			return false;
		}
	}
	private static void setMessageToCache(DuplicateRemovalMessage duplicateRemovalMessage) {
		if (MESSAGE_CACHE.size() >= MESSAGE_CACHE_SIZE) {
			MESSAGE_CACHE.remove(0);
		}
		MESSAGE_CACHE.add(duplicateRemovalMessage);
	}

 

 

DuplicateRemovalMessage对象：

 

public class DuplicateRemovalMessage {

	private String MsgId;
	
	private String FromUserName;
	
	private String CreateTime;

	@Override
	public int hashCode() {
		final int prime = 31;
		int result = 1;
		result = prime * result + ((CreateTime == null) ? 0 : CreateTime.hashCode());
		result = prime * result + ((FromUserName == null) ? 0 : FromUserName.hashCode());
		result = prime * result + ((MsgId == null) ? 0 : MsgId.hashCode());
		return result;
	}

	@Override
	public boolean equals(Object obj) {
		if (this == obj)
			return true;
		if (obj == null)
			return false;
		if (getClass() != obj.getClass())
			return false;
		DuplicateRemovalMessage other = (DuplicateRemovalMessage) obj;
		if (CreateTime == null) {
			if (other.CreateTime != null)
				return false;
		} else if (!CreateTime.equals(other.CreateTime))
			return false;
		if (FromUserName == null) {
			if (other.FromUserName != null)
				return false;
		} else if (!FromUserName.equals(other.FromUserName))
			return false;
		if (MsgId == null) {
			if (other.MsgId != null)
				return false;
		} else if (!MsgId.equals(other.MsgId))
			return false;
		return true;
	}

	
	public String getMsgId() {
		return MsgId;
	}

	public void setMsgId(String msgId) {
		MsgId = msgId;
	}

	public String getFromUserName() {
		return FromUserName;
	}

	public void setFromUserName(String fromUserName) {
		FromUserName = fromUserName;
	}

	public String getCreateTime() {
		return CreateTime;
	}

	public void setCreateTime(String createTime) {
		CreateTime = createTime;
	}
	@Override
	public String toString() {
		StringBuilder builder = new StringBuilder();
		builder.append("DuplicateRemovalMessage [MsgId=");
		builder.append(MsgId);
		builder.append(", FromUserName=");
		builder.append(FromUserName);
		builder.append(", CreateTime=");
		builder.append(CreateTime);
		builder.append("]");
		return builder.toString();
	}

}

 

 

 

评论

4 楼 lief 2018-10-09  

iteye的文章无法编辑，该方案的所有改动和完善在知乎上回答过，参考链接：当微信服务器给我的URL发送多次同一请求，怎样实现排重？ - 李一峰的回答 - 知乎
https://www.zhihu.com/question/22685171/answer/68281207

3 楼 lief 2017-11-14  

记错了，刚去看了一眼微信文档，微信推送消息超时的时间是5秒。

2 楼 lief 2017-11-14  

as499745582as 写道

我想问的是，如果判断是重复消息了，要怎么做？返回空吗？这样微信是不会继续发信息了，但是我们之前的请求的回复信息不是也发不给微信服务器吗？这个问题想了很久，没有想到解决的方法， 还请博主指点指点

很抱歉，很久没登录博客，刚刚看到你的回复。我捋一下这个逻辑，微信推送消息被我们识别为重复消息→说明之前我们的系统已经收到过相同的消息，微信重复推送这条消息给我们说明之前推给我们的消息都没有得到回复，这里面最大的可能性就是由于种种原因我们服务器处理消息并返回结果给微信时间超过了3秒，导致了微信重复推送。解决办法就是：1、将微信推送消息的处理代码执行时间控制在3秒之内；2、如果处理微信消息的业务确实无法缩短执行时间了，可以改成异步操作，操作完成后使用【客服消息】接口向用户发送结果（当然必须是服务号才有权限使用该接口）。

1 楼 as499745582as 2017-04-18  

我想问的是，如果判断是重复消息了，要怎么做？返回空吗？这样微信是不会继续发信息了，但是我们之前的请求的回复信息不是也发不给微信服务器吗？这个问题想了很久，没有想到解决的方法， 还请博主指点指点