模块八

CREATE TABLE topic (	  id BINARY(16) NOT NULL,  -- 主题id  topic_name VARCHAR(255) NOT NULL,  -- 主题名称  broker_id BINARY(16) NOT NULL,   -- 主题对应的broker  create_time TIMESTAMP NOT NULL ,  -- 创建时间  modify_time TIMESTAMP NOT NULL ,  -- 修改时间  PRIMARY KEY(id));

CREATE TABLE queue(  id BINARY(16) NOT NULL, -- 队列ID  name VARCHAR(255) NOT NULL, -- 队列名称  topic_id BINARY(16) NOT NULL, -- 主题id  message_table_name VARCHAR(255) NOT NULL,  -- 消息表表名  create_time TIMESTAMP NOT NULL ,  -- 创建时间  modify_time TIMESTAMP NOT NULL ,  -- 修改时间  PRIMARY KEY(id)，  INDEX idx_topic(topic_id) --便于查询消费表);

CREATE TABLE queue_message(  id BINARY(16) NOT NULL, -- 消息ID  queue_id BINARY(16) NOT NULL, -- 队列ID  message_data JSON, -- 使用JSON数据类型保存消息数据  state NOT NULL, -- 消息消费状态  create_time TIMESTAMP NOT NULL ,  -- 创建时间  modify_time TIMESTAMP NOT NULL ,  -- 修改时间  PRIMARY KEY (ID));

CREATE TABLE queue_message_consumer(  id BINARY(16) NOT NULL,   queue_id BINARY(16) NOT NULL, -- 队列id  message_id BINARY(16) NOT NULL, -- 消息ID  message_table_name VARCHAR(255) NOT NULL,  -- 消息表表名  state NOT NULL, -- 消息消费状态  create_time TIMESTAMP NOT NULL ,  -- 创建时间  modify_time TIMESTAMP NOT NULL ,  -- 修改时间  PRIMARY KEY (ID),  INDEX idx_queue(queue_id) --便于查询消费位置);