mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 00:30:49 +00:00
ffc1fca296
This allows starting and stopping separately each protocol server without restarting ClickHouse. This also allows adding or removing `listen_host` entries, which start and stops servers for all enabled ports. When stopping a server, the listening socket is immediately closed (and available for another server). Protocols with persistent connections try to wait for any currently running query to finish before closing the connection, but idle connection are closed quickly (depending on how often the protocol is polled). An extra ProfileEvent is added, `MainConfigLoads`, it is incremented every time the configuration is reloaded. This helps when trying to assess whether the new configuration was applied.
99 lines
2.5 KiB
C++
99 lines
2.5 KiB
C++
#pragma once
|
|
|
|
#include <Server/IServer.h>
|
|
|
|
#include <daemon/BaseDaemon.h>
|
|
|
|
/** Server provides three interfaces:
|
|
* 1. HTTP - simple interface for any applications.
|
|
* 2. TCP - interface for native clickhouse-client and for server to server internal communications.
|
|
* More rich and efficient, but less compatible
|
|
* - data is transferred by columns;
|
|
* - data is transferred compressed;
|
|
* Allows to get more information in response.
|
|
* 3. Interserver HTTP - for replication.
|
|
*/
|
|
|
|
namespace Poco
|
|
{
|
|
namespace Net
|
|
{
|
|
class ServerSocket;
|
|
}
|
|
}
|
|
|
|
namespace DB
|
|
{
|
|
class AsynchronousMetrics;
|
|
class ProtocolServerAdapter;
|
|
|
|
class Server : public BaseDaemon, public IServer
|
|
{
|
|
public:
|
|
using ServerApplication::run;
|
|
|
|
Poco::Util::LayeredConfiguration & config() const override
|
|
{
|
|
return BaseDaemon::config();
|
|
}
|
|
|
|
Poco::Logger & logger() const override
|
|
{
|
|
return BaseDaemon::logger();
|
|
}
|
|
|
|
ContextMutablePtr context() const override
|
|
{
|
|
return global_context;
|
|
}
|
|
|
|
bool isCancelled() const override
|
|
{
|
|
return BaseDaemon::isCancelled();
|
|
}
|
|
|
|
void defineOptions(Poco::Util::OptionSet & _options) override;
|
|
|
|
protected:
|
|
int run() override;
|
|
|
|
void initialize(Application & self) override;
|
|
|
|
void uninitialize() override;
|
|
|
|
int main(const std::vector<std::string> & args) override;
|
|
|
|
std::string getDefaultCorePath() const override;
|
|
|
|
private:
|
|
ContextMutablePtr global_context;
|
|
Poco::Net::SocketAddress socketBindListen(Poco::Net::ServerSocket & socket, const std::string & host, UInt16 port, [[maybe_unused]] bool secure = false) const;
|
|
|
|
using CreateServerFunc = std::function<ProtocolServerAdapter(UInt16)>;
|
|
void createServer(
|
|
Poco::Util::AbstractConfiguration & config,
|
|
const std::string & listen_host,
|
|
const char * port_name,
|
|
bool listen_try,
|
|
bool start_server,
|
|
std::vector<ProtocolServerAdapter> & servers,
|
|
CreateServerFunc && func) const;
|
|
|
|
void createServers(
|
|
Poco::Util::AbstractConfiguration & config,
|
|
const std::vector<std::string> & listen_hosts,
|
|
bool listen_try,
|
|
Poco::ThreadPool & server_pool,
|
|
AsynchronousMetrics & async_metrics,
|
|
std::vector<ProtocolServerAdapter> & servers,
|
|
bool start_servers = false);
|
|
|
|
void updateServers(
|
|
Poco::Util::AbstractConfiguration & config,
|
|
Poco::ThreadPool & server_pool,
|
|
AsynchronousMetrics & async_metrics,
|
|
std::vector<ProtocolServerAdapter> & servers);
|
|
};
|
|
|
|
}
|