|
@@ -148,38 +148,38 @@ func receive(c net.Conn) { //
|
|
var stru map[string]interface{}
|
|
var stru map[string]interface{}
|
|
err_unmarshal := json.Unmarshal(mid, &stru)
|
|
err_unmarshal := json.Unmarshal(mid, &stru)
|
|
if err_unmarshal != nil {
|
|
if err_unmarshal != nil {
|
|
- log.Println("json解析出错了,err_unmarshal=", err_unmarshal, "len(mid=)", len(mid), "len(a)=", len(a))
|
|
|
|
|
|
+ log.Println("json err,err_unmarshal=", err_unmarshal, "len(mid=)", len(mid), "len(a)=", len(a))
|
|
}
|
|
}
|
|
var structure Rec
|
|
var structure Rec
|
|
|
|
|
|
//1,time
|
|
//1,time
|
|
times, err_time := redis.Strings(stru["Megred_Timestamp"], nil)
|
|
times, err_time := redis.Strings(stru["Megred_Timestamp"], nil)
|
|
if err_time != nil {
|
|
if err_time != nil {
|
|
- log.Println("err_time出错了", err_time, "打印字符串a=", a)
|
|
|
|
|
|
+ log.Println("err_time", err_time, "a=", a)
|
|
}
|
|
}
|
|
structure.Megred_Timestamp = times
|
|
structure.Megred_Timestamp = times
|
|
//2,msg
|
|
//2,msg
|
|
msgs, err_msgs := redis.Strings(stru["Megred_Hashtags"], nil)
|
|
msgs, err_msgs := redis.Strings(stru["Megred_Hashtags"], nil)
|
|
if err_msgs != nil {
|
|
if err_msgs != nil {
|
|
- log.Println("err_msgs出错了", err_msgs, "打印字符串a", a)
|
|
|
|
|
|
+ log.Println("err_msgs", err_msgs, "符串a", a)
|
|
}
|
|
}
|
|
structure.Merged_Hashtags = msgs
|
|
structure.Merged_Hashtags = msgs
|
|
//3,uid
|
|
//3,uid
|
|
uid, err_uid := redis.String(stru["Megred_User_Id"], nil)
|
|
uid, err_uid := redis.String(stru["Megred_User_Id"], nil)
|
|
if err_uid != nil {
|
|
if err_uid != nil {
|
|
- log.Println("err_uid出错了", err_uid, "打印字符串a", a)
|
|
|
|
|
|
+ log.Println("err_uid", err_uid, "a", a)
|
|
}
|
|
}
|
|
structure.Megred_User_Id = uid
|
|
structure.Megred_User_Id = uid
|
|
//4,ip
|
|
//4,ip
|
|
ip, err_ip := redis.String(stru["Megred_Ip"], nil)
|
|
ip, err_ip := redis.String(stru["Megred_Ip"], nil)
|
|
if err_ip != nil {
|
|
if err_ip != nil {
|
|
- log.Println("err_ip出错了", err_ip, "打印字符串a", a)
|
|
|
|
|
|
+ log.Println("err_ip", err_ip, "a", a)
|
|
}
|
|
}
|
|
structure.Megred_Ip = ip
|
|
structure.Megred_Ip = ip
|
|
//5.cover
|
|
//5.cover
|
|
cov, err_cover := redis.String(stru["Cover_Msg"], nil)
|
|
cov, err_cover := redis.String(stru["Cover_Msg"], nil)
|
|
if err_cover != nil {
|
|
if err_cover != nil {
|
|
- log.Println("err_cover出错了", err_cover)
|
|
|
|
|
|
+ log.Println("err_cover", err_cover)
|
|
break
|
|
break
|
|
}
|
|
}
|
|
structure.Cover_Msg = cov
|
|
structure.Cover_Msg = cov
|
|
@@ -552,7 +552,7 @@ func arrivalToLearn1() bool {
|
|
//a1,conn the recipient
|
|
//a1,conn the recipient
|
|
httpConn_receiver, err2 := net.Dial("tcp", "192.168.32.144:20001") //recipients address
|
|
httpConn_receiver, err2 := net.Dial("tcp", "192.168.32.144:20001") //recipients address
|
|
if err2 != nil {
|
|
if err2 != nil {
|
|
- log.Println("连接receiver出错,dial 192.168.32.144:20001 failed", err2)
|
|
|
|
|
|
+ log.Println("receiver,dial 192.168.32.144:20001 failed", err2)
|
|
}
|
|
}
|
|
|
|
|
|
//a2,init sendDBToReceiver' channel to store uid in batch list
|
|
//a2,init sendDBToReceiver' channel to store uid in batch list
|
|
@@ -686,7 +686,7 @@ func learning_function(flag bool) {
|
|
2,do clustering, store result ingroupresult
|
|
2,do clustering, store result ingroupresult
|
|
3,create anonymity set and record the users in each set
|
|
3,create anonymity set and record the users in each set
|
|
*/
|
|
*/
|
|
- //1,执行output.sh;
|
|
|
|
|
|
+ //1,output.sh;
|
|
// /home/it/middle_data/rediskey.txt val value.csv
|
|
// /home/it/middle_data/rediskey.txt val value.csv
|
|
_, err := exec.Command("/bin/bash", "/home/it/middle_data/output.sh").CombinedOutput()
|
|
_, err := exec.Command("/bin/bash", "/home/it/middle_data/output.sh").CombinedOutput()
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -787,12 +787,12 @@ func learning_function(flag bool) {
|
|
sum := 0
|
|
sum := 0
|
|
for i := 0; i < k_val; i++ {
|
|
for i := 0; i < k_val; i++ {
|
|
gg := number_group_hashmap[i+k_val*groupSet_Number]
|
|
gg := number_group_hashmap[i+k_val*groupSet_Number]
|
|
- log.Println("id=", gg.Group_Id, "i+ k_val*groupSet_Number=", i+k_val*groupSet_Number, "的group,其size=", gg.Group_Size)
|
|
|
|
|
|
+ log.Println("id=", gg.Group_Id, "i+ k_val*groupSet_Number=", i+k_val*groupSet_Number, "group,size=", gg.Group_Size)
|
|
sum = sum + gg.Group_Size
|
|
sum = sum + gg.Group_Size
|
|
}
|
|
}
|
|
log.Println("groupSet_Number=", groupSet_Number)
|
|
log.Println("groupSet_Number=", groupSet_Number)
|
|
groupSet_Number++
|
|
groupSet_Number++
|
|
- log.Println("更新groupSet_Number之后,groupSet_Number=", groupSet_Number)
|
|
|
|
|
|
+ log.Println("update groupSet_Number,groupSet_Number=", groupSet_Number)
|
|
return
|
|
return
|
|
} else {
|
|
} else {
|
|
return
|
|
return
|
|
@@ -974,7 +974,7 @@ func each_group_process(g *Group) {
|
|
} else {
|
|
} else {
|
|
log.Println("group_id=", g.Group_Id, "threshold number=", number, "active user number", len(middle_active_list))
|
|
log.Println("group_id=", g.Group_Id, "threshold number=", number, "active user number", len(middle_active_list))
|
|
}
|
|
}
|
|
- log.Println("group_id=", g.Group_Id, "is", g.Group_active, "active user number=", len(middle_active_list), "inactive user number=", len(middle_inactive_list), "group_size=", g.Group_Size, "Group_User_List长度=", len(g.Group_User_List))
|
|
|
|
|
|
+ log.Println("group_id=", g.Group_Id, "is", g.Group_active, "active user number=", len(middle_active_list), "inactive user number=", len(middle_inactive_list), "group_size=", g.Group_Size, "Group_User_List length=", len(g.Group_User_List))
|
|
}
|
|
}
|
|
|
|
|
|
var db12_send_to_receiver_wg sync.WaitGroup
|
|
var db12_send_to_receiver_wg sync.WaitGroup
|
|
@@ -1242,7 +1242,7 @@ func main() {
|
|
ave_groupsize_double[i] = math.Round((float64(v) / float64(k_val-1)))
|
|
ave_groupsize_double[i] = math.Round((float64(v) / float64(k_val-1)))
|
|
}
|
|
}
|
|
log.Println("average group size=", ave_groupsize_double)
|
|
log.Println("average group size=", ave_groupsize_double)
|
|
- log.Println("group size之和=", ave_groupsize)
|
|
|
|
|
|
+ log.Println("sum of group size=", ave_groupsize)
|
|
log.Println("delay_limitation=", delay_limitation, "outlier_delay_limitation", outlier_delay_limitation, "group_Threshold_global", group_Threshold_global, "Group_sleep_times_threshold", Group_sleep_times_threshold)
|
|
log.Println("delay_limitation=", delay_limitation, "outlier_delay_limitation", outlier_delay_limitation, "group_Threshold_global", group_Threshold_global, "Group_sleep_times_threshold", Group_sleep_times_threshold)
|
|
|
|
|
|
}
|
|
}
|