arduino复制代码public class TmallConfig {

    /**
     * hbase 数据库
     */
    public static final String HBASE_SCHEMA = "TMALL_REALTIME";

    /**
     * phoenix 连接地址
     */
    public static final String PHOENIX_SERVER = "jdbc:phoenix:hd1,hd2,hd3:2181";

    /**
     * clickhouse 连接地址
     */
    public static final String CLICKHOUSE_URL="jdbc:clickhouse://hd1:8123/tmall_realtime";

}

arduino复制代码public enum CDCTypeEnum {

    /**
     * CDC 中的 c 操作类型 转成 INSERT
     */
    INSERT("c"),
    /**
     * CDC 中的 u 操作类型 转成 UPDATE
     */
    UPDATE("u"),
    /**
     * CDC 中的 d 操作类型 转成 DELETE
     */
    DELETE("d");

    private static final Map<String, CDCTypeEnum> MAP = new HashMap<>();

    static {
        for (CDCTypeEnum cdcTypeEnum : CDCTypeEnum.values()) {
            MAP.put(cdcTypeEnum.op, cdcTypeEnum);
        }
    }

    String op;

    CDCTypeEnum(String op) {
        this.op = op;
    }

    public static CDCTypeEnum of(String c) {
        return MAP.get(c);
    }
}

typescript复制代码public class KafkaUtil {

   private static final String KAFKA_SERVER = "hd1:9092,hd2:9092,hd3:9092";

   /**
    * 获取 kafka 通用配置
    * @return 配置类
    */
   private static Properties getProps() {
       Properties properties = new Properties();
       properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, KAFKA_SERVER);
       return properties;
   }

   /**
    * 通过 topic 和 groupId 创建一个 Kafka Source
    * @param topic
    * @param groupId
    * @return Kafka Source
    */
   public static SourceFunction<String> ofSource(String topic, String groupId) {
       Properties props = getProps();
       props.setProperty(ConsumerConfig.GROUP_ID_CONFIG, groupId);
       return new FlinkKafkaConsumer<>(topic, new SimpleStringSchema(), props);
   }

   /**
    * 通过 topic 创建一个字符串序列化的 Kafka Sink
    * @param topic
    * @return Kafka Sink
    */
   public static SinkFunction<String> ofSink(String topic) {
       return new FlinkKafkaProducer<>(topic, new SimpleStringSchema(), getProps());
   }

   /**
    * 通过 序列化器 创建一个 Kafka Sink
    * @param serializationSchema
    * @param <IN>
    * @return Kafka Sink
    */
   public static <IN> SinkFunction<IN> ofSink(KafkaSerializationSchema<IN> serializationSchema) {
       return new FlinkKafkaProducer<>("default_topic", serializationSchema, getProps(), FlinkKafkaProducer.Semantic.EXACTLY_ONCE);
   }

   /**
    * 通过 topic 和 groupId 生成一个 Flink SQL 的 Kafka 连接信息
    * @param topic
    * @param groupId
    * @return
    */
   public static String getKafkaDDL(String topic, String groupId) {
       return " 'connector' = 'kafka', " +
               " 'topic' = '" + topic + "'," +
               " 'properties.bootstrap.servers' = '" + KAFKA_SERVER + "', " +
               " 'properties.group.id' = '" + groupId + "', " +
               "  'format' = 'json', " +
               "  'scan.startup.mode' = 'latest-offset' ";
   }
}

csharp复制代码public class RedisUtil {

   private static volatile JedisPool jedisPool;

   public static Jedis getJedis() {
       if (jedisPool == null) {
           synchronized (RedisUtil.class) {
               if (jedisPool == null) {
                   JedisPoolConfig poolConfig = new JedisPoolConfig();
                   //最大可用连接数
                   poolConfig.setMaxTotal(100);
                   //连接耗尽是否等待
                   poolConfig.setBlockWhenExhausted(true);
                   //等待时间
                   poolConfig.setMaxWaitMillis(2000);
                   //最大闲置连接数
                   poolConfig.setMaxIdle(5);
                   //最小闲置连接数
                   poolConfig.setMinIdle(5);
                   //取连接的时候进行一下测试 ping pong
                   poolConfig.setTestOnBorrow(true);
                   jedisPool = new JedisPool(poolConfig, "hd1", 6379, 1000, "密码");
               }
           }
       }
       return jedisPool.getResource();
   }

}

ini复制代码public class PhoenixUtil {

   private static Connection connection;

   /**
    * 查询 一个集合数据
    * @param sql sql
    * @param clazz 返回集合的类型
    * @param <T> 返回集合的类型
    * @return 结果集合
    */
   public static <T> List<T> queryList(String sql, Class<T> clazz) {
       if (connection == null) {
           initConnection();
       }
       try (PreparedStatement preparedStatement = connection.prepareStatement(sql)) {
           ResultSet resultSet = preparedStatement.executeQuery();
           ResultSetMetaData metaData = resultSet.getMetaData();
           ArrayList<T> resList = new ArrayList<>();
           while (resultSet.next()) {
               T t = clazz.newInstance();
               for (int i = 1; i <= metaData.getColumnCount(); i++) {
                   BeanUtils.setProperty(t, metaData.getColumnName(i), resultSet.getObject(i));
               }
               resList.add(t);
           }
           resultSet.close();
           return resList;
       } catch (Exception e) {
           e.printStackTrace();
       }
       return Collections.emptyList();
   }

   /**
    * 初始化 Phoenix 连接
    */
   @SneakyThrows
   private static void initConnection() {
       Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
       connection = DriverManager.getConnection(TmallConfig.PHOENIX_SERVER);
   }

}

