Статьи

Краткое руководство по кластеризации JBoss

Ноябрь 27, 2018

Поэтому я участвовал в кластеризации двух экземпляров JBoss и по какой-то причине я потерял свое руководство, которое я сделал для себя в прошлый раз, когда делал реализацию кластеризации. На этот раз я подумал, что нужно писать в блоге, чтобы сохранить его в качестве справки для себя, а также для всех, кому, возможно, потребуется быстро выполнить кластеризацию JBoss, поскольку мы все знаем, насколько критичны все IT-проекты. Я расскажу об этом поэтапно, чтобы было легче читать и понимать. Обратите внимание, что этот подход предполагает кластеризацию всей конфигурации в JBoss.

  • Найдите cluster-service.xml, расположенный в папке развертывания. Откройте его и найдите атрибут PartitionName в первом mbean, которое вы видите в этом файле, и измените значение $ {jboss.partition.name:DefaultPartition} на $ {jboss.partition.name} . Как и в части удаления DefaultParition. 
  •  Найдите код mbean, равный org.jboss.ha.jndi.HANamingService и org.jboss.ha.hasessionstate.server.HASessionStateService. Внутри этого найдите тег   . Измените значение jboss: service = $ {jboss.partition.name:DefaultPartition} на jboss: service = $ {jboss.partition.name} . Также добавьте следующее к обоим mbeans, упомянутым выше $ {jboss.partition.name} .
  • В вашем приложении jndi reference обязательно измените порт на 1100, потому что в кластерной среде HA-JNDI (JNDI высокой доступности) используется для поиска ресурса. Таким образом, localhost: 1099 должен быть localhost: 1100. Также вы должны указать jndi через запятую, указав все кластеризованные серверы. Это необходимо в случае, если один сервер выходит из строя, но поиск не завершится ошибкой, так как вы указали все серверы. Например, у вас есть два сервера с именами ABC и XYZ . Тогда, если вы укажете только свой jndi url как ABC: 1100 , это будет работать, но в случае, если ABC отключится, все остальные ваши поиски также потерпят неудачу. Поэтому, чтобы избежать подобных ситуаций, обязательно определите его как ABC: 1100, XYZ: 1100, Это позволит попробовать другой сервер в случае сбоя одного из них.
  • Во всех ваших EJB-компонентах обязательно добавьте аннотацию @Clustered (partition = «mypartition»). Указанное нами имя должно быть указано в вашем скрипте запуска, который я дам в конце этой статьи.
  • Если вы работаете в Redhat, убедитесь, что порт HA-JNDI открыт, введя следующие команды, чтобы открыть порт 1100;
iptables -A INPUT -i eth0 -p tcp --sport 1100 -m state --state ESTABLISHED -j ACCEPT

/etc/init.d/iptables restart


service iptables restart

Далее я хотел бы обратить ваше внимание на отказ в отказоустойчивости JNDI и как его преодолеть. Например, у вас есть два сервера с именем serverA и serverB. Если serverA завершает работу, то serverB должен обрабатывать всю нагрузку. Это работает из коробки от JBoss. Но если serverA запускается снова и serverB выходит из строя, то вы облажались, потому что вы получите сообщение об ошибке java.lang.RuntimeException: Unreachable ?: Служба недоступна .

Для преодоления этого есть обходной путь. Откройте файл standardjboss.xml и найдите его в каталоге all / conf. В этом файле найдите текст cluster -lessless-rmi-invoker. Теперь внутри этого вы увидите количество элементов. В одном из них вы найдете что-то с именем org.jboss.proxy.ejb.SingleRetryInterceptor . Вы найдете два экземпляра этого. Вам нужно изменить его на org.jboss.proxy.ejb.RetryInterceptor. Это будет повторять попытки бесконечного подключения, пока не появится другой сервер. Конечно, это не идеальное решение, а просто обходной путь. Обратите внимание, что это касается Jboss 4.2.3, о котором я говорю. Это могло быть исправлено в более поздних выпусках, о которых я не знаю.

Таким образом, изменение будет выглядеть как показано ниже; 

<invoker-proxy-binding>
      <name>clustered-stateless-rmi-invoker</name>
      <invoker-mbean>jboss:service=invoker,type=jrmpha</invoker-mbean>
      <proxy-factory>org.jboss.proxy.ejb.ProxyFactoryHA</proxy-factory>
      <proxy-factory-config>
        <client-interceptors>
          <home>
            <interceptor>org.jboss.proxy.ejb.HomeInterceptor</interceptor>
            <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
            <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
            <interceptor>org.jboss.proxy.ejb.RetryInterceptor</interceptor>
            <interceptor call-by-value="false">org.jboss.invocation.InvokerInterceptor</interceptor>
            <interceptor call-by-value="true">org.jboss.invocation.MarshallingInvokerInterceptor</interceptor>
          </home>
          <bean>
            <interceptor>org.jboss.proxy.ejb.StatelessSessionInterceptor</interceptor>
            <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
            <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
            <interceptor>org.jboss.proxy.ejb.RetryInterceptor</interceptor>
            <interceptor call-by-value="false">org.jboss.invocation.InvokerInterceptor</interceptor>
            <interceptor call-by-value="true">org.jboss.invocation.MarshallingInvokerInterceptor</interceptor>
          </bean>
        </client-interceptors>
      </proxy-factory-config>
    </invoker-proxy-binding>

