Форум программистов, компьютерный форум, киберфорум
Java: Базы данных
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.75/4: Рейтинг темы: голосов - 4, средняя оценка - 4.75
765 / 666 / 194
Регистрация: 24.11.2015
Сообщений: 2,163

Зависает отправка SMS

25.02.2016, 13:12. Показов 885. Ответов 5
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
В базе данных Oracle имеетя JAVA-класс
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
import java.io.IOException;
import java.util.Random;
import org.jsmpp.InvalidResponseException;
import org.jsmpp.PDUException;
import org.jsmpp.bean.Alphabet;
import org.jsmpp.bean.BindType;
import org.jsmpp.bean.ESMClass;
import org.jsmpp.bean.GSMSpecificFeature;
import org.jsmpp.bean.GeneralDataCoding;
import org.jsmpp.bean.MessageClass;
import org.jsmpp.bean.MessageMode;
import org.jsmpp.bean.MessageType;
import org.jsmpp.bean.NumberingPlanIndicator;
import org.jsmpp.bean.RegisteredDelivery;
import org.jsmpp.bean.SMSCDeliveryReceipt;
import org.jsmpp.bean.TypeOfNumber;
import org.jsmpp.extra.NegativeResponseException;
import org.jsmpp.extra.ResponseTimeoutException;
import org.jsmpp.session.BindParameter;
import org.jsmpp.session.SMPPSession;
import org.jsmpp.session.Session;
 
 
public class SendSMS {
 
    private static final String SMCS_USER = "USER";
    private static final String SMCS_PASSWORD = "password";
    private static final String SMCS_HOST = "XX.XXX.XXX.XXX";
    private static final int    SMCS_PORT = 3102;
    private static final String SMCS_SOURCE = "7921XXXXXXX";
 
    private static final int MAX_MULTIPART_MSG_SEGMENT_SIZE_UCS2 = 134;
    private static final int MAX_SINGLE_MSG_SEGMENT_SIZE_UCS2 = 70;
 
 
    private static byte[][] splitUnicodeMessage(byte[] aMessage, Integer maximumMultipartMessageSegmentSize) {
 
        final byte UDHIE_HEADER_LENGTH = 0x05;
        final byte UDHIE_IDENTIFIER_SAR = 0x00;
        final byte UDHIE_SAR_LENGTH = 0x03;
 
        //determine how many messages have to be sent
        int numberOfSegments = aMessage.length / maximumMultipartMessageSegmentSize;
        int messageLength = aMessage.length;
        if (numberOfSegments > 255) {
            numberOfSegments = 255;
            messageLength = numberOfSegments * maximumMultipartMessageSegmentSize;
        }
        if ((messageLength % maximumMultipartMessageSegmentSize) > 0) {
            numberOfSegments++;
        }
 
        // prepare array for all of the msg segments
        byte[][] segments = new byte[numberOfSegments][];
 
        int lengthOfData;
 
        //generate new reference number
        byte[] referenceNumber = new byte[1];
        new Random().nextBytes(referenceNumber);
 
        // split the message adding required headers
        for (int i = 0; i < numberOfSegments; i++) {
            if (numberOfSegments - i == 1) {
                lengthOfData = messageLength - i * maximumMultipartMessageSegmentSize;
            } else {
                lengthOfData = maximumMultipartMessageSegmentSize;
            }
 
            //new array to store the header
            segments[i] = new byte[6 + lengthOfData];
 
            //UDH header
            //doesnt include itself, its header length
            segments[i][0] = UDHIE_HEADER_LENGTH;
            //SAR identifier
            segments[i][1] = UDHIE_IDENTIFIER_SAR;
            // SAR length
            segments[i][2] = UDHIE_SAR_LENGTH;
            // reference number (same for all messages)
            segments[i][3] = referenceNumber[0];
            // total number of segments
            segments[i][4] = (byte) numberOfSegments;
            // segment number
            segments[i][5] = (byte) (i + 1);
 
            // copy the data into the array
            System.arraycopy(aMessage, (i * maximumMultipartMessageSegmentSize), segments[i], 6, lengthOfData);
 
        }
        return segments;
    }
 
 
    public static String sendTextMessage(String destinationMsisdn, String messageBody, String MY_SMCS_SOURCE) throws IOException, InterruptedException {
 
        String sourceMsisdn = MY_SMCS_SOURCE; // SMCS_SOURCE;
        MessageClass messageClass = MessageClass.CLASS1;
 
        SMPPSession session = new SMPPSession();
 
        try {
            session.connectAndBind(SMCS_HOST, SMCS_PORT, new BindParameter(BindType.BIND_TX, SMCS_USER, SMCS_PASSWORD,
                    "cp", TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN, null));
        } catch (IOException e) {
            System.err.println("Failed connect and bind to host");
            e.printStackTrace();
        }
 
        // configure variables acording to if message contains national
        // characters
        Alphabet alphabet = null;
        int maximumSingleMessageSize = 0;
        int maximumMultipartMessageSegmentSize = 0;
        byte[] byteSingleMessage = null;
        byteSingleMessage = messageBody.getBytes("UTF-16BE");
        alphabet = Alphabet.ALPHA_UCS2;
        maximumSingleMessageSize = MAX_SINGLE_MSG_SEGMENT_SIZE_UCS2;
        maximumMultipartMessageSegmentSize = MAX_MULTIPART_MSG_SEGMENT_SIZE_UCS2;
 
        // check if message needs splitting and set required sending parameters
        byte[][] byteMessagesArray = null;
        ESMClass esmClass = null;
        if (messageBody.length() > maximumSingleMessageSize) {
            // split message according to the maximum length of a segment
            byteMessagesArray = splitUnicodeMessage(byteSingleMessage, maximumMultipartMessageSegmentSize);
            // set UDHI so PDU will decode the header
            esmClass = new ESMClass(MessageMode.DEFAULT, MessageType.DEFAULT, GSMSpecificFeature.UDHI);
        } else {
            byteMessagesArray = new byte[][] { byteSingleMessage };
            esmClass = new ESMClass();
        }
 
        System.out.println("Sending message " + messageBody);
        System.out.printf("Message is %d characters long and will be sent as %d messages with params: %s %s ",
                messageBody.length(), byteMessagesArray.length, alphabet, messageClass);
        System.out.println();
 
        // submit all messages
        String messageId = null;
        for (int i = 0; i < byteMessagesArray.length; i++) {
            messageId = submitMessage(session, byteMessagesArray[i], sourceMsisdn, destinationMsisdn,
                    messageClass, alphabet, esmClass);
            System.out.println("Message submitted, message_id is " + messageId);
        }
 
 
        session.unbindAndClose();
        return messageId;
    }
 
