Блог

Я работаю над разработкой решения для подключения к финансовому рынку с использованием протокола FIX с фреймворком quickfixj. В частности, я внедряю инициатор, и мне требуется для подключения к акцептору указать имя пользователя и пароль. В документации quickfixj в этом отношении не очень понятно, как передавать эти поля в сообщении для входа на сервер.

Просматривая, я обнаружил, что это заложено в функцию toAdmin, я поместил в эту функцию следующий код:

 @Override
public void toAdmin(Message message, SessionID sessionId) {

    Session.lookupSession(sessionId).setTargetDefaultApplicationVersionID(new ApplVerID("9"));

    final Message.Header header = message.getHeader();      

     try {
        if ( header.getField(new BooleanField(MsgType.FIELD)).equals(MsgType.LOGON) ) {                  
                message.setField(new StringField(Username.FIELD, "user")); 
                message.setField( new StringField(Password.FIELD, "pass"));
                System.out.println(">>> "   message.toRawString()); 
             }
    } catch (FieldNotFound e) {
        // TODO Auto-generated catch block

        e.printStackTrace();
    } 
}
  

Но я все еще не могу выполнить процесс входа в систему, и он показывает мне следующий журнал при попытке входа в систему.

 <20190313-14:44:33, FIXT.1.1:aaa->bbb, outgoing> (8=FIXT.1.1 9=74 35=A 34=1 49=aaa 52=20190313-14:44:33.431 56=bbb 98=0 108=30 1137=9 10=131 )
<20190313-14:44:33, FIXT.1.1:aaa->bbb, event> (Initiated logon request)
<20190313-14:44:33, FIXT.1.1:aaa->bbb, event> (Disconnecting: Encountered END_OF_STREAM)
<20190313-14:44:37, FIXT.1.1:aaa->bbb, event> (MINA session created: local=/192.168.1.80:51372, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=/3.3.3.3:443)
<20190313-14:44:38, FIXT.1.1:aaa->bbb, outgoing> (8=FIXT.1.1 9=74 35=A 34=2 49=aaa 52=20190313-14:44:38.420 56=bbb 98=0 108=30 1137=9 10=135 )
<20190313-14:44:38, FIXT.1.1:aaa->bbb, event> (Initiated logon request)
<20190313-14:44:38, FIXT.1.1:aaa->bbb, event> (Disconnecting: Encountered END_OF_STREAM)
  

На некоторых форумах упоминается, что это может произойти, когда имя пользователя и пароль переданы неправильно

Вопросы:

• Кто-то использовал quickfixj, передавая имя пользователя и пароль для аутентификации в акцепторе, который мог бы мне помочь.
• Показанное сообщение об ошибке может иметь какую-то другую причину, которую кто-то знает?

Начиная с QuickFix / J 2.2.0, вы можете передавать LogonTag настройки сеанса, чтобы установить эти теги в отправляемом сообщении входа в систему.

Пример:

 LogonTag=553=user
LogonTag1=554=password 
  

Это то, что вам нужно в вашем toAdmin() :

 final String msgType = msg.getHeader().getString(MsgType.FIELD);
if(MsgType.LOGON.compareTo(msgType) == 0)
{
    msg.setString(quickfix.fields.Username.FIELD, _username);
    msg.setString(quickfix.fields.Password.FIELD, _password);
}
  

Это в часто задаваемых вопросах для пользователей.