when the broker uses hostNetwork, the broker's IP returned by NameSer…

…ver is the IP of the k8s node where the broker is located.

images/broker/alpine/brokerGenConfig.sh

@@ -27,7 +27,12 @@ function create_config() {
     echo "brokerClusterName=$BROKER_CLUSTER_NAME" >> $BROKER_CONFIG_FILE
     echo "brokerName=$BROKER_NAME" >> $BROKER_CONFIG_FILE
     echo "brokerId=$BROKER_ID" >> $BROKER_CONFIG_FILE
-    echo "brokerIP1=`hostname -i`" >> $BROKER_CONFIG_FILE
+     # If the STATUS_POD_IP ip is not empty, the pod uses hostNetwork: true
+    if [ -n "${HOST_NETWORK_POD_IP}" ]; then
+        echo "brokerIP1=${HOST_NETWORK_POD_IP}" >> ${BROKER_CONFIG_FILE}
+    else
+        echo "brokerIP1=`hostname -i`" >> $BROKER_CONFIG_FILE
+    fi
     if [ $BROKER_ID != 0 ]; then
         sed -i 's/brokerRole=.*/brokerRole=SLAVE/g' $BROKER_CONFIG_FILE
     fi

pkg/constants/constants.go

@@ -172,4 +172,6 @@ const (
 
 	// EnvControllerAddr is the container environment variable name of Controller address in Broker
 	EnvControllerAddr = "controllerAddr"
+	// EnvHostNetworkPodIp is the container environment variable name of host network pod ip, to help the brokerStart.sh script to get the host network pod ip
+	EnvHostNetworkPodIp = "HOST_NETWORK_POD_IP"
 )

pkg/controller/broker/broker_controller.go

@@ -517,6 +517,18 @@ func getENV(broker *rocketmqv1alpha1.Broker, replicaIndex int, brokerGroupIndex
 		envs = append(envs, corev1.EnvVar{Name: cons.EnvEnableControllerMode, Value: "true"})
 		envs = append(envs, corev1.EnvVar{Name: cons.EnvControllerAddr, Value: share.ControllerAccessPoint})
 	}
+	if broker.Spec.HostNetwork {
+		envs = append(
+			envs,
+			corev1.EnvVar{
+				Name: cons.EnvHostNetworkPodIp,
+				ValueFrom: &corev1.EnvVarSource{
+					FieldRef: &corev1.ObjectFieldSelector{
+						FieldPath: "status.podIP"},
+				},
+			},
+		)
+	}
 	envs = append(envs, broker.Spec.Env...)
 	return envs
 }