blob: 841dc6c4c06f7718b8f7a8463f867488ae16b453 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.db.service;
import org.apache.iotdb.commons.concurrent.ThreadName;
import org.apache.iotdb.commons.exception.runtime.RPCServiceException;
import org.apache.iotdb.commons.service.AbstractThriftServiceThread;
import org.apache.iotdb.commons.service.ServiceType;
import org.apache.iotdb.commons.service.ThriftService;
import org.apache.iotdb.commons.service.ThriftServiceThread;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.service.metrics.MetricsService;
import org.apache.iotdb.db.service.metrics.enums.Metric;
import org.apache.iotdb.db.service.metrics.enums.Tag;
import org.apache.iotdb.db.service.thrift.ProcessorWithMetrics;
import org.apache.iotdb.db.service.thrift.handler.RPCServiceThriftHandler;
import org.apache.iotdb.db.service.thrift.impl.IClientRPCServiceWithHandler;
import org.apache.iotdb.metrics.config.MetricConfigDescriptor;
import org.apache.iotdb.metrics.utils.MetricLevel;
import org.apache.iotdb.service.rpc.thrift.IClientRPCService.Processor;
import java.lang.reflect.InvocationTargetException;
/** A service to handle jdbc request from client. */
public class RPCService extends ThriftService implements RPCServiceMBean {
private IClientRPCServiceWithHandler impl;
public static RPCService getInstance() {
return RPCServiceHolder.INSTANCE;
}
@Override
public void initTProcessor()
throws ClassNotFoundException, IllegalAccessException, InstantiationException,
NoSuchMethodException, InvocationTargetException {
impl =
(IClientRPCServiceWithHandler)
Class.forName(IoTDBDescriptor.getInstance().getConfig().getRpcImplClassName())
.getDeclaredConstructor()
.newInstance();
initSyncedServiceImpl(null);
if (MetricConfigDescriptor.getInstance().getMetricConfig().getEnableMetric()) {
processor = new ProcessorWithMetrics(impl);
} else {
processor = new Processor<>(impl);
}
}
@Override
public void initThriftServiceThread() throws IllegalAccessException {
IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
try {
thriftServiceThread =
new ThriftServiceThread(
processor,
getID().getName(),
ThreadName.RPC_CLIENT.getName(),
config.getRpcAddress(),
config.getRpcPort(),
config.getRpcMaxConcurrentClientNum(),
config.getThriftServerAwaitTimeForStopService(),
new RPCServiceThriftHandler(impl),
IoTDBDescriptor.getInstance().getConfig().isRpcThriftCompressionEnable());
} catch (RPCServiceException e) {
throw new IllegalAccessException(e.getMessage());
}
thriftServiceThread.setName(ThreadName.RPC_SERVICE.getName());
MetricsService.getInstance()
.getMetricManager()
.getOrCreateAutoGauge(
Metric.THRIFT_ACTIVE_THREADS.toString(),
MetricLevel.CORE,
thriftServiceThread,
AbstractThriftServiceThread::getActiveThreadCount,
Tag.NAME.toString(),
ThreadName.RPC_SERVICE.getName());
}
@Override
public String getBindIP() {
return IoTDBDescriptor.getInstance().getConfig().getRpcAddress();
}
@Override
public int getBindPort() {
return IoTDBDescriptor.getInstance().getConfig().getRpcPort();
}
@Override
public ServiceType getID() {
return ServiceType.RPC_SERVICE;
}
@Override
public int getRPCPort() {
return getBindPort();
}
private static class RPCServiceHolder {
private static final RPCService INSTANCE = new RPCService();
private RPCServiceHolder() {}
}
}