    private static String submitMessage(SMPPSession session, byte[] message, String sourceMsisdn, String destinationMsisdn,
            MessageClass messageClass, Alphabet alphabet, ESMClass esmClass) {
        String messageId = null;
        //GeneralDataCoding dataCoding = new GeneralDataCoding(false, true, MessageClass.CLASS1, Alphabet.ALPHA_UCS2);
        GeneralDataCoding dataCoding = new GeneralDataCoding(false, true, messageClass, alphabet);
        try {
            messageId = session.submitShortMessage("CMT", TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN,
                    sourceMsisdn, TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN, destinationMsisdn, esmClass,
                    (byte) 0, (byte) 1, null, null, new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS),
                    (byte) 0,new GeneralDataCoding((byte) 8) , (byte) 0, message);
        
        } catch (PDUException e) {
            // Invalid PDU parameter
            System.err.println("Invalid PDU parameter");
            e.printStackTrace();
        } catch (ResponseTimeoutException e) {
            // Response timeout
            System.err.println("Response timeout");
            e.printStackTrace();
        } catch (InvalidResponseException e) {
            // Invalid response
            System.err.println("Receive invalid respose");
            e.printStackTrace();
        } catch (NegativeResponseException e) {
            // Receiving negative response (non-zero command_status)
            System.err.println("Receive negative response");
            e.printStackTrace();
        } catch (IOException e) {
            System.err.println("IO error occur");
            e.printStackTrace();
        }
       return messageId;
    }
 
}
и оракловая функция, вызывающая JAVA-процедуру
SQL
1
2
3
4
5
6
7
8
9
10
11
12
13
CREATE OR REPLACE 
FUNCTION        send_megafon_sms_java (
    p_dest IN varchar2,
    p_message IN varchar2,
    p_tel IN varchar2
) RETURN varchar2
AS
    LANGUAGE java name 'SendSMS.sendTextMessage(
        java.lang.String,
        java.lang.String,
        java.lang.String
        )
    return java.lang.String';
В подавляющем большинстве случаев sms отправляется нормально. Иногда (в частности, при ошибочных параметрах процедуры) говорит, что произошел таймаут через 2000мсек, но иногда (примерно 1раз на 1000) процедура зависает и висит, пока не будет убита оракловая сессия.
Есть ли какие-то идеи как бороться с этой напастью?
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
25.02.2016, 13:12
Ответы с готовыми решениями:

