Git标签管理知识

更新时间：2017年7月6日 23:33 点击：1496

Gif也是现在很受许多用户关注的，今天文章就就给大家介绍Gif怎么管理，有哪些管理知识。感兴趣的下面一起来看看。

前面的话

发布一个版本时，我们通常先在版本库中打一个标签(tag)。这样，就唯一确定了打标签时刻的版本。将来无论什么时候，取某个标签的版本，就是把那个打标签的时刻的历史版本取出来。所以，标签也是版本库的一个快照，实质上它就是指向某个commit的指针。所以，创建和删除标签都是瞬间完成的。简而言之，标签tag就是一个让人容易记住的有意义的名字，它跟某个commit绑在一起。本文将详细介绍Git标签管理

创建标签

在Git中打标签非常简单，首先，切换到需要打标签的分支上

然后，敲命令git tag就可以打一个新标签

可以用命令git tag查看所有标签

默认标签是打在最新提交的commit上的。有时候，如果忘了打标签怎么办呢？方法是找到历史提交的commit id，然后打上就可以了

比方说要对create b.txt这次提交打标签，它对应的commit id是7ec9296，敲入命令：

再用命令git tag查看标签，注意，标签不是按时间顺序列出，而是按字母排序的

可以用git show查看标签信息

附注标签

实际上，Git使用的标签有两种类型：轻量级的(lightweight)和含附注的(annotated)。上面介绍的就是轻量级标签，轻量级标签就像是个不会变化的分支，实际上它就是个指向特定提交对象的引用。而含附注标签，实际上是存储在仓库中的一个独立对象，它有自身的校验和信息，包含着标签的名字，电子邮件地址和日期，以及标签说明，标签本身也允许使用GNU Privacy Guard(GPG)来签署或验证。一般我们都建议使用含附注型的标签，以便保留相关信息；当然，如果只是临时性加注标签，或者不需要旁注额外信息，用轻量级标签也没问题

创建一个含附注类型的标签非常简单，用-a(取annotated的首字母，中文意思为注释)指定标签名字即可，而-m选项则指定了对应的标签说明，Git会将此说明一同保存在标签对象中。如果没有给出该选项，Git会启动文本编辑软件供你输入标签说明

$ git tag -a v1.4 -m 'my version 1.4'

我们可以看到在提交对象信息上面，列出了此标签的提交者和提交时间，以及相应的标签说明

签署标签

如果有自己的私钥，还可以用GPG来签署标签，只需要把之前的-a改为-s(取signed的首字母，中文意思为有符号的)即可

$ git tag -s v0.2 -m 'signed version 0.2 released'

签名采用PGP签名，因此，必须首先安装gpg(GnuPG)，如果没有找到gpg，或者没有gpg密钥对，就会报错

现在再运行 git show 会看到对应的 GPG 签名也附在其内

$ git show v0.2

tag v0.2

Tagger: Michael Liao

Date: Mon Aug 26 07:28:33 2013 +0800

signed version 0.2 released

-----BEGIN PGP SIGNATURE-----

Version: GnuPG v1.4.12 (Darwin)

iQEcBAABAgAGBQJSGpMhAAoJEPUxHyDAhBpT4QQIAKeHfR3bo...

-----END PGP SIGNATURE-----

commit fec145accd63cdc9ed95a2f557ea0658a2a6537f

Author: Michael Liao

Date: Thu Aug 22 10:37:30 2013 +0800

branchtest

用PGP签名的标签是不可伪造的，因为可以验证PGP签名

可以使用git tag -v [tagname] (取verify的首字母，中文意思为核实)的方式验证已经签署的标签。此命令会调用GPG来验证签名，所以你需要有签署者的公钥，存放在keyring中，才能验证

$ git tag -vv1.4.2.1

object 883653babd8ee7ea23e6a5c392bb739348b1eb61

typecommit

tag v1.4.2.1

tagger Junio C Hamano1158138501 -0700

GIT 1.4.2.1

Minor fixes since 1.4.2, including git-mvand git-http with alternates.

gpg: Signature made Wed Sep 13 02:08:25 2006 PDT using DSA key ID F3119B9A

gpg: Good signature from"Junio C Hamano"

gpg: aka"[jpeg image of size 1513]"

Primary key fingerprint: 3565 2A26 2040 E066 C9A7 4A7D C0C6 D9A4 F311 9B9A

若是没有签署者的公钥，会报告类似下面这样的错误：

gpg: Signature made Wed Sep 13 02:08:25 2006 PDT using DSA key ID F3119B9A

gpg: Can't check signature: public key not found

error: could not verify the tag'v1.4.2.1'

操作标签

如果标签打错了，也可以删除

$ git tag -d

因为创建的标签都只存储在本地，不会自动推送到远程。所以，打错的标签可以在本地安全删除。

默认情况下，git push并不会把标签传送到远端服务器上，只有通过显式命令才能推送标签到远端仓库

$ git push origin

或者，一次性推送全部尚未推送到远程的本地标签

$ git push origin --tags

如果标签已经推送到远程，要删除远程标签就麻烦一点，先从本地删除

然后，从远程删除。删除命令也是push，但是格式如下

最后一个问题，如何查看发送到远程的标签呢？

点击Github项目中的release

即可看到远程标签的信息

本文介绍了php怎么打开html页面的代码，不会的同学快来看看吧！

直接打开就行如： $temp=file_get_contents(Ƈ.htm '); echo $temp;

本文我们来分享一下自动化配置和管理工具saltstack mine如何通过自定义收集minion的状态及应用场景的，对minion开发感兴趣的朋友可以看一下。

mine是做什么？就是你在mine定义了收集模块，他自己会把数据收集的，存到了哪里，不知道，但是肯定是客户端minino本地。有兴趣的朋友可以check saltstack的代码。

这里先粘贴下，官方的doc用法：

代码如下

复制代码

mine.delete:

    Remove specific function contents of minion. Returns True on success.

    CLI Example:

        salt '*' mine.delete 'network.interfaces'


mine.flush:

    Remove all mine contents of minion. Returns True on success.

    CLI Example:

        salt '*' mine.flush


mine.get:

    Get data from the mine based on the target, function and expr_form

    Targets can be matched based on any standard matching system that can be
    matched on the master via these keywords::

        glob
        pcre
        grain
        grain_pcre

    CLI Example:

        salt '*' mine.get '*' network.interfaces
        salt '*' mine.get 'os:Fedora' network.interfaces grain


mine.send:

    Send a specific function to the mine.

    CLI Example:

        salt '*' mine.send network.interfaces eth0


mine.update:

    Execute the configured functions and send the data back up to the master
    The functions to be executed are merged from the master config, pillar and
    minion config under the option "function_cache":

        mine_functions:
          network.ip_addrs:

配置起来很简单，跑到minion端，配置下文件，开启几个模块的检测。

代码如下

复制代码

[root@vm-10-154-252-46 utils]# tail /etc/salt/minion

mine_functions:

test.ping: []

network.dig:

   - www.naver.com

network.usage: []

mine_interval: 1

然后咱们跑到master端去抓数据。

[root@vm-10-154-252-82 ~/clusterops/templates]$salt '10.154.252.46' mine.get '*' network.dig

10.154.252.46:

    ----------

    10.154.252.46:



        ; <<>> DiG 9.8.2rc1-RedHat-9.8.2-0.10.rc1.el6 <<>> www.baidu.com

        ;; global options: +cmd

        ;; Got answer:

        ;; ->>HEADER<<- opcode: QUERY, status: NOERROR, id: 5279

        ;; flags: qr rd ra; QUERY: 1, ANSWER: 3, AUTHORITY: 5, ADDITIONAL: 2

        ;; QUESTION SECTION:

        ;www.baidu.com.                 IN      A


        ;; ANSWER SECTION:

        www.baidu.com.          186     IN      CNAME   www.a.shifen.com.

        www.a.shifen.com.       149     IN      A       220.181.111.188

        www.a.shifen.com.       149     IN      A       220.181.112.244

        ;; AUTHORITY SECTION:

        a.shifen.com.           186     IN      NS      ns3.a.shifen.com.

        a.shifen.com.           186     IN      NS      ns1.a.shifen.com.

        a.shifen.com.           186     IN      NS      ns5.a.shifen.com.

        a.shifen.com.           186     IN      NS      ns2.a.shifen.com.

        a.shifen.com.           186     IN      NS      ns4.a.shifen.com.

        ;; ADDITIONAL SECTION:

        ns5.a.shifen.com.       70      IN      A       119.75.219.43

        ns2.a.shifen.com.       186     IN      A       180.149.133.241



        ;; Query time: 1 msec

        ;; SERVER: 10.150.0.253#53(10.150.0.253)

        ;; WHEN: Wed Jul 2 14:42:55 2014

        ;; MSG SIZE rcvd: 212

[root@vm-10-154-252-82 ~/clusterops/templates]$

我先前定义的是一分钟来生成一次数据。在minon的日志端是可以体现出来的。

代码如下

复制代码

2014-07-03 09:15:05,054 [salt.loaded.int.module.mine
2014-07-03 09:15:05,186 [salt.loaded.int.module.mine
2014-07-03 09:16:05,149 [salt.loaded.int.module.mine
2014-07-03 09:16:05,274 [salt.loaded.int.module.mine
2014-07-03 09:17:05,242 [salt.loaded.int.module.mine
2014-07-03 09:17:05,366 [salt.loaded.int.module.mine
2014-07-03 09:18:05,336 [salt.loaded.int.module.mine
2014-07-03 09:18:05,463 [salt.loaded.int.module.mine
2014-07-03 09:19:05,430 [salt.loaded.int.module.mine
2014-07-03 09:19:05,554 [salt.loaded.int.module.mine
2014-07-03 09:20:05,523 [salt.loaded.int.module.mine
2014-07-03 09:20:05,648 [salt.loaded.int.module.mine
2014-07-03 09:21:05,619 [salt.loaded.int.module.mine
2014-07-03 09:21:05,748 [salt.loaded.int.module.mine
2014-07-03 09:22:05,713 [salt.loaded.int.module.mine
2014-07-03 09:22:05,843 [salt.loaded.int.module.mine
2014-07-03 09:23:05,808 [salt.loaded.int.module.mine
2014-07-03 09:23:05,938 [salt.loaded.int.module.mine
2014-07-03 09:24:05,901 [salt.loaded.int.module.mine
2014-07-03 09:24:06,026 [salt.loaded.int.module.mine
2014-07-03 09:25:05,995 [salt.loaded.int.module.mine
2014-07-03 09:25:06,120 [salt.loaded.int.module.mine
2014-07-03 09:26:05,088 [salt.loaded.int.module.mine
2014-07-03 09:26:05,214 [salt.loaded.int.module.mine
2014-07-03 09:27:05,183 [salt.loaded.int.module.mine
2014-07-03 09:27:05,319 [salt.loaded.int.module.mine
2014-07-03 09:28:05,287 [salt.loaded.int.module.mine
2014-07-03 09:28:05,418 [salt.loaded.int.module.mine
2014-07-03 09:29:05,373 [salt.loaded.int.module.mine
2014-07-03 09:29:05,502 [salt.loaded.int.module.mine
2014-07-03 09:30:05,466 [salt.loaded.int.module.mine
2014-07-03 09:30:05,591 [salt.loaded.int.module.mine
2014-07-03 09:31:05,560 [salt.loaded.int.module.mine
2014-07-03 09:31:05,689 [salt.loaded.int.module.mine
2014-07-03 09:32:05,655 [salt.loaded.int.module.mine
2014-07-03 09:32:05,785 [salt.loaded.int.module.mine
2014-07-03 09:33:05,749 [salt.loaded.int.module.mine
2014-07-03 09:33:05,874 [salt.loaded.int.module.mine
2014-07-03 09:34:05,845 [salt.loaded.int.module.mine
2014-07-03 09:34:05,969 [salt.loaded.int.module.mine
2014-07-03 09:35:05,937 [salt.loaded.int.module.mine
2014-07-03 09:35:06,068 [salt.loaded.int.module.mine
2014-07-03 09:36:05,017 [salt.loaded.int.module.mine
2014-07-03 09:36:05,141 [salt.loaded.int.module.mine
2014-07-03 09:37:05,113 [salt.loaded.int.module.mine
2014-07-03 09:37:05,238 [salt.loaded.int.module.mine
2014-07-03 09:38:05,208 [salt.loaded.int.module.mine
2014-07-03 09:38:05,336 [salt.loaded.int.module.mine
2014-07-03 09:39:05,304 [salt.loaded.int.module.mine
2014-07-03 09:39:05,428 [salt.loaded.int.module.mine
2014-07-03 09:40:05,687 [salt.loaded.int.module.mine
2014-07-03 09:40:05,810 [salt.loaded.int.module.mine
2014-07-03 09:41:05,781 [salt.loaded.int.module.mine
2014-07-03 09:41:05,908 [salt.loaded.int.module.mine

咱们也可以利用mine.send来发送数据。

代码如下	复制代码
[root@vm-10-154-252-82 ~/clusterops/templates]$salt '10.154.252.46' mine.send network.dig youku.com 10.154.252.46: True [root@vm-10-154-252-82 ~/clusterops/templates]$

我们又重新定义了mine的规则。

代码如下	复制代码
mine_functions: test.ping: [] cmd.run: - date;df

咱们定义了有时间特征的收集，用来判断下，他获取的数据是不是一分钟间隔，你就算mine.get也只是获取到他先前生成的数据，而不是实时的。

有些朋友还是再疑惑这些东西也可以用直接推送模块来实现，但是你看下面，我定义了sleep 10s，如果用模块去取值的话，一定要sleep 10秒之后，才能获取到数据。但这里master去get数据的时候，还是很即时的回来。当然取得数据是一分钟之前的。对一些场合这已经足够了。

上面说了，是什么场合？来个简单渲染haproxy配置。

代码如下

复制代码

/srv/pillar/top.sls:

base:

'G@roles:web':

    - web

/srv/pillar/web.sls:

mine_functions:

network.ip_addrs: [eth0]

/etc/salt/minion.d/mine.conf:

mine_interval: 5

/srv/salt/haproxy.sls:

haproxy_config:

file:

    - managed

    - name: /etc/haproxy/config

    - source: salt://haproxy_config

    - template: jinja

/srv/salt/haproxy_config:

<...file contents snipped...>

{% for server, addrs in salt['mine.get']('roles:web', 'network.ip_addrs', expr_form='grain').items() %}

server {{ server }} {{ addrs[0] }}:80 check

{% endfor %}

<...file contents snipped...>

根据monin客户端的一些特征来渲染配置，估计大家已经学会了用根据grains取渲染配置，但是grains的数据有些不及时，虽然也有办法让他及时。

我这里也只是阐述下mine和grains在通过jinja2渲染配置的场景。我自己看来，grains更适合很久很久才变化的。 mine适合变化比较大的。

大家show下saltstack grains的数据，几乎都是系统和硬件的信息。

代码如下

复制代码

[root@vm-10-154-252-82 ~/clusterops]$salt '10.154.252.46' grains.item productname
10.154.252.46:
productname: OpenStack Nova
[root@vm-10-154-252-82 ~/clusterops]$salt '10.154.252.46' grains.item lang
10.154.252.46:
lang: python erlang
[root@vm-10-154-252-82 ~/clusterops]$
[root@vm-10-154-252-82 ~/clusterops]$
[root@vm-10-154-252-82 ~/clusterops]$
[root@vm-10-154-252-82 ~/clusterops]$salt '10.154.252.46' sys.reload_modules
10.154.252.46:
True
[root@vm-10-154-252-82 ~/clusterops]$

用mine的话，咱们可以定义自己感兴趣的。可以根据现在minon使用的负载和内存情况，来分配不同的配置选项。。。。 pillar 和 mine我想大家应该能区分开来。

代码如下

复制代码

[root@vm-10-154-252-82 ~/clusterops]$time salt '10.154.252.46' mine.get '*' status.meminfo|more
10.154.252.46:
    ----------
    10.154.252.46:
        ----------
        Active:
            ----------
            unit:
                kB
            value:
                506876
        Active(anon):
            ----------
            unit:
                kB
            value:
                94456
        Active(file):
            ----------
            unit:
                kB
            value:
                412420
        AnonHugePages:
            ----------
            unit:
                kB
            value:
                20480
        AnonPages:
            ----------
            unit:
                kB
            value:
                94232
        Bounce:
            ----------

总结，一定要区分直接推送模块和mine的区别，还有grains和mine的区别。仁者见仁，智者见智。想怎么用，还是需要你自己掌控的。

nanomsg是一个实现了几种“可扩展协议”的高性能通信库;可扩展协议的任务是定义多个应用系统如何通信,从而组成一个大的分布式系统。本文我们来讲讲nanomsg的pubsub及survey

nanomsg实验——pubsub

发布订阅模式是很多消息中间件提供的常见功能。通过消息机制，能够将消息发布者和消息接收（消费）者
进行解耦。pubsub模式也是nanomsg直接支持的一直消息模型之一，因此通过pubsub模式实验，
同时也大致了解了下nanomsg的基础用法。

服务端

代码如下

复制代码

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <string.h>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>

void usage(const char *name)
{
    fprintf(stderr, "%s [ bind url]n", name);
}

int main(int argc, char **argv)
{
    if(argc != 2) {
        usage(argv[0]);
        exit(-1);
    }

    const char *url = argv[1];
    int sock = nn_socket(AF_SP, NN_PUB);
    if(sock < 0) {
        fprintf (stderr, "nn_socket failed: %sn", nn_strerror (errno));
        exit(-1);
    }

    if(nn_bind(sock, url) < 0) {
        fprintf(stderr, "nn_bind failed: %sn", nn_strerror(errno));
        exit(-1);
    }

    while(1) {
        time_t rawtime;
        struct tm * timeinfo;

        time (&rawtime);
        timeinfo = localtime (&rawtime);
        char *text = asctime (timeinfo);
        int textLen = strlen(text);
        text[textLen - 1] = '';

        printf ("SERVER: PUBLISHING DATE %sn", text);
        nn_send(sock, text, textLen, 0);
        sleep(1);
    }

    return 0;
}

nanomsg使用非常简单，只要直接include nanomsg/nn.h，即可使用基本API。使用内置的通信模式，
需要引入对应的头文件，如pubsub模式，引入nonomsg/pubsub.h即可。

pubsub server，需要首先通过nn_socket调用创建socket，这里模仿了POSIX接口，
函数返回一个文件描述符。因此直接通过判断返回值是否大于0，判断是否创建成功。注意第二个参数为协议，
在协议相关头文件中会定义对应的宏。然后所有操作都将基于这个文件描述符。
和berkeley sockets一样，server需要bind一个端口，nanomsg需要bind一个url。目前nanomsg支持的格式有：
* 进程内通信（inproc）：url格式为inproc://test
* 进程间同in想（ipc）：url格式为ipc:///tmp/test.ipc
* tcp通信：url格式为tcp://*:5555

github上源码貌似已经支持websocket了。

nanomsg的错误和UNIX相同，失败之后会设置errno，可以通过nn_strerror获取对应的错误文本。

bind完了之后，就可以通过nn_send函数向socket发送消息了。这个函数参数和berkeley sockets api接口类似。
这里直接获取当前时间，然后发出给所有订阅者。

客户端

代码如下

复制代码

#include <stdio.h>
#include <stdlib.h>

#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>

int main(int argc, char **argv)
{
    if(argc != 3) {
        fprintf(stderr, "usage: %s NAME BIND_URLn", argv[0]);
        exit(-1);
    }
    const char *name = argv[1];
    const char *url = argv[2];

    int sock = nn_socket (AF_SP, NN_SUB);
    if(sock < 0) {
        fprintf(stderr, "fail to create socket: %sn", nn_strerror(errno));
        exit(-1);
    }
    if(nn_setsockopt (sock, NN_SUB, NN_SUB_SUBSCRIBE, "", 0) < 0) {
        fprintf(stderr, "fail to set sorket opts: %sn", nn_strerror(errno));
        exit(-1);
    }

    if (nn_connect(sock, url) < 0) {
        fprintf(stderr, "fail to connect to %s : %sn", url, nn_strerror(errno));
        exit(-1);
    }

    while ( 1 ) {
        char *buf = NULL;
        int bytes = nn_recv (sock, &buf, NN_MSG, 0);
        printf ("CLIENT (%s): RECEIVED %sn", name, buf);
        nn_freemsg (buf);
    }

    nn_shutdown(sock, 0);

    return 0;
}

客户端初始化和服务端差不多，在连接服务端之前，需要通过nn_setsockopt将当前socket设置成消息订阅者。
然后通过nn_connect连接发布者，参数和服务端bind的差不多，也是一个socket、一个url。
这里的url要和服务端bind的url相同。之后就是一个死循环不停的接收发布者的消息。

测试

首先是编译，和普通c程序相同，只是增加链接nanomsg。

gcc -o pubserver pubserver.c -lnanomsg
gcc -o pubclient pubclient.c -lnanomsg

为了方便测试，写了一个简单的shell脚本：

代码如下

复制代码

#!/bin/bash

BASE="$( cd "$( dirname "$0" )" && pwd )"
PUB=$BASE/pubserver
SUB=$BASE/pubclient

URL="tcp://127.0.0.1:1234"

echo "start pubserver to bind tcp: $URL"

$PUB tcp://127.0.0.1:1234 &

echo "start to start pubclient"
for((i = 0; i < 10; i++))
    do
    echo "start client$i"
    $SUB client$i $URL &
    sleep 1
done

sleep 20
echo "kill all process and exit"

for pid in `jobs -p`
do
    echo "kill $pid"
    kill $pid
done

wait

脚本很简单，首先启动一个消息发布者，然后每秒启动一个消息接受者。等待20s之后，kill掉所有子进程。

脚本的输出：

代码如下

复制代码

start pubserver to bind tcp: tcp://127.0.0.1:1234
start to start pubclient
start client0
SERVER: PUBLISHING DATE Tue Feb 17 15:12:11 2015
start client1
SERVER: PUBLISHING DATE Tue Feb 17 15:12:12 2015
CLIENT (client0): RECEIVED Tue Feb 17 15:12:12 2015
CLIENT (client1): RECEIVED Tue Feb 17 15:12:12 2015
start client2
SERVER: PUBLISHING DATE Tue Feb 17 15:12:13 2015
CLIENT (client0): RECEIVED Tue Feb 17 15:12:13 2015
CLIENT (client1): RECEIVED Tue Feb 17 15:12:13 2015
CLIENT (client2): RECEIVED Tue Feb 17 15:12:13 2015
start client3
SERVER: PUBLISHING DATE Tue Feb 17 15:12:14 2015
CLIENT (client0): RECEIVED Tue Feb 17 15:12:14 2015
CLIENT (client1): RECEIVED Tue Feb 17 15:12:14 2015
CLIENT (client2): RECEIVED Tue Feb 17 15:12:14 2015
...
SERVER: PUBLISHING DATE Tue Feb 17 15:12:41 2015
CLIENT (client0): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client1): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client2): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client3): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client4): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client5): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client6): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client7): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client8): RECEIVED Tue Feb 17 15:12:41 2015
CLIENT (client9): RECEIVED Tue Feb 17 15:12:41 2015
kill all process and exit

可以看见每次启动一个新的订阅者，每个订阅者都能够收到发布者发布的当前时间。

nanomsg实验——survey

survey模式是由server发出询问，client针对请求回复响应的一种模式。这种模式在分布式系统中非常有用，
可以用来做服务发现、分布式事物等分布式询问。
客户端

客户端实现比较方便，除了基础调用（创建socket、连接url）之外，就是先接收服务端询问
（例子中比较简单，服务端询问是固定的，所以没有对内容进行检查）针对询问发送响应
（例子中是发送服务端当前时间）

代码如下

复制代码

#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <ctime>
#include <nanomsg/nn.h>
#include <nanomsg/survey.h>

using namespace std;

int main(int argc, const char **argv) {
    if(argc != 3) {
        fprintf(stderr, "usage: %s NAME URLn", argv[0]);
        exit(-1);
    }
    const char *name = argv[1];
    const char *url = argv[2];

    int sock = nn_socket(AF_SP, NN_RESPONDENT);
    if(sock < 0){
        fprintf(stderr, "nn_socket fail: %sn", nn_strerror(errno));
        exit(-1);
    }
    if(nn_connect(sock, url) < 0) {
        fprintf(stderr, "nn_connect fail: %sn", nn_strerror(errno));
        exit(-1);
    }

    while(1){
        char *buf = NULL;
        int bytes = nn_recv (sock, &buf, NN_MSG, 0);

        if(bytes > 0) {
            printf ("CLIENT (%s): RECEIVED "%s" SURVEY REQUESTn", name, buf);
            nn_freemsg (buf);

            char sendBuffer[128];
            time_t rawtime;
            struct tm * timeinfo;

            time (&rawtime);
            timeinfo = localtime (&rawtime);
            char *timeText = asctime (timeinfo);
            int textLen = strlen(timeText);
            timeText[textLen - 1] = '';
            sprintf(sendBuffer, "[ %s ] %s", name, timeText);
            int sendSize = strlen(sendBuffer) + 1;
            int actualSendSize = nn_send(sock, sendBuffer, sendSize, 0);

            if(actualSendSize != sendSize) {
                fprintf(stderr, "nn_send fail, expect length %d, actual length %dn", sendSize, actualSendSize);
                continue;
            }
        }
    }

    nn_shutdown(sock, 0);

    return 0;
}

这里收到消息后，就简单的打印，然后将响应数据写会给服务端。

服务端

服务端有个问题，之前搜索了几个例子都不太正常。经过尝试和简单查看代码之后发现，通过nanomsg基础api，
无法获取当前有多少客户端。但是，如果当前所有连接的客户端的响应都已经收到，再次调用nn_recv之后，
会直接返回-1，表示读取失败，同时errno（通过errno函数获取）被设置为EFSM，表示当前状态机状态不正确。

代码如下

复制代码

#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/survey.h>

using namespace std;

const char *SURVEY_TYPE = "DATE";

int main(int argc, char** argv)
{

    if ( argc != 2 ) {
        fprintf(stderr, "usage: %s URLn", argv[0]);
        exit(-1);
    }
    const char *url = argv[1];
    int sock = nn_socket(AF_SP, NN_SURVEYOR);
    if(sock < 0) {
        fprintf (stderr, "nn_socket failed: %sn", nn_strerror (errno));
        exit(-1);
    }

    if(nn_bind(sock, url) < 0) {
        fprintf(stderr, "nn_bind fail: %sn", nn_strerror(errno));
        exit(-1);
    }

    while(1) {
        int sendSize = strlen(SURVEY_TYPE) + 1;
        int actualSendSize;
        printf ("SERVER: SENDING DATE SURVEY REQUESTn");
        if ((actualSendSize = nn_send(sock, SURVEY_TYPE, sendSize, 0)) != sendSize) {
            fprintf(stderr, "nn_send fail, expect length %d, actual length %dn", sendSize, actualSendSize);
            continue;
        }

        int count = 0;
        while(1) {
            char *buf = NULL;
            int bytes = nn_recv (sock, &buf, NN_MSG, 0);
            if (bytes < 0 && nn_errno() == ETIMEDOUT) break;
            if (bytes >= 0) {
                printf ("SERVER: RECEIVED "%s" SURVEY RESPONSEn", buf);
                ++count;
                nn_freemsg (buf);
            } else {
                fprintf(stderr, "nn_recv fail: %sn", nn_strerror(errno));
                break;
            }
        }
        printf("SERVER: current receive %d survey response.n", count);
        sleep(1);
    }

    nn_shutdown(sock, 0);

    return 0;

}

这里用了两个死循环，外层循环不停尝试向客户端发起询问。完成询问后，通过另外一个死循环读取所有的客户端响应，
当读取失败时退出循环。

之前找到的源码是直接判断错误是否ETIMEDOUT，经过打印会发现每次都没有超时，而是状态机错误：

代码如下	复制代码
/* If no survey is going on return EFSM error. */ if (nn_slow (!nn_surveyor_inprogress (surveyor))) return -EFSM;

测试

测试和前文差不多，先启动一个server，然后再一个个启动client：

代码如下

复制代码

#!/bin/bash

BASE="$( cd "$( dirname "$0" )" && pwd )"
SERVER=$BASE/surveyserver
CLIENT=$BASE/surveyclient

URL="tcp://127.0.0.1:1234"

echo "start surveyserver to bind tcp: $URL"
$SERVER tcp://127.0.0.1:1234 &

echo "start to start surveyclient"
for((i = 0; i < 10; i++))
do
    echo "start client$i"
    $CLIENT client$i $URL &
    sleep 1
done

sleep 20
echo "kill all process and exit"

for pid in `jobs -p`
do
    echo "kill $pid"
    kill $pid
done

wait

输出为：

代码如下

复制代码

start surveyserver to bind tcp: tcp://127.0.0.1:1234
start to start surveyclient
start client0
SERVER: SENDING DATE SURVEY REQUEST
start client1
nn_recv fail: Operation cannot be performed in this state
SERVER: current receive 0 survey response.
start client2
SERVER: SENDING DATE SURVEY REQUEST
CLIENT (client0): RECEIVED "DATE" SURVEY REQUEST
SERVER: RECEIVED "[ client0 ] Tue Feb 17 23:32:43 2015" SURVEY RESPONSE
CLIENT (client1): RECEIVED "DATE" SURVEY REQUEST
SERVER: RECEIVED "[ client1 ] Tue Feb 17 23:32:43 2015" SURVEY RESPONSE
nn_recv fail: Operation cannot be performed in this state
SERVER: current receive 2 survey response.
start client3
SERVER: SENDING DATE SURVEY REQUEST
CLIENT (client0): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client1): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client2): RECEIVED "DATE" SURVEY REQUEST
...
SERVER: SENDING DATE SURVEY REQUEST
CLIENT (client0): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client1): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client2): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client3): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client4): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client5): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client6): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client7): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client9): RECEIVED "DATE" SURVEY REQUEST
CLIENT (client8): RECEIVED "DATE" SURVEY REQUEST
SERVER: RECEIVED "[ client0 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client1 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client2 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client3 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client4 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client5 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client6 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client7 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client9 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
SERVER: RECEIVED "[ client8 ] Tue Feb 17 23:33:09 2015" SURVEY RESPONSE
nn_recv fail: Operation cannot be performed in this state
SERVER: current receive 10 survey response.

从输出可以看见，每次最后一个接收完成之后，都会有一个“Operation cannot be performed in this state”
错误，也就是EFSM错误。

[!--infotagslink--]

上一篇: TCP怎么建立的 TCP关闭方法是什么

下一篇: php怎么打开html页面？

js基础知识（公有方法、私有方法、特权方法）
本文涉及的主题虽然很基础，在许多人看来属于小伎俩，但在JavaScript基础知识中属于一个综合性的话题。这里会涉及到对象属性的封装、原型、构造函数、闭包以及立即执行表达式等知识。公有方法公有方法就是能被外部访问...2015-11-08
Jquery 获取指定标签的对象及属性的设置与移除
1、先讲讲JQuery的概念，JQuery首先是由一个 America 的叫什么 John Resig的人创建的，后来又很多的JS高手也加入了这个团队。其实 JQuery是一个JavaScript的类库，这个类库集合了很多功能方法，利用类库你可以用简单的一些代...2014-05-31
护卫神主机管理系统使用说明(MSSQL管理)
护卫神·主机管理系统该版本支持在Windows Server 200320082012，含32位和64位，直接开设配置WEB站、FTP站，以及SQL Server和MySQL，是您开设和管理虚拟主机的绝好帮手。但是对于新用户可能在使用上有一些困难，因此请仔细阅读如下说明文档...2016-01-27
C# 如何设置label（标签）控件的背景颜色为透明
这篇文章主要介绍了C# 如何设置label（标签）控件的背景颜色为透明，帮助大家更好的理解和使用c#，感兴趣的朋友可以了解下...2020-12-08
matplotlib之pyplot模块坐标轴标签设置使用(xlabel()、ylabel())
这篇文章主要介绍了matplotlib之pyplot模块坐标轴标签设置使用(xlabel()、ylabel()),文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-02-23
JS创建Tag标签的方法详解
这篇文章主要介绍了JS创建Tag标签的方法,结合具体实例形式分析了javascript动态操作页面HTML元素实现tag标签功能的步骤与相关操作技巧,需要的朋友可以参考下...2017-06-15
C#删除UL LI中指定标签里文字的方法
这篇文章主要介绍了C#删除UL LI中指定标签里文字的方法,涉及C#针对页面HTML元素进行正则匹配与替换的相关操作技巧,需要的朋友可以参考下...2020-06-25
帝国CMS用灵动标签调用实现各种幻灯（焦点图）效果
用灵动标签(e:loop)可以实现各种幻灯效果，本节讲解制作幻灯的基本方法。如本站JS焦点图频道里的大部分幻灯图片效果都可以用灵动标签调用的。 ...2015-12-30
深入C# 内存管理以及优化的方法详解
本篇文章是对C#中内存管理以及优化的方法进行了详细的分析介绍，需要的朋友参考下...2020-06-25
帝国CMS灵动标签调用新闻正文内容第一张图片的方法
有时候我们在建站的过程当中需要调用内容页中正文的第一张图片（并不是缩略图），这样就会无从下手，但其实对不懂开发的站长是太难了，往往是会用标题图片来取代，下面分享网友们贡献出...2015-12-30
探讨JavaScript标签位置的存放与功能有无关系
在网页中，我们可以将JavaScript代码放在html文件中任何位置，但一般放在head或body标签里面。一般来说，<script>元素放在哪里与其的功能作用是紧密相关的，通过本文我们一起学习下...2016-01-18
详解swift中xcworkspace多项目管理
给大家详细讲解了IOS开发中swift语言xcworkspace多项目管理的方法和介绍，一起参考一下。...2020-06-30
jquery实现标签支持图文排列带上下箭头按钮的选项卡
带上下箭头jquery垂直tab选项卡切换标签,技持左侧列表上下滚动，滚动到底部带信息提示。复制代码代码如下: <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml...2015-03-15
PHP正则表达式过滤html标签属性(DEMO)
这篇文章主要介绍了PHP正则表达式过滤html标签属性的相关内容，实用性非常，感兴趣的朋友参考下吧...2016-05-06
C#使用正则表达式过滤html标签
最近在开发一个项目，其中有需求要求我们把一段html转换为一般文本返回，使用正则表达式是明智的选择，下面小编给介绍下C#使用正则表达式过滤html标签，需要的朋友参考下...2020-06-25
C#知识整理
本文主要介绍了C#的相关知识。具有很好的参考价值，下面跟着小编一起来看下吧...2020-06-25
基于mybatis中<include>标签的作用说明
这篇文章主要介绍了基于mybatis中<include>标签的作用说明，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-20
js实现车辆管理系统
这篇文章主要为大家详细介绍了js实现车辆管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2020-08-26
thinkphp自定义权限管理之名称判断方法
下面小编就为大家带来一篇thinkphp自定义权限管理之名称判断方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧...2017-04-03
C++学生信息管理系统
这篇文章主要为大家想详细介绍了C++学生信息管理系统的实现代码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2020-04-25

Git标签管理知识

相关文章

阁下可能感兴趣的内容

推荐阅读