Потоковый процессор WSO2 Интеграция с базой данных mysql не работает

Я пытаюсь подключить сервер mysql через приложение siddhi, и для настройки я перешел по приведенной ниже ссылке документации. https://docs.wso2.com/display/SP430/Integrating+Datastores

Но когда я запускаю приложение сиддхи, я получаю следующую ошибку:

[2018-11-05_05-22-38_825] INFO {org.wso2.carbon.siddhi.editor.core.internal.WorkspaceDeployer} - Siddhi App ShipmentHistoryApp successfully deployed. 
ShipmentHistoryApp.siddhi - Started Successfully!
[2018-11-05_05-22-46_761] ERROR {org.wso2.siddhi.core.table.Table} - Error on 'ShipmentHistoryApp'. Exception during pool initialization: Communications link failure__The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. . Error while connecting to Table 'ShipmentDetails'. (Encoded)
com.zaxxer.hikari.pool.PoolInitializationException: Exception during pool initialization: Communications link failure
The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at com.zaxxer.hikari.pool.HikariPool.initializeConnections(HikariPool.java:581)
    at com.zaxxer.hikari.pool.HikariPool.(HikariPool.java:152)
    at com.zaxxer.hikari.HikariDataSource.(HikariDataSource.java:73)
    at org.wso2.extension.siddhi.store.rdbms.RDBMSEventTable.initializeDatasource(RDBMSEventTable.java:1002)
    at org.wso2.extension.siddhi.store.rdbms.RDBMSEventTable.connect(RDBMSEventTable.java:795)
Caused by: com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failure
The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
    at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
    at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:835)
    at com.mysql.cj.jdbc.ConnectionImpl.(ConnectionImpl.java:455)
    ... 21 more
Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications link failure
The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
Caused by: java.net.SocketException: Broken pipe (Write failed)
    at java.net.SocketOutputStream.socketWrite0(Native Method)
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111)
    at java.net.SocketOutputStream.write(SocketOutputStream.java:155)
    at sun.security.ssl.OutputRecord.writeBuffer(OutputRecord.java:431)
    at sun.security.ssl.OutputRecord.write(OutputRecord.java:417)
    at sun.security.ssl.SSLSocketImpl.writeRecordInternal(SSLSocketImpl.java:879)
    at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:850)
    at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:720)
[2018-11-05_05-22-46_762] ERROR {org.wso2.siddhi.core.SiddhiAppRuntime} - Error starting Siddhi App 'ShipmentHistoryApp', triggering shutdown process. Exception during pool initialization: Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.

Ниже показано приложение siddhi, которое я создал в студии потокового процессора WSO2,

@app:name('ShipmentHistoryApp')

@source(type = 'http', receiver.url='http://localhost:8280/ShipmentHistoryApp/RawMaterialStream', @Map(type = 'json'))
define stream RawMaterialStream(name string, supplier string, amount double);

@PrimaryKey('name')
@index('supplier')
@store(type='rdbms', jdbc.url="jdbc:mysql://localhost:3306/SweetFactoryDB", username="root", password="root@123" , jdbc.driver.name="com.mysql.cj.jdbc.Driver")
define table ShipmentDetails(name string, supplier string, amount double);

from RawMaterialStream
select name, supplier, amount
insert into ShipmentDetails;

Ниже приведена конфигурация mysql, которую я определил в редакторе deployment.yaml.

  - name: SweetFactoryDB
    description: Datasource used for Sweet Factory Supply Records
    jndiConfig:
      name: jdbc/SweetFactoryDB
      useJndiReference: true
    definition:
      type: RDBMS
      configuration:
        jdbcUrl: 'jdbc:mysql://siddhi:3306/SweetFactoryDB'
        username: root
        password: root@123
        driverClassName: com.mysql.cj.jdbc.Driver
        maxPoolSize: 50
        idleTimeout: 60000
        connectionTestQuery: SELECT 1
        validationTimeout: 30000
        isAutoCommit: false

Я попытался преобразовать драйвер mysql в OSGI (используя jartobundle.sh), прежде чем поместить в каталог / lib:

misra_debasish91@siddhi:/usr/lib/wso2/wso2sp/4.3.0$ sh /usr/lib/wso2/wso2sp/4.3.0/bin/jartobundle.sh mysql-connector-java-8.0.13.jar lib/
JAVA_HOME environment variable is set to /usr/lib/jvm/java-8-oracle
CARBON_HOME environment variable is set to /usr/lib/wso2/wso2sp/4.3.0
Nov 05, 2018 7:00:41 AM org.wso2.carbon.tools.converter.utils.BundleGeneratorUtils convertFromJarToBundle
WARNING: Path /usr/lib/wso2/wso2sp/4.3.0/mysql-connector-java-8.0.13.jar refers to an OSGi bundle
Nov 05, 2018 7:00:41 AM org.wso2.carbon.tools.converter.utils.BundleGeneratorUtils convertFromJarToBundle
INFO: Created the OSGi bundle mysql_connector_java_8.0.13_1.0.0.jar for JAR file /usr/lib/wso2/wso2sp/4.3.0/mysql-connector-java-8.0.13.jar

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

Спасибо!!


person Ganesh    schedule 05.11.2018    source источник


Ответы (1)


Есть несколько вещей, которые необходимо исправить в приведенной выше конфигурации. В общем приложении Siddhi в @store аннотация, вы предоставляете все параметры БД для создания соединения с БД. Это один из способов подключения к магазинам. Другой метод - определить источник данных в файле deployment.yaml и использовать его. Поскольку вы уже определили свой магазин in-line, давайте сначала удалим определение источника данных, которое вы добавили в deployment.yaml. Я предполагаю, что эта проблема с подключением в журналах возникает из-за URL-адреса jdbc: mysql: // siddhi: 3306 / SweetFactoryDB, поскольку имя хоста siddhi не разрешается.

Также следует отметить, что последние версии драйверов mqsql уже имеют OSGified. Поэтому, пожалуйста, проверьте, что конкретный драйвер jar уже входит в комплект OSGi. В этом случае конвертировать не нужно.

С помощью приведенных выше советов и общей документации вы сможете выполнить свои требования.

person Tishan    schedule 05.11.2018
comment
Да, я удалил источник данных в файле deployment.yaml и изменил имя хоста siddhi на localhost, а ниже - ошибка {org.wso2.carbon.siddhi.editor.core.internal.DebuggerEventStreamService} - Ошибка при отправке событий в движок отладчика Siddhi com.zaxxer.hikari.pool.PoolInitializationException: исключение во время инициализации пула: не удается создать соединение с сервером базы данных. Попытка переподключиться 3 раза. Сдаваться. Не удалось установить соединение с сервером базы данных javax.net.ssl.SSLHandshakeException: получено фатальное предупреждение: unknown_ca Сообщите мне свои мысли. - person Ganesh; 07.11.2018
comment
Добавьте параметр? UseSSL = false для URL-адреса источника данных. Пример: jdbc: mysql: // siddhi: 3306 / SweetFactoryDB? UseSSL = false - person Tishan; 07.11.2018