Отправка Sms
Всем привет. Я хочу написать прогу для отправки sms на телефон с компа, но у меня не получается. Я знаю, что можно было отправлять sms на...

SMS-отправка
Сложно ли написать приложение, которое бы отправляло СМС-сообщения с текущей сим-карты по списку? Номер получателя и сообщение бралось бы...

Отправка SMS
Добрый день. PascalScript. Написал код для отправки SMS XMLHTTP := CreateObject('WinHttp.WinHttpRequest.5.1'); ...

5
Эксперт Java
 Аватар для KEKCoGEN
2399 / 2224 / 565
Регистрация: 28.12.2010
Сообщений: 8,672
25.02.2016, 14:27
Цитата Сообщение от AGK Посмотреть сообщение
Есть ли какие-то идеи как бороться с этой напастью?
прекратить извращения и не вызывать джава код из БД?
0
765 / 666 / 194
Регистрация: 24.11.2015
Сообщений: 2,163
25.02.2016, 14:38  [ТС]
Цитата Сообщение от KEKCoGEN Посмотреть сообщение
прекратить извращения и не вызывать джава код из БД
Вы наверное не в курсе, но вызов JAVA-процедур из Oracle является одним из стандартных приемов для Oracle.
Я понял, что кроме стеба, предложить Вы ничего не можете, спасибо и на этом.
0
Эксперт Java
 Аватар для KEKCoGEN
2399 / 2224 / 565
Регистрация: 28.12.2010
Сообщений: 8,672
25.02.2016, 15:04
Цитата Сообщение от AGK Посмотреть сообщение
Я понял, что кроме стеба, предложить Вы ничего не можете
на ваш вопрос кроме этого ответить особо нечего. Причин может быть миллион. Если есть возможность, подключайтесь дебагом, если нет, пишите в лог каждый шаг выполнения кода и смотрите что пошло не так.
Так же если запускается джава код, где то есть JVM с вашим кодом. Берите дамп и смотрите где что висит.

Такие проблемы не решаются смотрением на код обычно.
0
765 / 666 / 194
Регистрация: 24.11.2015
Сообщений: 2,163
25.02.2016, 15:23  [ТС]
Цитата Сообщение от KEKCoGEN Посмотреть сообщение
Такие проблемы не решаются смотрением на код обычно
Поскольку сбойная ситуация возникает пару раз в неделю, то делать кучу дампов, чтобы заловить непредсказуемую пакость весьма накладно. Тем более, что повторная отправка sms, как правило, проходит на ура.
Если можно, подскажите пожалуйста людям, неопытным в JAVA, как можно убить JAVA-процедуру через, к примеру, 30 секунд после начала её работы. Я могу это сделать средствами базы данных, но придется городить большой огород. Есть слабая надежда, что средствами JAVA это можно сделать существенно легче.
0
Эксперт Java
 Аватар для KEKCoGEN
2399 / 2224 / 565
Регистрация: 28.12.2010
Сообщений: 8,672
25.02.2016, 15:51
Цитата Сообщение от AGK Посмотреть сообщение
Поскольку сбойная ситуация возникает пару раз в неделю, то делать кучу дампов, чтобы заловить непредсказуемую пакость весьма накладно.
тогда пишите лог.

Цитата Сообщение от AGK Посмотреть сообщение
как можно убить JAVA-процедуру через, к примеру, 30 секунд после начала её работы.
В обычной джава программе можно написать watchdog котоый будет это делать. Но это тот ещё костыль и решение будет таким же огородом полагаю
1
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
25.02.2016, 15:51
Помогаю со студенческими работами здесь

Отправка SMS сообщений
привет всем. неужели не существует способа отправки SMS сообщений напрямую, т.е. не через web-интерфейс или непосредственно с сотового?

Отправка SMS с сайта
Доброго всем дня, я совсем новичок в PHP, если поможете буду очень рад. Т.е. знаю пока CSS и HTML.... Но появился интересный проект. Есть...

Отправка sms сообщения
Подскажите пожалуйста какую лучше всего использовать библиотеку или API для отправки SMS на определенный адрес и нужно что-либо еще для...

Отправка SMS с сайта
Здравствуйте хочу задать вопрос не относящийся к php. просто хочу узнать ваше мнение --------------- модерату: можете переносить тему в...

Отправка SMS на email
Дорогие форумчане, помогите реализовать отправку смс из приложение на e-mail. Перепробывал массу кодов с нета, не чего не работает Вот...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами
8Observer8 20.02.2026
Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .
Конвертировать закладки radiotray-ng в m3u-плейлист
damix 19.02.2026
Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI
Eddy_Em 18.02.2026
Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru