UUBlog

UUBlog

Posted on Edited on In

问题描述

在这篇文章《Docker Swarm Mode中部署SpringCloud微服务》之后

遇到了点新问题。

在运行时指定自己网络的时候，容器里面多个网络，多个IP，但是注册的不是固定注册某个网卡的IP作为服务IP。

这就导致有时候注册的IP不是属于overlay网络的IP。服务访问就会出现问题。

Read more »

关注公众号 尹安灿

Posted on Edited on In

有同志容器的日志写到了自己容器里面。但是出问题后，一直写，导致磁盘写满。

以上是问题出现的前奏。

我接着清理下无用的容器，先快速释放部分空间出来。

1
docker system prune -a

紧接着我就出去帮忙别的东西了。

过一会被告知，Jenkins构建失败，而不止一个项目。每个项目出错如下：

Read more »

关注公众号 尹安灿

Posted on Edited on In

根据给定日期，生成 5*7的日历。自动补齐前面的日期。

含计算日期，计算星期几等函数。生生复习了一遍闰年和星期几计算。记录下留档。

Read more »

关注公众号 尹安灿

Posted on Edited on In

[TOC]

在Docker Swarm中部署Spring Cloud的服务.

本来服务注册是由Eureka做的,但是Eureka团队停止对该项目支持.于是我们转而转向consul.

经实践,最终定下来新的微服务部署用到的技术如下.

Docker+Consul+Registrator

实验环境

三台机：

  • node1：192.168.99.100

  • node2：192.168.99.101

  • node3：192.168.99.102

规划如下：

node1: Consul Server,Docker Swarm master

node2: Consul Server,Docker Swarm node

node3: Consul Client,Docker Swarm node

一般建议consul server数量为3~5个，做高可用，但是由于是演示，机器也比较渣，就不启用多台作为实验。

Read more »

关注公众号 尹安灿

Posted on Edited on In

[TOC]

Consul

整理了一些觉得有用的资料和踩过的坑.

为什么选用consul

1.因为Eureka即将停止维护了

2.Consul要更强大点,带配置中心

  • 每台机都必须运行一个consul agent.
  • consul agent有两种模式,1,server模式 2,client模式.
  • consul server,每个数据中心会有一个leader有server选举出来,故障后会重新选举.
  • consul server,保持数据一致性,维护集群状态,转发查询,转发请求给leader或者远程数据中心,交换wan gossip.
  • consul client用于注册服务,运行健康检查和转发对server的查询.
  • node名字必须在集群中唯一
Read more »

关注公众号 尹安灿

Posted on Edited on In

主要注意挂载目录以便数据持久化,命名hostname.

1
docker run -d --name rabbitmq -p 4369:4369 -p 8080:15672 -p 5671-5672:5671-5672 --restart=always --hostname my-rabbit  -v /data/rabbitmq:/var/lib/rabbitmq rabbitmq:3-management

关注公众号 尹安灿

Posted on Edited on In

一个连接rabbitmq的python例子.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
# coding: utf-8
import json

import pika
# from selenium.webdriver.common.by import By

from house_info import HouseInfo

# CONFIG AREA
AMQP_CONFIG = {
    'host': '127.0.0.1',
    'port': 5672,
    'username': 'guest',
    'password': 'guest'
}
AMQP_QUEUE_NAME = 'house-inquery'
AMQP_FEEDBACK_QUEUE_NAME = 'house-inquery-result'


# 因为反馈回去的队列要求在不同队列,所以重新建立了一个新的队列连接
def process_feedback(msg):
    mq_credential = pika.PlainCredentials(
        username=AMQP_CONFIG['username'],
        password=AMQP_CONFIG['password']
    )
    mq_conn = pika.BlockingConnection(pika.ConnectionParameters(
        host=AMQP_CONFIG['host'],
        credentials=mq_credential
    ))
    mq_channel = mq_conn.channel()
    mq_channel.queue_declare(queue=AMQP_FEEDBACK_QUEUE_NAME, durable=True)
    return mq_channel.basic_publish(exchange='',
                                    routing_key=AMQP_FEEDBACK_QUEUE_NAME,
                                    body=msg,
                                    properties=pika.BasicProperties(
                                        delivery_mode=2,
                                        content_encoding='UTF-8',
                                        content_type='text/plain'
                                    )
                                    )


user_pwd = pika.PlainCredentials(AMQP_CONFIG['username'], AMQP_CONFIG['password'])
s_conn = pika.BlockingConnection(pika.ConnectionParameters(AMQP_CONFIG['host'], credentials=user_pwd))
channel = s_conn.channel()
channel.queue_declare(queue=AMQP_QUEUE_NAME, durable=True)


def callback(ch, method, properties, body):
    print(body)
    query_data = json.loads(body)
    if not query_data:
        return
    try:
        # 一些业务逻辑代码
        # 应答消息
        ch.basic_ack(delivery_tag=method.delivery_tag)
    except Exception as e:
        print(e)

# 设置一次只获取一条消息处理
channel.basic_qos(prefetch_count=1)
# 启用ack,防止异常消息丢失 确认处理后再删除消息
channel.basic_consume(callback, queue=AMQP_QUEUE_NAME, no_ack=False)
channel.start_consuming()

关注公众号 尹安灿

Posted on Edited on In ,

其实就是通过flask接受url传递过来的命令，然后调用SDK相关API执行docker exec命令，然后将结果返回给页面。

1
pip install flask docker
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
# coding: utf-8
from flask import Flask
from flask import render_template
from flask import request
import docker

app = Flask(__name__, template_folder='./templates', static_folder="", static_url_path="")
client = docker.from_env()


@app.route('/cmd', methods=['GET', 'POST'])
def exec_cmd():
    if request.method == 'GET':
        return render_template('cmd.html')
    if request.method == 'POST':
        container = client.containers.get('gmb-index') # 这里我写死了获取本地这个容器
        cmd = request.form.get('cmd')
        result = container.exec_run(cmd=cmd)
        output = result.output.decode()
        return render_template('cmd.html', output=output)


if __name__=='__main__':
    app.run(host='127.0.0.1', port=8888)

模板

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Console</title>
</head>
<body>
<div>
    <form action="/cmd" method="post">
        <input type="text" name="cmd">
        <input type="submit" value="Submit">
    </form>

    <textarea  rows="100" cols="200" readonly="readonly">
{{ output }}
    </textarea>
</div>
</body>
</html>

如图：

截图

参考资料

关注公众号 尹安灿

Posted on Edited on In

某日看到妹子整理表格，需要对excel一万多条记录中的重复数据删除处理。

但是处理两小时没好，耽误了两人看动漫时间，最后帮她搞了这个脚本。

为了速度，存在很多硬编码，但是应该不影响阅读。

Read more »

关注公众号 尹安灿

Posted on Edited on In

已经经历两次开发环境磁盘占用满的情况的。

第一次是部署太频繁，然后有很多无用的images没有删除掉。

第二次是docker容器，某些服务写了很多日志，导致磁盘被写满。

撇开这些设置不当的问题，怎么清理掉一些“垃圾”，让docker占用空间变得小一点？

Docker占用磁盘的主要有以下几样东西：

  1. Docker Images

  2. Docker Containers

  3. Docker Logs

对于输出日志特别多的程序，Logs还是不容小觑的。

尤其是开发服务器，频繁的部署，会导致产生很多用不上的Images也占用在空间。

而Container占用空间突然增大，一般也主要是一些异常产生的文件太多，写了太多logs在容器内所致。

Read more »

关注公众号 尹安灿

0%