typescript复制代码public class DimUtil {

   /**
    * 删除缓存
    * @param tableName
    * @param id
    */
   public static void delDimCache(String tableName, String id) {
       StringBuilder cacheKey = new StringBuilder().append("dim:").append(tableName.toLowerCase()).append(":").append(id);
       try (Jedis jedis = RedisUtil.getJedis()) {
           jedis.del(cacheKey.toString());
       }
   }

   /**
    * 更具 表名 和 id 查询一条数据
    * @param tableName 表名
    * @param id id
    * @return  数据
    */
   public static JSONObject getDimInfo(String tableName, String id) {
       return getDimInfo(tableName, Tuple2.of("id", id));
   }

   /**
    * 更具 表名 和 多个条件 查询一条数据
    * @param tableName 表名
    * @param colAndValue 必须的 （条件，值）
    * @param colAndValues 可选多个 （条件，值）
    * @return 数据
    */
   @SafeVarargs
   public static JSONObject getDimInfo(String tableName, Tuple2<String, String> colAndValue, Tuple2<String, String>... colAndValues) {
       //缓存 key
       StringBuilder cacheKey = new StringBuilder().append("dim:").append(tableName.toLowerCase()).append(":").append(colAndValue.f1);
       for (Tuple2<String, String> cv : colAndValues) {
           cacheKey.append("_").append(cv.f1);
       }
       try (Jedis jedis = RedisUtil.getJedis()) {
           //查缓存
           String str = jedis.get(cacheKey.toString());
           if (StringUtils.isNotBlank(str)) {
               return JSON.parseObject(str);
           }
           //拼接sql
           StringBuilder sql = new StringBuilder();
           sql.append("select * from ").append(TmallConfig.HBASE_SCHEMA).append(".").append(tableName)
                   .append(" where ").append(colAndValue.f0).append("='").append(colAndValue.f1).append("' ");
           for (Tuple2<String, String> cv : colAndValues) {
               sql.append("and ").append(cv.f0).append("='").append(cv.f1).append("' ");
           }
           // 查询
           List<JSONObject> jsonObjectList = PhoenixUtil.queryList(sql.toString(), JSONObject.class);
           if (!jsonObjectList.isEmpty()) {
               JSONObject jsonObject = jsonObjectList.get(0);
               jedis.setex(cacheKey.toString(), 60 * 60 * 24, jsonObject.toJSONString());
               return jsonObject;
           }
       }
       return null;
   }

}

xml复制代码<property>
    <name>phoenix.schema.isNamespaceMappingEnabled</name>
    <value>true</value>
</property>

<property>
    <name>phoenix.schema.mapSystemTablesToNamespace</name>
    <value>true</value>
</property>

