src/org/redkale/mq/MessageProducers.java

@@ -28,12 +28,8 @@ public class MessageProducers {
     }
 
     public MessageProducer getProducer(MessageRecord message) {
-        int hash;
+        int hash = message.hash();
-        if (message.getGroupid() != null && !message.getGroupid().isEmpty()) {
+        if (hash == 0) {
-            hash = message.getGroupid().hashCode();
-        } else if (message.getUserid() > 0) {
-            hash = message.getUserid();
-        } else {
             hash = index.incrementAndGet();
             if (index.get() > 1000 * producers.length) {
                 synchronized (index) {

src/org/redkale/mq/MessageRecord.java

@@ -156,6 +156,16 @@ public class MessageRecord implements Serializable {
         return this;
     }
 
+    public int hash() {
+        if (groupid != null && !groupid.isEmpty()) {
+            return groupid.hashCode();
+        } else if (userid > 0) {
+            return userid;
+        } else {
+            return 0;
+        }
+    }
+
     public MessageRecord version(int version) {
         this.version = version;
         return this;