代码优化

mpusher · Feb 18, 2016 · ac3167e · ac3167e
1 parent 8749831
commit ac3167e
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 30 deletions.
diff --git a/mpush-client/src/main/java/com/shinemo/mpush/push/PushRequest.java b/mpush-client/src/main/java/com/shinemo/mpush/push/PushRequest.java
@@ -16,22 +16,24 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.concurrent.atomic.AtomicInteger;
+
 /**
  * Created by ohun on 2015/12/30.
  */
 public class PushRequest implements PushSender.Callback, Runnable {
-
-	private static GatewayServerManage gatewayClientManage = (GatewayServerManage)ServiceContainer.getInstance(ServerManage.class, "gatewayServerManage");
-
     private static final Logger LOGGER = LoggerFactory.getLogger(PushRequest.class);
+
+    private final static GatewayServerManage gatewayClientManage = (GatewayServerManage) ServiceContainer.getInstance(ServerManage.class, "gatewayServerManage");
+
     private PushSender.Callback callback;
     private String userId;
     private String content;
     private long timeout;
-    private int status = 0;
     private long timeout_;
     private int sessionId;
     private long sendTime;
+    private AtomicInteger status = new AtomicInteger(0);
 
     public PushRequest() {
     }
@@ -60,14 +62,6 @@ public PushRequest setTimeout(long timeout) {
         return this;
     }
 
-    public void setSessionId(int sessionId) {
-        this.sessionId = sessionId;
-    }
-
-    public int getSessionId() {
-        return sessionId;
-    }
-
     @Override
     public void onSuccess(String userId) {
         submit(1);
@@ -89,20 +83,18 @@ public void onTimeout(String userId) {
     }
 
     private void submit(int status) {
-        if (this.status != 0) {//防止重复调用
+        if (this.status.compareAndSet(0, status)) {//防止重复调用
-            return;
+            if (callback != null) {
-        }
+                PushRequestBus.INSTANCE.getExecutor().execute(this);
-        this.status = status;
+            } else {
-        if (callback != null) {
+                LOGGER.warn("callback is null");
-            PushRequestBus.INSTANCE.getExecutor().execute(this);
+            }
-        } else {
-            LOGGER.warn("callback is null");
         }
     }
 
     @Override
     public void run() {
-        switch (status) {
+        switch (status.get()) {
             case 1:
                 callback.onSuccess(userId);
                 break;
@@ -145,11 +137,11 @@ public void send() {
     }
 
     public void redirect() {
-        this.status = 0;
-        this.timeout_ = timeout + System.currentTimeMillis();
         ConnectionRouterManager.INSTANCE.invalidateLocalCache(userId);
-        sendToConnServer();
         LOGGER.warn("user route has changed, userId={}, content={}", userId, content);
+        if (status.get() == 0) {
+            send();
+        }
     }
 
     private void sendToConnServer() {
@@ -185,9 +177,8 @@ public void operationComplete(ChannelFuture future) throws Exception {
         PushRequestBus.INSTANCE.put(sessionId, this);
     }
 
-	public long getSendTime() {
+    public long getSendTime() {
-		return sendTime;
+        return sendTime;
-	}
+    }
-
+
-
 }
diff --git a/mpush-client/src/main/java/com/shinemo/mpush/push/PushRequestBus.java b/mpush-client/src/main/java/com/shinemo/mpush/push/PushRequestBus.java
@@ -1,5 +1,7 @@
 package com.shinemo.mpush.push;
 
+import io.netty.util.internal.chmv8.ConcurrentHashMapV8;
+
 import java.util.Iterator;
 import java.util.Map;
 import java.util.concurrent.*;
@@ -9,7 +11,7 @@
  */
 public class PushRequestBus implements Runnable {
     public static final PushRequestBus INSTANCE = new PushRequestBus();
-    private Map<Integer, PushRequest> requests = new ConcurrentHashMap<>();
+    private Map<Integer, PushRequest> requests = new ConcurrentHashMapV8<>(1024);
     private Executor executor = Executors.newFixedThreadPool(5);//test
     private ScheduledExecutorService scheduledExecutor = Executors.newSingleThreadScheduledExecutor();//test