sql复制代码<insert id=”insertname”>
insert into names (name) values (#{value})
</insert>

ini复制代码list < string > names = new arraylist();
names.add(“fred”);
names.add(“barney”);
names.add(“betty”);
names.add(“wilma”);
 
// 注意 executortype.batch
sqlsession sqlsession =sqlsessionfactory.opensession(executortype.batch);
try {
    namemapper mapper = sqlsession.getmapper(namemapper.class);
    for (string name: names) {
        mapper.insertname(name);
    }
    sqlsession.commit();
} catch (Exception e) {
    e.printStackTrace();
    sqlSession.rollback();
    throw e;
} finally {
    sqlsession.close();
}

ini复制代码useGeneratedKeys="true" keyProperty="id"

arduino复制代码Public User selectUser(String name,String area);

csharp复制代码<select id="selectUser" resultMap="BaseResultMap" parameterType="java.lang.String">  
    select  *  from user_user_t   where user_name = #{0} and user_area=#{1}  
</select>

less复制代码Public User selectUser(@param(“userName”)Stringname,@param(“userArea”)String area);

sql复制代码<select id=" selectUser" resultMap="BaseResultMap">  
   select  *  from user_user_t   where user_name = #{userName，jdbcType=VARCHAR} and user_area=#{userArea,jdbcType=VARCHAR}  
</select>

xml复制代码<!-- 查询学生list，like姓名 -->  

<select id=" getStudentListLikeName " parameterType="StudentEntity" resultMap="studentResultMap">  

    SELECT * from STUDENT_TBL ST   

    <if test="studentName!=null and studentName!='' ">  

        WHERE ST.STUDENT_NAME LIKE CONCAT(CONCAT('%', #{studentName}),'%')   

    </if>  

</select>

xml复制代码
<!-- 查询学生list，like姓名，=性别 -->  
<select id="getStudentListWhere" parameterType="StudentEntity" resultMap="studentResultMap">  
    SELECT * from STUDENT_TBL ST   
    <where>  
        <if test="studentName!=null and studentName!='' ">  
            ST.STUDENT_NAME LIKE CONCAT(CONCAT('%', #{studentName}),'%')   
        </if>  
        <if test="studentSex!= null and studentSex!= '' ">  
            AND ST.STUDENT_SEX = #{studentSex}   
        </if>  
    </where>  
</select>

xml复制代码<!-- 更新学生信息 -->  
<update id="updateStudent" parameterType="StudentEntity">  
    UPDATE STUDENT_TBL   
    <set>  
        <if test="studentName!=null and studentName!='' ">  
            STUDENT_TBL.STUDENT_NAME = #{studentName},   
        </if>  
        <if test="studentSex!=null and studentSex!='' ">  
            STUDENT_TBL.STUDENT_SEX = #{studentSex},   
        </if>  
        <if test="studentBirthday!=null ">  
            STUDENT_TBL.STUDENT_BIRTHDAY = #{studentBirthday},   
        </if>  
        <if test="classEntity!=null and classEntity.classID!=null and classEntity.classID!='' ">  
            STUDENT_TBL.CLASS_ID = #{classEntity.classID}   
        </if>  
    </set>  
    WHERE STUDENT_TBL.STUDENT_ID = #{studentID};   
</update>

xml复制代码 <!-- 查询学生list，like姓名，=性别 -->  
<select id="getStudentListWhere" parameterType="StudentEntity" resultMap="studentResultMap">  
    SELECT * from STUDENT_TBL ST   
    <trim prefix="WHERE" prefixOverrides="AND|OR">  
        <if test="studentName!=null and studentName!='' ">  
            ST.STUDENT_NAME LIKE CONCAT(CONCAT('%', #{studentName}),'%')   
        </if>  
        <if test="studentSex!= null and studentSex!= '' ">  
            AND ST.STUDENT_SEX = #{studentSex}   
        </if>  
    </trim>  
</select>

xml复制代码<!-- 查询学生list，like姓名、或=性别、或=生日、或=班级，使用choose -->  
<select id="getStudentListChooseEntity" parameterType="StudentEntity" resultMap="studentResultMap">  
    SELECT * from STUDENT_TBL ST   
    <where>  
        <choose>  
            <when test="studentName!=null and studentName!='' ">  
                    ST.STUDENT_NAME LIKE CONCAT(CONCAT('%', #{studentName}),'%')   
            </when>  
            <when test="studentSex!= null and studentSex!= '' ">  
                    AND ST.STUDENT_SEX = #{studentSex}   
            </when>  
            <when test="studentBirthday!=null">  
                AND ST.STUDENT_BIRTHDAY = #{studentBirthday}   
            </when>  
            <when test="classEntity!=null and classEntity.classID !=null and classEntity.classID!='' ">  
                AND ST.CLASS_ID = #{classEntity.classID}   
            </when>  
            <otherwise>  
                   
            </otherwise>  
        </choose>  
    </where>  
</select>

sql复制代码<select id="getStudentListByClassIDs" resultMap="studentResultMap">  
    SELECT * FROM STUDENT_TBL ST   
     WHERE ST.CLASS_ID IN    
     <foreach collection="list" item="classList"  open="(" separator="," close=")">  
        #{classList}   
     </foreach>      
</select>

xml复制代码<mapper namespace="com.lcb.mapping.userMapper">  
    <!--association  一对一关联查询 -->  
    <select id="getClass" parameterType="int" resultMap="ClassesResultMap">  
        select * from class c,teacher t where c.teacher_id=t.t_id and c.c_id=#{id}  
    </select>  
 
    <resultMap type="com.lcb.user.Classes" id="ClassesResultMap">  
        <!-- 实体类的字段名和数据表的字段名映射 -->  
        <id property="id" column="c_id"/>  
        <result property="name" column="c_name"/>  
        <association property="teacher" javaType="com.lcb.user.Teacher">  
            <id property="id" column="t_id"/>  
            <result property="name" column="t_name"/>  
        </association>  
    </resultMap>  

</mapper>

xml复制代码<!--collection  一对多关联查询 -->  
    <select id="getClass2" parameterType="int" resultMap="ClassesResultMap2">  
        select * from class c,teacher t,student s where c.teacher_id=t.t_id and c.c_id=s.class_id and c.c_id=#{id}  
    </select>  
 
    <resultMap type="com.lcb.user.Classes" id="ClassesResultMap2">  
        <id property="id" column="c_id"/>  
        <result property="name" column="c_name"/>  
        <association property="teacher" javaType="com.lcb.user.Teacher">  
            <id property="id" column="t_id"/>  
            <result property="name" column="t_name"/>  
        </association>  
 
        <collection property="student" ofType="com.lcb.user.Student">  
            <id property="id" column="s_id"/>  
            <result property="name" column="s_name"/>  
        </collection>  
    </resultMap>

ini复制代码
<mappers>

<mapper resource="mapper.xml 文件的地址" />

<mapper resource="mapper.xml 文件的地址" />

</mappers>

ini复制代码
<bean id=" " class="mapper 接口的实现">

 <property name="sqlSessionFactory" ref="sqlSessionFactory"></property>

</bean>

ini复制代码<mappers>

<mapper resource="mapper.xml 文件的地址" />

<mapper resource="mapper.xml 文件的地址" />

</mappers>

ini复制代码
<bean id="" class="org.mybatis.spring.mapper.MapperFactoryBean">

<property name="mapperInterface" value="mapper 接口地址" />

<property name="sqlSessionFactory" ref="sqlSessionFactory" />

</bean>

ini复制代码<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">

<property name="basePackage" value="mapper 接口包地址"></property>

<property name="sqlSessionFactoryBeanName"value="sqlSessionFactory"/>

</bean>

typescript复制代码public interface Interceptor {

  Object intercept(Invocation invocation) throws Throwable;
  default Object plugin(Object target) {
    return Plugin.wrap(target, this);
  }
  default void setProperties(Properties properties) {
    // NOP
  }
}

typescript复制代码public class Invocation {

  private final Object target;
  private final Method method;
  private final Object[] args;
  public Invocation(Object target, Method method, Object[] args) {
    this.target = target;
    this.method = method;
    this.args = args;
  }

  public Object getTarget() {
    return target;
  }

  public Method getMethod() {
    return method;
  }

  public Object[] getArgs() {
    return args;
  }

  public Object proceed() throws InvocationTargetException, IllegalAccessException {
    return method.invoke(target, args);
  }

}

markdown复制代码# My map

## Search sites

- [Google](https://www.google.com/)
- [Baidu](https://www.baidu.com/)
- [Bing](https://www.bing.com/)
- [pixabay](https://pixabay.com/)

## WeChat public number

### The preparatory work

- The theme
- conceived
- writing
- typography
- Adjustment and supplement
- Design cover drawing
- Regularly send

### Late work

- Public number text reading
- The reader forward
- The secondary transfer
- Circle of friends
- community
- ......

---

- learning
- The input
- The output

shell复制代码FROM 			# 基础镜像，一切从这里开始
MAINTAINER	        # 镜像是谁写的
RUN 			# 镜像构建是需要运行的命令
ADD		        # 步骤
WORKDIR			# 镜像的工作目录
VOLUME			# 挂载的目录
EXPOSE			# 保留端口配置
CMD		        # 指定这个容器启动时要运行的命令，只有最后一个会生效
ENTRYPOINT		# 指定这个容器启动时要运行的命令，可以追加命令
COPY			# 类似ADD，将文件拷贝到镜像中
ENV			# 构建时候设置的环境变量

ruby复制代码$ docker run -it centos
[root@8fbe85e4a93b /]# vim
bash: vim: command not found
[root@8fbe85e4a93b /]# ifconfig
bash: ifconfig: command not found
[root@8fbe85e4a93b /]#

bash复制代码FROM centos

ENV MYPATH /usr/local
WORKDIR $MYPATH

RUN yum -y install vim
RUN yum -y install net-tools

EXPOSE 80

CMD echo $MYPATH
CMD echo "---end---"
CMD /bin/bash

复制代码docker build -f mydockerfile -t mycentos:0.1 .

arduino复制代码docker run -it mycentos:0.1

bash复制代码docker history

shell复制代码FROM centos
MAINTAINER ajajaj

COPY readme.txt /usr/local/readme.txt

ADD jdk-8u301-linux-x64.tar /usr/local/
ADD apache-tomcat-8.5.70.tar.gz /usr/local/

RUN yum -y install vim

ENV MYPATH /usr/local
WORKDIR $MYPATH

ENV JAVA_HOME /usr/local/jdk1.8.0_301
ENV CLASSPATH $JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
ENV CATALINA_HOME /usr/local/apache-tomcat-8.5.70
ENV CATALINA_BASH /usr/local/apache-tomcat-8.5.70
ENV PATH $PATH:$JAVA_HOME/bin:$CATALINA_HOME/lib:$CATALINA_HOME/bin

EXPOSE 8080

CMD /usr/local/apache-tomcat-8.5.70/bin/startup.sh && tail -F
/usr/local/apache-tomcat-8.5.70/bin/logs/catalina.out

erlang复制代码docker build -t diytomcat .

shell复制代码docker run -d -p 9090:8080 --name ajtomcat -v /Users/cb/test/tomcat-out/test:/usr/local/apache-tomcat-8.5.70/webapps/test -v /Users/cb/test/tomcat-out/tomcatlogs:/usr/local/apache-tomcat-8.5.70/logs diytomcat

shell复制代码$ docker exec -it 9f3f7ed2b184 /bin/bash
[root@9f3f7ed2b184 local]#

xml复制代码<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee"
    xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    id="WebApp_ID" version="2.5">
</web-app>

jsp复制代码<html>
<head><title>Hello World</title></head>
<body>
Hello World!<br/>
<%
out.println("Your IP address is " + request.getRemoteAddr());
%>
</body>
</html>

sql复制代码CREATE TABLE `table_process` (
  `source_table` varchar(200) NOT NULL COMMENT '来源表',
  `operate_type` varchar(200) NOT NULL COMMENT '操作类型 insert,update,delete（用于过滤是否处理 某些操作的数据）',
  `sink_type` varchar(200) DEFAULT NULL COMMENT '输出类型 hbase kafka',
  `sink_table` varchar(200) DEFAULT NULL COMMENT '输出表(主题)',
  `sink_columns` varchar(2000) DEFAULT NULL COMMENT '输出字段（用于过滤一些不需要的字段）',
  `sink_pk` varchar(200) DEFAULT NULL COMMENT '主键字段',
  `sink_extend` varchar(200) DEFAULT NULL COMMENT '建表扩展（建hbase表时，的表配置）',
  PRIMARY KEY (`source_table`,`operate_type`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

xml复制代码<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.47</version>
</dependency>
<dependency>
   <groupId>com.alibaba.ververica</groupId>
    <artifactId>flink-connector-mysql-cdc</artifactId>
    <version>1.2.0</version>
</dependency>
<dependency>
    <groupId>commons-beanutils</groupId>
    <artifactId>commons-beanutils</artifactId>
    <version>1.9.3</version>
</dependency>
<dependency>
    <groupId>org.apache.phoenix</groupId>
    <artifactId>phoenix-spark</artifactId>
    <version>5.0.0-HBase-2.0</version>
    <exclusions>
        <exclusion>
            <groupId>org.glassfish</groupId>
            <artifactId>javax.el</artifactId>
        </exclusion>
    </exclusions>
</dependency>

java复制代码@Data
public class TableProcess {

    /**
     * 动态分流Sink常量   改为小写和脚本一致
     */
    public static final String SINK_TYPE_HBASE = "hbase";
    public static final String SINK_TYPE_KAFKA = "kafka";
    public static final String SINK_TYPE_CK = "clickhouse";

    /**
     * 来源表
     */
    private String sourceTable;

    /**
     * 操作类型 insert,update,delete
     */
    private String operateType;

    /**
     * 输出类型 hbase kafka
     */
    private String sinkType;

    /**
     * 输出表(主题)
     */
    private String sinkTable;

    /**
     * 输出字段
     */
    private String sinkColumns;

    /**
     * 主键字段
     */
    private String sinkPk;

    /**
     * 建表扩展
     */
    private String sinkExtend;
}

bash复制代码sudo vim /etc/my.cnf

ini复制代码server-id=1
log-bin=mysql-bin 
binlog_format=row 
binlog-do-db=tmall
binlog-do-db=tmall_realtime

vbnet复制代码    HELO 向服务器标识用户身份\
    MAIL 初始化邮件传输 mail from:\
    RCPT 标识单个的邮件接收人；常在MAIL命令后面,可有多个rcpt to:\
    DATA 在单个或多个RCPT命令后,表示所有的邮件接收人已标识,并初始化数据传输,以.结束\
    VRFY 用于验证指定的用户/邮箱是否存在；由于安全方面的原因,服务器常禁止此命令\
    EXPN 验证给定的邮箱列表是否存在,扩充邮箱列表,也常被禁用\
    HELP 查询服务器支持什么命令\
    NOOP 无操作,服务器应响应OK\
    QUIT 结束会话\
    RSET 重置会话,当前传输被取消\
    MAIL FROM 指定发送者地址\
    RCPT TO 指明的接收者地址

python复制代码
# smtplib 用于邮件的发信动作
import smtplib
from email.mime.text import MIMEText
# email 用于构建邮件内容
from email.header import Header
# 用于构建邮件头
# 发信方的信息：发信邮箱，126 邮箱授权码
from_addr = 'trobot@126.com'
password = 'POP3/SMTP服务授权密码,上一步可以获取'
 
# 收信方邮箱
to_addr = 'xxxx@163.com'
 
# 发信服务器
smtp_server = 'smtp.126.com'


"""标题"""
head="邮箱验证码"
"""正文"""
text="【TRobot】您的验证码32123，该验证码5分钟内有效，请勿泄漏于他人！"

 
# 邮箱正文内容，第一个参数为内容，第二个参数为格式(plain 为纯文本)，第三个参数为编码
msg = MIMEText(text,'plain','utf-8')
 
# 邮件头信息
msg['From'] = Header(from_addr)
msg['To'] = Header(to_addr)
msg['Subject'] = Header(head)
 
# 开启发信服务，这里使用的是加密传输
#server = smtplib.SMTP_SSL()
server=smtplib.SMTP_SSL(smtp_server)
server.connect(smtp_server,465)
# 登录发信邮箱
server.login(from_addr, password)
# 发送邮件
server.sendmail(from_addr, to_addr, msg.as_string())
# 关闭服务器
server.quit()

arduino复制代码$ nvm use v8.16.0
Now using node v8.16.0 (npm v6.4.1)

$ nvm use v14.15.4
Now using node v14.15.4 (npm v6.14.10)

$ nvm use v18.6.0
Now using node v18.6.0 (npm v8.13.2)

ruby复制代码$ brew install nvm

shell复制代码$ curl -o- https://raw.githubusercontent.com/nvm-sh/nvm/v0.39.1/install.sh | bash
或
$ wget -qO- https://raw.githubusercontent.com/nvm-sh/nvm/v0.39.1/install.sh | bash

shell复制代码# 安装
$ bash -c "$(curl -fsSL https://gitee.com/RubyKids/nvm-cn/raw/master/install.sh)"

# 卸载
$ bash -c "$(curl -fsSL https://gitee.com/RubyKids/nvm-cn/raw/master/uninstall.sh)"

shell复制代码$ sh xxx/instal.sh

error复制代码=> Profile not found. Tried ~/.bashrc, ~/.bash_profile, ~/.zshrc, and ~/.profile.

![image.png](https://gitee.com/songjianzaina/juejin_p3/raw/master/img/79ec57565b557f47c80344cbc8d30b3cdb6ffbf02b43ff16e5048adc33a9041a)


#### 四、使用 `nvm`


* 安装最新稳定版 `node`，当前是 `node v12.9.1 (npm v7.9.0)`

* 安装指定版本，可模糊安装，如：安装 `v4.4.0`，既可 `$ nvm install v4.4.0`，又可 `$ nvm install 4.4`

* 删除已安装的指定版本，语法与 `install` 用法一致

* 切换使用指定的版本 `node`

`注意`：在任意一个命令行窗口进行切换之后，其他的窗口或其他命令行工具窗口 `需要关掉工具，重启才能生效`。（例如 `VSCode` 内或外部命令切换之后，需要重启 `VSCode`，才能正常生效，否则或处于 `临时生效状态`，也就是在 `VSCode` 中重新打开一个命令行查看版本还会是旧版本，所以必须要重启。）


这里的 `重启` 不是简单的关掉窗口重启，没有退出后台进程，而是完全退出杀死工具进程，重新启动。
* 列出所有安装的版本

* 列出所有远程服务器的版本（官方 `node version list`）

* 显示当前的版本

* 给不同的版本号添加别名

* 删除已定义的别名

* 在当前版本 `node` 环境下，重新全局安装指定版本号的 `npm` 包

* 查看更多命令可在终端输入

javascript复制代码npm install multiparty

javascript复制代码(req, res)=>{
var form = new multiparty.Form({uploadDir:'保存文件的地址'})
// 进行解析
form.parse(req)
}

javascript复制代码const express = require('express');
const multiparty = require('multiparty');
const app = express();
const fs = require('fs');
const path = require('path')
const Busboy = require('busboy');

app.get('/', (req, res) => {
    res.send('hello, this is a node server for upload file current env is' + process.env.NODE_ENV)
})
// 跨域
app.use(function (req, res, next) {
    if (req.method == 'OPTIONS') res.send('OPTIONS PASS')
    res.append('Access-Control-Allow-Origin', '*')
    res.append('Access-Control-Allow-Methods', 'OPTIONS, GET, PUT, POST, DELETE')
    res.append('Access-Control-Allow-Headers', '*')
    next();
});
// 上传
app.post('/upload', (req, res) => {
    const form = new multiparty.Form();
    try {
        form.on('part', async function (part) {
            if (part.filename) {
                // 获取上传路径
                const p = await new Promise((resolve, reject) => {
                    form.on('field', (name, value) => {
                        resolve(name == 'path'?value:'')
                    })
                })
                const saveTo = (process.env.NODE_ENV == 'dev' ? 'D://Temp' : '/usr/static') + (p || '/default')
                // 如果不存在文件夹路径则创建文件夹
                await new Promise((resolve, reject) => {
                    fs.stat(saveTo, (err) => {
                        if (err) {
                            fs.mkdirSync(saveTo);
                        }
                        resolve()
                    })
                })
                // 根据路径创建写入流
                const writeStrem = fs.createWriteStream(path.join(saveTo, part.filename))
                part.pipe(writeStrem)
            }
            part.on('error', function (err) {
                fileStrem.destroy();
            });
        });
        form.parse(req)
    } catch (e) {
        console.log(e)
        res.send('500')
    }
    res.send('200')
})
app.listen(8010, function () {
    console.log('Example app listening on port 8010!\n');
});

javascript复制代码const express = require('express');
const multiparty = require('multiparty');
const app = express();
const fs = require('fs');
const path = require('path')
const Busboy = require('busboy');

app.get('/', (req, res) => {
    res.send('hello, this is a node server for upload file current env is' + process.env.NODE_ENV)
})
// 跨域
app.use(function (req, res, next) {
    if (req.method == 'OPTIONS') res.send('OPTIONS PASS')
    res.append('Access-Control-Allow-Origin', '*')
    res.append('Access-Control-Allow-Methods', 'OPTIONS, GET, PUT, POST, DELETE')
    res.append('Access-Control-Allow-Headers', '*')
    next();
});
// 上传
app.post('/upload', (req, res) => {
    // const form = new multiparty.Form();
    // try {
    //     form.on('part', async function (part) {
    //         if (part.filename) {
    //             // 获取上传路径
    //             const p = await new Promise((resolve, reject) => {
    //                 form.on('field', (name, value) => {
    //                     resolve(name == 'path'?value:'')
    //                 })
    //             })
    //             const saveTo = (process.env.NODE_ENV == 'dev' ? 'D://Temp' : '/usr/static') + (p || '/default')
    //             // 如果不存在文件夹路径则创建文件夹
    //             await new Promise((resolve, reject) => {
    //                 fs.stat(saveTo, (err) => {
    //                     if (err) {
    //                         fs.mkdirSync(saveTo);
    //                     }
    //                     resolve()
    //                 })
    //             })
    //             // 根据路径创建写入流
    //             const writeStrem = fs.createWriteStream(path.join(saveTo, part.filename))
    //             part.pipe(writeStrem)
    //         }
    //         part.on('error', function (err) {
    //             fileStrem.destroy();
    //         });
    //     });
    //     form.parse(req)
    // } catch (e) {
    //     console.log(e)
    //     res.send('500')
    // }
    const busboy = new Busboy({ headers: req.headers });
    busboy.on('file', function(fieldname, file, filename, encoding, mimetype) {
        var saveTo = path.join('D://Temp', path.basename(filename));
        file.pipe(fs.createWriteStream(saveTo));
      });
      busboy.on('finish', function() {
        res.writeHead(200, { 'Connection': 'close' });
        res.end("That's all folks!");
      });
      return req.pipe(busboy); 
})
app.listen(8010, function () {
    console.log('Example app listening on port 8010!\n');
});

xml复制代码<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-validation</artifactId>
</dependency>

java复制代码@Data
public class ValidVO {
    private String id;

    @Length(min = 6,max = 12,message = "appId长度必须位于6到12之间")
    private String appId;

    @NotBlank(message = "名字为必填项")
    private String name;

    @Email(message = "请填写正确的邮箱地址")
    private String email;

    private String sex;

    @NotEmpty(message = "级别不能为空")
    private String level;
}

java复制代码@RestController
@Slf4j
@Validated
public class ValidController {

    @ApiOperation("RequestBody校验")
    @PostMapping("/valid/test1")   
    public String test1(@Validated @RequestBody ValidVO validVO){
        log.info("validEntity is {}", validVO);
        return "test1 valid success";
    }

    @ApiOperation("Form校验")
    @PostMapping(value = "/valid/test2")
    public String test2(@Validated ValidVO validVO){
        log.info("validEntity is {}", validVO);
        return "test2 valid success";
    }
  
  	@ApiOperation("单参数校验")
    @PostMapping(value = "/valid/test3")
    public String test3(@Email String email){
        log.info("email is {}", email);
        return "email valid success";
    }
}

json复制代码POST http://localhost:8080/valid/test1
Content-Type: application/json

{
  "id": 1,
  "level": "12",
  "email": "47693899",
  "appId": "ab1c"
}

json复制代码{
  "status": 500,
  "message": "Validation failed for argument [0] in public java.lang.String com.jianzh5.blog.valid.ValidController.test1(com.jianzh5.blog.valid.ValidVO) with 3 errors: [Field error in object 'validVO' on field 'email': rejected value [47693899]; codes [Email.validVO.email,Email.email,Email.java.lang.String,Email]; arguments [org.springframework.context.support.DefaultMessageSourceResolvable: codes [validVO.email,email]; arguments []; default message [email],[Ljavax.validation.constraints.Pattern$Flag;@26139123,.*]; default message [不是一个合法的电子邮件地址]]...",
  "data": null,
  "timestamp": 1628239624332
}

json复制代码POST http://localhost:8080/valid/test2
Content-Type: application/x-www-form-urlencoded

id=1&level=12&email=476938977&appId=ab1c

json复制代码{
  "status": 500,
  "message": "org.springframework.validation.BeanPropertyBindingResult: 3 errors\nField error in object 'validVO' on field 'name': rejected value [null]; codes [NotBlank.validVO.name,NotBlank.name,NotBlank.java.lang.String,NotBlank]; arguments [org.springframework.context.support.DefaultMessageSourceResolvable: codes [validVO.name,name]; arguments []; default message [name]]; default message [名字为必填项]...",
  "data": null,
  "timestamp": 1628239301951
}

json复制代码POST http://localhost:8080/valid/test3
Content-Type: application/x-www-form-urlencoded

email=476938977

json复制代码{
  "status": 500,
  "message": "test3.email: 不是一个合法的电子邮件地址",
  "data": null,
  "timestamp": 1628239281022
}

java复制代码@ExceptionHandler(value = {BindException.class, ValidationException.class, MethodArgumentNotValidException.class})
public ResponseEntity<ResultData<String>> handleValidatedException(Exception e) {
  ResultData<String> resp = null;

  if (e instanceof MethodArgumentNotValidException) {
    // BeanValidation exception
    MethodArgumentNotValidException ex = (MethodArgumentNotValidException) e;
    resp = ResultData.fail(HttpStatus.BAD_REQUEST.value(),
                           ex.getBindingResult().getAllErrors().stream()
                           .map(ObjectError::getDefaultMessage)
                           .collect(Collectors.joining("; "))
                          );
  } else if (e instanceof ConstraintViolationException) {
    // BeanValidation GET simple param
    ConstraintViolationException ex = (ConstraintViolationException) e;
    resp = ResultData.fail(HttpStatus.BAD_REQUEST.value(),
                           ex.getConstraintViolations().stream()
                           .map(ConstraintViolation::getMessage)
                           .collect(Collectors.joining("; "))
                          );
  } else if (e instanceof BindException) {
    // BeanValidation GET object param
    BindException ex = (BindException) e;
    resp = ResultData.fail(HttpStatus.BAD_REQUEST.value(),
                           ex.getAllErrors().stream()
                           .map(ObjectError::getDefaultMessage)
                           .collect(Collectors.joining("; "))
                          );
  }

  return new ResponseEntity<>(resp,HttpStatus.BAD_REQUEST);
}

java复制代码POST http://localhost:8080/valid/test1
Content-Type: application/json

{
  "id": 1,
  "level": "12",
  "email": "47693899",
  "appId": "ab1c"
}

json复制代码{
  "status": 400,
  "message": "名字为必填项; 不是一个合法的电子邮件地址; appId长度必须位于6到12之间",
  "data": null,
  "timestamp": 1628435116680
}

java复制代码@Target({METHOD, FIELD, ANNOTATION_TYPE, CONSTRUCTOR, PARAMETER, TYPE_USE})
@Retention(RUNTIME)
@Repeatable(EnumString.List.class)
@Documented
@Constraint(validatedBy = EnumStringValidator.class)//标明由哪个类执行校验逻辑
public @interface EnumString {
    String message() default "value not in enum values.";

    Class<?>[] groups() default {};

    Class<? extends Payload>[] payload() default {};

    /**
     * @return date must in this value array
     */
    String[] value();

    /**
     * Defines several {@link EnumString} annotations on the same element.
     *
     * @see EnumString
     */
    @Target({METHOD, FIELD, ANNOTATION_TYPE, CONSTRUCTOR, PARAMETER, TYPE_USE})
    @Retention(RUNTIME)
    @Documented
    @interface List {

        EnumString[] value();
    }
}

java复制代码public class EnumStringValidator implements ConstraintValidator<EnumString, String> {
    private List<String> enumStringList;

    @Override
    public void initialize(EnumString constraintAnnotation) {
        enumStringList = Arrays.asList(constraintAnnotation.value());
    }

    @Override
    public boolean isValid(String value, ConstraintValidatorContext context) {
        if(value == null){
            return true;
        }
        return enumStringList.contains(value);
    }
}

java复制代码@ApiModelProperty(value = "性别")
@EnumString(value = {"F","M"}, message="性别只允许为F或M")
private String sex;

java复制代码POST http://localhost:8080/valid/test2
Content-Type: application/x-www-form-urlencoded

id=1&name=javadaily&level=12&email=476938977@qq.com&appId=ab1cdddd&sex=N

json复制代码{
  "status": 400,
  "message": "性别只允许为F或M",
  "data": null,
  "timestamp": 1628435243723
}

java复制代码public interface ValidGroup extends Default {
  
    interface Crud extends ValidGroup{
        interface Create extends Crud{

        }

        interface Update extends Crud{

        }

        interface Query extends Crud{

        }

        interface Delete extends Crud{

        }
    }
}

java复制代码@Data
@ApiModel(value = "参数校验类")
public class ValidVO {
    @ApiModelProperty("ID")
    @Null(groups = ValidGroup.Crud.Create.class)
    @NotNull(groups = ValidGroup.Crud.Update.class, message = "应用ID不能为空")
    private String id;

    @Null(groups = ValidGroup.Crud.Create.class)
    @NotNull(groups = ValidGroup.Crud.Update.class, message = "应用ID不能为空")
    @ApiModelProperty(value = "应用ID",example = "cloud")
    private String appId;

    @ApiModelProperty(value = "名字")
    @NotBlank(groups = ValidGroup.Crud.Create.class,message = "名字为必填项")
    private String name;
  
  	@ApiModelProperty(value = "邮箱")
    @Email(message = "请填写正取的邮箱地址")
    privte String email;

   	...

}

java复制代码@RestController
@Api("参数校验")
@Slf4j
@Validated
public class ValidController {

    @ApiOperation("新增")
    @PostMapping(value = "/valid/add")
    public String add(@Validated(value = ValidGroup.Crud.Create.class) ValidVO validVO){
        log.info("validEntity is {}", validVO);
        return "test3 valid success";
    }


    @ApiOperation("更新")
    @PostMapping(value = "/valid/update")
    public String update(@Validated(value = ValidGroup.Crud.Update.class) ValidVO validVO){
        log.info("validEntity is {}", validVO);
        return "test4 valid success";
    }
}

java复制代码POST http://localhost:8080/valid/add
Content-Type: application/x-www-form-urlencoded

name=javadaily&level=12&email=476938977@qq.com&sex=F

java复制代码{
  "status": 400,
  "message": "ID不能为空; 应用ID不能为空",
  "data": null,
  "timestamp": 1628492514313
}

java复制代码POST http://localhost:8080/valid/add
Content-Type: application/x-www-form-urlencoded

name=javadaily&level=12&email=476938977&sex=F

json复制代码{
  "status": 400,
  "message": "请填写正取的邮箱地址",
  "data": null,
  "timestamp": 1628492637305
}

shell复制代码tar -zxvf Nacos下载包的名称

shell复制代码startup.cmd -m standalone

xml复制代码<!--nacos客户端-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

java复制代码@SpringBootApplication
@EnableDiscoveryClient
public class ShopProductServerApp {
  public static void main(String[] args) {
    SpringApplication.run(ShopProductServerApp.class,args);
  }
}

yaml复制代码spring:
  cloud: 
    nacos: 
      discovery: 
        server-addr: localhost:8848

xml复制代码<!--nacos客户端-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

java复制代码@SpringBootApplication
@EnableDiscoveryClient
public class ShopOrderServerApp {
  public static void main(String[] args) {
    SpringApplication.run(ShopOrderServerApp.class,args);
  }

  @Bean
  @LoadBalanced
  public RestTemplate getInstance(){
    return new RestTemplate();
  }
}

yaml复制代码spring:
  cloud: 
    nacos: 
      discovery: 
        server-addr: localhost:8848

java复制代码  @Autowired
  private DiscoveryClient discoveryClient;
  @RequestMapping("test")
  public String test(){
    ServiceInstance serviceInstance = discoveryClient.getInstances("product-service").get(0);
    return serviceInstance.toString();
  }