https://hyperledger-fabric-zh-cn.readthedocs.io/zh/latest/docs/Ledger.html#transaction-flow

func (service *channelService) updateChannelConfig(request module.PutChannelOrganizationRequest) error {
	namespace := request.OrderNamespace
	clientset, err := kubernetes.NewKubernetesClient()
	if err != nil {
		return err
	}
	dep, err := clientset.AppsV1beta1().Deployments(namespace).Get(CliDepName, v1.GetOptions{})
	if err != nil {
		return err
	}

	podLabels := dep.Spec.Selector.MatchLabels
	podSelector := pkglabels.FormatLabels(podLabels)
	podOpts := v1.ListOptions{
		LabelSelector: podSelector,
	}
	podList, err := clientset.CoreV1().Pods(namespace).List(podOpts)
	if err != nil {
		return err
	}

	if len(podList.Items) == 0 {
		return errors.New("can't find cli pod")
	}

	podName := podList.Items[0].Name
	containerName := podList.Items[0].Spec.Containers[0].Name
	peerOrgs := strings.Join(request.PeerOrgs, ",")
	command := fmt.Sprintf("/opt/gopath/src/github.com/hyperledger/fabric/peer/scripts/addorg.sh %s %s %s %s", request.ChannelName, request.OrderNamespace, request.OrgName, peerOrgs)
	glog.Infof("ContainerExec  namespace :%s", namespace)
	glog.Infof("ContainerExec  podName :%s", podName)
	glog.Infof("ContainerExec  containerName :%s", containerName)
	glog.Infof("ContainerExec  command :%s", command)
	stdout, stderr, err := kubernetes.ContainerExec(namespace, podName, containerName, command)
	if err != nil {
		glog.Errorf("Invoke ContainerExec occur a error. It is %s", err)
		return err
	}
	glog.Info("stdout ==>", stdout)
	glog.Info("stderr ==>", stderr)
	return nil
}

fabric网络中创建通道
mspId, _ := db.GetMspIdByPeerId(peer)
fabricClient, err := context.GetServer().GetClient(joinChl.NetId, "Admin", mspId)
if err != nil {
	log.Logger.Errorf("GetClient error: %v", err)
	c.JSON(http.StatusInternalServerError, gin.H{
		"err": err.Error(),
	})
}
// Resmgmt client
clientProvider := fabricClient.GetClientProvider()
resmgmtClient, err := resmgmt.New(clientProvider)
ctx, err := clientProvider()
log.Logger.Debugf("join channel resmgmtClient.ctx = %+v, %v", ctx, err)
err = resmgmtClient.JoinChannel(channelName, resmgmt.WithTargetURLs(peerURL), resmgmt.WithOrdererURL(ordererURL))
if err != nil {
	log.Logger.Errorf("JoinChannel error :%v ", err)
	c.JSON(http.StatusInternalServerError, gin.H{
		"err": err.Error(),
	})
	return
}
log.Logger.Info("JoinChannel SUCCESS!")

//RefreshClient
for _, peerOrg := range PeerOrgs {
		err = context.GetServer().RefreshClient(joinChl.NetId, "Admin", fmt.Sprintf("%s%s", strings.ToUpper(peerOrg.Name[0:1]), peerOrg.Name[1:]))
		if err != nil {
			log.Logger.Errorln("RefreshClient error:", err)
			c.JSON(http.StatusInternalServerError, gin.H{
				"err": err.Error(),
			})
			return
		}
	}

BlockMetadataIndex_SIGNATURES：区块签名；

BlockMetadataIndex_LAST_CONFIG：最新配置区块的区块号；

BlockMetadataIndex_TRANSACTIONS_FILTER：最新交易过滤器，封装了交易数据集合Data中所有交易对应的交易验证码，标识其交易的有效性。

BlockMetadataIndex_ORDERER：Orderer配置信息，如Kafka共识组件的初始化参数。

https://www.cnblogs.com/kaixinyufeng/p/9803413.html


https://blog.csdn.net/greedystar/article/details/80344984

https://www.cnblogs.com/charlesblc/p/6130433.html

https://blog.csdn.net/u011531425/article/details/89161392

https://blog.csdn.net/s_lisheng/article/details/78022645

https://www.cnblogs.com/fengzhiwu/p/5524324.html

https://blog.csdn.net/t46414704152abc/article/details/81191804

https://blog.csdn.net/astro_boy/article/details/84054090

http://m.elecfans.com/article/596778.html

http://www.elecfans.com/blockchain/800061.html

docker pull docker.elastic.co/elasticsearch/elasticsearch:6.4.3