Наконец, я представляю вам файл jboss_redhat_init.sh, в котором задается имя раздела jboss, которое будет использоваться в приложении, то же имя, которое используется в аннотации @Clustered.
  
#!/bin/sh
#
# $Id: jboss_init_redhat.sh 71252 2008-03-25 17:52:00Z dbhole $
#
# JBoss Control Script
#
# To use this script run it as root - it will switch to the specified user
#
# Here is a little (and extremely primitive) startup/shutdown script
# for RedHat systems. It assumes that JBoss lives in /usr/local/jboss,
# it's run by user 'jboss' and JDK binaries are in /usr/local/jdk/bin.
# All this can be changed in the script itself. 
#
# Either modify this script for your requirements or just ensure that
# the following variables are set correctly before calling the script.

#define where jboss is - this is the directory containing directories log, bin, conf etc
JBOSS_HOME=${JBOSS_HOME:-"/opt/xyz/jboss-4.2.3.GA"}

#define the user under which jboss will run, or use 'RUNASIS' to run as the current user
JBOSS_USER=${JBOSS_USER:-"RUNASIS"}

#make sure java is in your path
JAVAPTH=${JAVAPTH:-"/usr/java/jdk1.6.0_16/bin"}

#configuration to use, usually one of 'minimal', 'default', 'all'
JBOSS_CONF=${JBOSS_CONF:-"all"}

#if JBOSS_HOST specified, use -b to bind jboss services to that address
JBOSS_BIND_ADDR=${JBOSS_HOST:+"-b $JBOSS_HOST"}

#define the script to use to start jboss
JBOSSSH=${JBOSSSH:-"$JBOSS_HOME/bin/run.sh -b 172.2.23.2 -c $JBOSS_CONF $JBOSS_BIND_ADDR -Djboss.partition.name=mypartition"}

if [ "$JBOSS_USER" = "RUNASIS" ]; then
  SUBIT=""
else
  SUBIT="su - $JBOSS_USER -c "
fi

if [ -n "$JBOSS_CONSOLE" -a ! -d "$JBOSS_CONSOLE" ]; then
  # ensure the file exists
  touch $JBOSS_CONSOLE
  if [ ! -z "$SUBIT" ]; then
    chown $JBOSS_USER $JBOSS_CONSOLE
  fi 
fi

if [ -n "$JBOSS_CONSOLE" -a ! -f "$JBOSS_CONSOLE" ]; then
  echo "WARNING: location for saving console log invalid: $JBOSS_CONSOLE"
  echo "WARNING: ignoring it and using /dev/null"
  JBOSS_CONSOLE="/dev/null"
fi

#define what will be done with the console log
JBOSS_CONSOLE=${JBOSS_CONSOLE:-"/dev/null"}

JBOSS_CMD_START="cd $JBOSS_HOME/bin; $JBOSSSH"

if [ -z "`echo $PATH | grep $JAVAPTH`" ]; then
  export PATH=$PATH:$JAVAPTH
fi

if [ ! -d "$JBOSS_HOME" ]; then
  echo JBOSS_HOME does not exist as a valid directory : $JBOSS_HOME
  exit 1
fi

echo JBOSS_CMD_START = $JBOSS_CMD_START

function procrunning() {
   procid=0
   JBOSSSCRIPT=$(echo $JBOSSSH | awk '{print $1}' | sed 's/\//\\\//g')
   for procid in `/sbin/pidof -x "$JBOSSSCRIPT"`; do
       ps -fp $procid | grep "${JBOSSSH% *}" > /dev/null && pid=$procid
   done
}


stop() {
    pid=0
    procrunning
    if [ $pid = '0' ]; then
        echo -n -e "\nNo JBossas is currently running\n"
        exit 1
    fi

    RETVAL=1

    # If process is still running

    # First, try to kill it nicely
    for id in `ps --ppid $pid | awk '{print $1}' | grep -v "^PID$"`; do
       if [ -z "$SUBIT" ]; then
           kill -15 $id
       else
           $SUBIT "kill -15 $id"
       fi
    done

    sleep=0
    while [ $sleep -lt 120 -a $RETVAL -eq 1 ]; do
        echo -n -e "\nwaiting for processes to stop";
        sleep 10
        sleep=`expr $sleep + 10`
        pid=0
        procrunning
        if [ $pid == '0' ]; then
            RETVAL=0
        fi
    done

    # Still not dead... kill it

    count=0
    pid=0
    procrunning

    if [ $RETVAL != 0 ] ; then
        echo -e "\nTimeout: Shutdown command was sent, but process is still running with PID $pid"
        exit 1
    fi

    echo
    exit 0
}

case "$1" in
start)
    cd $JBOSS_HOME/bin
    if [ -z "$SUBIT" ]; then
        eval $JBOSS_CMD_START >${JBOSS_CONSOLE} 2>&1 &
    else
        $SUBIT "$JBOSS_CMD_START >${JBOSS_CONSOLE} 2>&1 &" 
    fi
    ;;
stop)
    stop
    ;;
restart)
    $0 stop
    $0 start
    ;;
*)
    echo "usage: $0 (start|stop|restart|help)"
esac

Здесь следует обратить внимание на -Djboss.partition.name = mypartition, который задает имя кластера как свойство всего приложения.

Вот и все, ребята. Если у вас есть какие-либо проблемы или улучшения, пожалуйста, оставьте комментарий, который всегда приветствуется. 

От http://dinukaroshan.blogspot.com/2011/03/jboss-clustering-quick-reference-guide.html

36
Share: