SMPP Reciever Java Client - PullRequest
Новая
       50

SMPP Reciever Java Client

0 голосов
/ 05 июня 2018

Я собрал java-программу для прослушивания SMPP-сервера и перехватывает SMS-сообщения, отправленные на этот сервер, он работает нормально, но через определенные промежутки времени я получаю различные типы ошибок, как показано ниже.

Также может кто угодноподскажите, как внести изменения, чтобы этот код Java захватывал только сообщения, отправленные на конкретный SC

ОШИБКА: com.logica.smpp.pdu.EnquireLink не может быть преобразован в com.logica.smpp.pdu.ОШИБКА DeliverSM: com.logica.smpp.pdu.Unbind не может быть приведен к com.logica.smpp.pdu.DeliverSM

И мой код такой, как показано ниже: 

import com.logica.smpp.Data;
import com.logica.smpp.Session;
import com.logica.smpp.TCPIPConnection;
import com.logica.smpp.pdu.BindReceiver;
import com.logica.smpp.pdu.BindRequest;
import com.logica.smpp.pdu.BindResponse;
import com.logica.smpp.pdu.DeliverSM;
import com.logica.smpp.pdu.PDU;

public class SimpleSMSReceiver {
/** * Parameters used for connecting to SMSC (or SMPPSim)*/
    private Session session = null;
    private String ipAddress = "localhost";
    private String systemId = "smppclient1";
    private String password = "password";
    private int port = 2775;

/** * @param args */
    public static void main(String[] args) {
        System.out.println("Sms receiver starts");
        SimpleSMSReceiver objSimpleSMSReceiver = new SimpleSMSReceiver();
        objSimpleSMSReceiver.bindToSmsc();
        while(true) {
            objSimpleSMSReceiver.receiveSms();
        }
    }
    private void bindToSmsc() {
        try {
            // setup connection
            TCPIPConnection connection = new TCPIPConnection(ipAddress, port);
            connection.setReceiveTimeout(20 * 1000);
            session = new Session(connection);
            // set request parameters
            BindRequest request = new BindReceiver();
            request.setSystemId(systemId);
            request.setPassword(password);
            // send request to bind
            BindResponse response = session.bind(request);
            if (response.getCommandStatus() == Data.ESME_ROK) {
                System.out.println("Sms receiver is connected to SMPPSim.");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    private void receiveSms() {
        try {
            PDU pdu = session.receive(1500);
            if (pdu != null) {
                DeliverSM sms = (DeliverSM) pdu;
                if ((int)sms.getDataCoding() == 0 ) {
                    //message content is English
                    System.out.println("***** New Message Received *****");
                    System.out.println("From: " + sms.getSourceAddr().getAddress());
                    System.out.println("To: " + sms.getDestAddr().getAddress());
                    System.out.println("Content: " + sms.getShortMessage());
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

1 Ответ

0 голосов
/ 07 июня 2018

PDU может быть не всегда DeliverSM.

Попробуйте: 

PDU pdu = session.receive(1500);
if ((pdu != null) && (pdu instanceof DeliverSM)) {
    ...
    DeliverSM sms = (DeliverSM) pdu;

Как видите, SMSC отправляет тактовые импульсы (EnquireLink), поэтому вы также должны дать положительный ответ на них.Если вы не подтвердите пульс, сервер будет считать, что соединение установлено, и закроет его (Unbind).

...