use right ip to register broker when in hostnetwork (#203)

Author: usernameisnull

images/broker/alpine/brokerGenConfig.sh

@@ -27,7 +27,8 @@ 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
+
+    echo "brokerIP1=${POD_IP}" >> $BROKER_CONFIG_FILE
     if [ $BROKER_ID != 0 ]; then
         sed -i 's/brokerRole=.*/brokerRole=SLAVE/g' $BROKER_CONFIG_FILE
     fi

pkg/constants/constants.go

@@ -172,4 +172,7 @@ const (
 
 	// EnvControllerAddr is the container environment variable name of Controller address in Broker
 	EnvControllerAddr = "controllerAddr"
+
+	// EnvPodIp is the container environment variable name of pod ip.
+	EnvPodIp = "POD_IP"
 )

pkg/controller/broker/broker_controller.go

@@ -525,6 +525,12 @@ func getENV(broker *rocketmqv1alpha1.Broker, replicaIndex int, brokerGroupIndex
 	}, {
 		Name:  cons.EnvBrokerName,
 		Value: broker.Name + "-" + strconv.Itoa(brokerGroupIndex),
+	}, {
+		Name: cons.EnvPodIp,
+		ValueFrom: &corev1.EnvVarSource{
+			FieldRef: &corev1.ObjectFieldSelector{
+				FieldPath: "status.podIP"},
+		},
 	}}
 	if broker.Spec.ClusterMode == "CONTROLLER" {
 		envs = append(envs, corev1.EnvVar{Name: cons.EnvEnableControllerMode, Value: "true"})