docker run -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" docker.elastic.co/elasticsearch/elasticsearch:6.4.3

wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-6.4.3.tar.gz
wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-6.4.3.tar.gz.sha512
shasum -a 512 -c elasticsearch-6.4.3.tar.gz.sha512 
tar -xzf elasticsearch-6.4.3.tar.gz
cd elasticsearch-6.4.3/ 
./bin/elasticsearch

[root@JD elasticsearch]# shasum -a 512 -c elasticsearch-6.4.3.tar.gz.sha512 
-bash: shasum: command not found

[root@JD elasticsearch-6.4.3]# ./bin/elasticsearch
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000ca660000, 899284992, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 899284992 bytes for committing reserved memory.
# An error report file with more information is saved as:
# logs/hs_err_pid16061.log

Elastic-Job is a distributed scheduling solution consisting of two separate projects, Lite and Cloud.

Elastic-Job-Lite is a lightweight, decentralized solution that provides distributed task sharding services. Elastic-Job-Cloud is a Mesos Framework which provides additional resource management, App distribution, process isolation and task aggregation features.

<dependency>
    <groupId>com.dangdang</groupId>
    <artifactId>elastic-job-lite-core</artifactId>
    <version>${elastic-job.version}</version>
</dependency>
<dependency>
    <groupId>com.dangdang</groupId>
    <artifactId>elastic-job-lite-spring</artifactId>
    <version>${elastic-job.version}</version>
</dependency>

import com.dangdang.ddframe.job.api.ShardingContext;
import DynamicJobConfig;
import SimpleDeliveryJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;

/**
 * @Author: zy
 * @Date: 2019/7/20/0020 10:55
 */
@Slf4j
@Component
public class InPolygonJob implements SimpleDeliveryJob {

    @Value("${elastic-job.task.InPolygon.cron}")
    private String cron;

    @Value("${elastic-job.task.InPolygon.shardingTotalCount}")
    private int shardingTotalCount;

    @Value("${elastic-job.task.InPolygon.shardingItemParameters}")
    private String shardingItemParameters;

    @Value("${elastic-job.task.InPolygon.description}")
    private String description;

    private ApplicationContext applicationContext;
    @Autowired
    private ISyncInPolygonService syncInPolygonService;

    
    @Override
    public void execute(ShardingContext shardingContext) {
         // do something 
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        DynamicJobConfig dynamicJobConfig = (DynamicJobConfig) applicationContext.getBean("dynamicJobConfig");
        dynamicJobConfig.dynamicAddSimpleJobScheduler(this, cron, shardingTotalCount, shardingItemParameters, description);
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}

import com.dangdang.ddframe.job.api.simple.SimpleJob;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.ApplicationContextAware;

/**
 * @Description :
 * @author: zy
 * @Date : 2019-06-14 13:59
 */
public interface SimpleDeliveryJob extends SimpleJob, InitializingBean, ApplicationContextAware {
}

import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import javax.sql.DataSource;

/**
 * @Description : 动态调度任务
 * @author: zy
 * @Date : 2019-06-12 18:11
 */
@Slf4j
@Component
public class DynamicJobConfig {

    @Autowired
    private ZookeeperRegistryCenter regCenter;

    @Autowired
    @Qualifier("taskDataSource")
    private DataSource taskDataSource;

    @Async("taskExecutor")
    public void dynamicAddSimpleJobScheduler(SimpleJob simpleJob, String cron,
                                             int shardingTotalCount, String shardingItemParameters, String description) {
        new SpringJobScheduler(simpleJob, regCenter,
                LiteJobConfigUtil.getLiteJobConfiguration(simpleJob.getClass(), cron, shardingTotalCount,shardingItemParameters, description),
                new JobEventRdbConfiguration(taskDataSource)).init();
    }

}

elastic-job:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://192.168.0.1:3306/elastic_job?autoReconnect=true&allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
    type: com.alibaba.druid.pool.DruidDataSource
    initialSize: 5
    minIdle: 5
    maxActive: 20
    maxWait: 60000
    timeBetweenEvictionRunsMillis: 60000
    minEvictableIdleTimeMillis: 300000
    validationQuery: SELECT 1 FROM DUAL
    testWhileIdle: true
    testOnBorrow: false
    testOnReturn: false
    filters: stat,wall,log4j
    logSlowSql: true

  registry-center:
    address: 192.168.0.2:2181  
    namespace: elastic-job

  task:
    test:
      cron: 0/5 * * * * ?
      #作业分片总数
      shardingTotalCount: 3
      shardingItemParameters: 0=Beijing,1=Shanghai,2=Guangzhou
      description: 描述