upload

.idea/.gitignore

@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
+# Editor-based HTTP Client requests
+/httpRequests/

.idea/Moscato_Client.iml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/Moscato_Client.iml" filepath="$PROJECT_DIR$/.idea/Moscato_Client.iml" />
+    </modules>
+  </component>
+</project>

.idea/vcs.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/apex/log" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/benbjohnson/clock" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/davecgh/go-spew" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/go-kit/log" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/go-logfmt/logfmt" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/go-stack/stack" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/mattn/go-colorable" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/mattn/go-isatty" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/pkg/errors" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/pmezard/go-difflib" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/rs/zerolog" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/sirupsen/logrus" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/github.com/stretchr/testify" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/go.uber.org/atomic" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/go.uber.org/goleak" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/go.uber.org/multierr" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/go.uber.org/zap" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/golang.org/x/sys" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/golang.org/x/term" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/google.golang.org/grpc" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/gopkg.in/inconshreveable/log15.v2" vcs="Git" />
+    <mapping directory="$PROJECT_DIR$/src/gopkg.in/yaml.v3" vcs="Git" />
+  </component>
+</project>

src/example.json

@@ -0,0 +1,36 @@
+{
+  "||": [
+    {
+      "&&": [
+        {
+          "==": {
+            "attribute": "job",
+            "value": "doctor"
+          }
+        },
+        {
+          ">=": {
+            "attribute": "age",
+            "value": 40
+          }
+        }
+      ]
+    },
+    {
+      "&&" : [
+        {
+          "==": {
+          "attribute": "job",
+          "value": "programmer"
+          }
+        },
+        {
+          "<": {
+            "atrribute": "age",
+            "value": 30
+          }
+        }
+      ]
+    }
+  ]
+}

src/getIpaddr.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"fmt"
+	"net"
+)
+
+func getCurrentIPAddr() string {
+	addrs, err := net.InterfaceAddrs()
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	var currentIP string
+
+	for _, address := range addrs {
+
+		// check the address type and if it is not a loopback the display it
+		// = GET LOCAL IP ADDRESS
+		if ipnet, ok := address.(*net.IPNet); ok && !ipnet.IP.IsLoopback() {
+			if ipnet.IP.To4() != nil {
+				//fmt.Println("Current IP address : ", ipnet.IP.String())
+				currentIP = ipnet.IP.String()
+			}
+		}
+	}
+	return currentIP
+}

src/github.com/apex/log

@@ -0,0 +1 @@
+Subproject commit 8da83152b5d6177b4bfe3d12810a5afd25355170

src/github.com/benbjohnson/clock

@@ -0,0 +1 @@
+Subproject commit 68df829297d4f02d5997a02f8c0e8d4b12f0b2a3

src/github.com/davecgh/go-spew

@@ -0,0 +1 @@
+Subproject commit d8f796af33cc11cb798c1aaeb27a4ebc5099927d

src/github.com/fatih/go.mod

@@ -0,0 +1,8 @@
+module github.com/fatih/color
+
+go 1.13
+
+require (
+	github.com/mattn/go-colorable v0.1.8
+	github.com/mattn/go-isatty v0.0.13
+)

src/github.com/fatih/go.sum

@@ -0,0 +1,8 @@
+github.com/mattn/go-colorable v0.1.8 h1:c1ghPdyEDarC70ftn0y+A/Ee++9zz8ljHG1b13eJ0s8=
+github.com/mattn/go-colorable v0.1.8/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
+github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
+github.com/mattn/go-isatty v0.0.13 h1:qdl+GuBjcsKKDco5BsxPJlId98mSWNKqYA+Co0SC1yA=
+github.com/mattn/go-isatty v0.0.13/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
+golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae h1:/WDfKMnPU+m5M4xB+6x4kaepxRw6jWvR5iDRdvjHgy8=
+golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

src/github.com/go-kit/log

@@ -0,0 +1 @@
+Subproject commit 0b69c7049332e99c25d5fd0f4d08317cfe45e7d8

src/github.com/go-logfmt/logfmt

@@ -0,0 +1 @@
+Subproject commit 99455b83edb21b32a1f1c0a32f5001b77487b721

src/github.com/go-stack/stack

@@ -0,0 +1 @@
+Subproject commit 93c7c7e3550c72bc91dead1452a0020142e2a902

src/github.com/mattn/go-colorable

@@ -0,0 +1 @@
+Subproject commit 11a925cff3d38c293ddc8c05a16b504e3e2c63be

src/github.com/mattn/go-isatty

@@ -0,0 +1 @@
+Subproject commit 13e91bf4058fb93d5629deb7b2e3763ec8f4fdf8

src/github.com/pkg/errors

@@ -0,0 +1 @@
+Subproject commit 5dd12d0cfe7f152f80558d591504ce685299311e

src/github.com/pmezard/go-difflib

@@ -0,0 +1 @@
+Subproject commit 5d4384ee4fb2527b0a1256a821ebfc92f91efefc

src/github.com/rs/zerolog

@@ -0,0 +1 @@
+Subproject commit 3543e9d94bc5ed088dd2d9ad1d19c7ccd0fa65f5

src/github.com/sirupsen/logrus

@@ -0,0 +1 @@
+Subproject commit f8bf7650dccb756cea26edaf9217aab85500fe07

src/github.com/stretchr/testify

@@ -0,0 +1 @@
+Subproject commit 9acc22213e5fbec050904b9886c6df042188cad5

src/go.uber.org/atomic

@@ -0,0 +1 @@
+Subproject commit 78a3b8ec6cb2e156b91140c7d53b16e12b7b3f91

src/go.uber.org/goleak

@@ -0,0 +1 @@
+Subproject commit 3465299153df9a4883eb828ae8898fe06724ba39

src/go.uber.org/multierr

@@ -0,0 +1 @@
+Subproject commit 39ca40c628bce6779c9725af600b737220b87602

src/go.uber.org/zap

@@ -0,0 +1 @@
+Subproject commit a55bdc32f526699c3b4cc51a2cc97e944d02fbbf

src/golang.org/x/sys

@@ -0,0 +1 @@
+Subproject commit 3b1fc93fc15c645820aa4a7d912e824f459ea1e3

src/golang.org/x/term

@@ -0,0 +1 @@
+Subproject commit 97ca0e3821bf3a3cf6ea2441ece139e524802385

src/google.golang.org/grpc

@@ -0,0 +1 @@
+Subproject commit f94594d587d5442778b970bccc478f347b51810f

src/gopkg.in/inconshreveable/log15.v2

@@ -0,0 +1 @@
+Subproject commit 5555550548196f43bf6dda2648158a72c416f9e7

src/gopkg.in/yaml.v3

@@ -0,0 +1 @@
+Subproject commit f6f7691b1fdeb513f56608cd2c32c51f8194bf51

src/logConfig.go

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
+)
+
+func MyEncoderConfig() zapcore.EncoderConfig {
+	return zapcore.EncoderConfig{
+		// Keys can be anything except the empty string.
+		TimeKey:  "T",
+		LevelKey: "L",
+		NameKey:  "N",
+		//CallerKey:      "C",
+		FunctionKey:    zapcore.OmitKey,
+		MessageKey:     "M",
+		//StacktraceKey:  "S",
+		LineEnding:     zapcore.DefaultLineEnding,
+		EncodeLevel:    zapcore.CapitalColorLevelEncoder,
+		EncodeTime:     zapcore.ISO8601TimeEncoder,
+		EncodeDuration: zapcore.StringDurationEncoder,
+		EncodeCaller:   zapcore.ShortCallerEncoder,
+	}
+}
+
+func NewMyLogger() *zap.Logger {
+	cfg := zap.Config{
+		Level:            zap.NewAtomicLevelAt(zap.DebugLevel),
+		Development:      true,
+		Encoding:         "console",
+		EncoderConfig:    MyEncoderConfig(),
+		OutputPaths:      []string{"stdout", "./test.log"},
+		ErrorOutputPaths: []string{"stderr"},
+	}
+	logger, err := cfg.Build()
+	if err != nil {
+		panic(err)
+	}
+	return logger
+}

src/main.go

@@ -0,0 +1,617 @@
+package main
+
+// TODO: 등록확인 되기 전에는 PM,SM 전송 불가하게 만들 것, 실행파일로 만든 후, AWS 이용해서 여러개 마이크로서비스 상태에서 테스트 해볼것
+
+import (
+	"bufio"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"log"
+	"math/rand"
+	"net"
+	"net/rpc"
+	"os"
+	"os/signal"
+	"strconv"
+	"strings"
+	"syscall"
+	"time"
+	"unicode"
+)
+
+const (
+	KGM = 1 + iota
+	KSM
+	PM
+	SM
+	RM
+	WM
+)
+
+type Message struct {
+	From    string //ip 주소
+	Version string
+	Time    string
+	Kind    int //종류
+}
+
+type MsgUnit interface {
+	// ConvertToJson - send 전 json 형식으로 바꾸는 함수
+	ConvertToJson() ([]byte, error)
+	// CheckType - Message 의 타입을 알려줌
+	CheckType() int
+}
+
+type RegisterMsg struct {
+	Message
+	PrivateKey int64
+}
+
+type SubscriptionMsg struct {
+	Message
+	Topic    []int64  //대주제
+	Value    []int64  //피연산자
+	Operator []string //연산자
+	IsAlpha  bool     //value가 숫자인지 문자열인지
+}
+
+type PublishMsg struct {
+	Message
+	Topic   []int64 //대주제
+	Value   []int64 //Topic 의 세부적인 내용
+	Content []int64 // 내용
+}
+
+type WithdrawMsg struct {
+	Message
+}
+
+type Receiver struct {
+	thisNodeAddr string
+	microService MicroService
+}
+
+type MicroService struct {
+	ClientAddr string
+	PrivateKey int64
+	ShareKey   int64
+	// 메세지 미들웨어에 연결되어 있는가
+	IsConnected chan bool
+	MMAddress   string
+}
+
+func (receiver Receiver) Receive(args Args, reply *Reply) error {
+	switch args.Kind {
+
+	case KSM:
+		//var msg KeyShareMsg
+		//err := json.Unmarshal(args.JsonMsg, &msg)
+		//if err != nil {
+		//	return err
+		//}
+		//go func() {
+		//	_, err := receiver.moscato.Receive(msg)
+		//	if err != nil {
+		//
+		//	}
+		//}()
+		//reply.CompleteLog = "received completely"
+	case PM:
+		var msg PublishMsg
+		err := json.Unmarshal(args.JsonMsg, &msg)
+		if err != nil {
+			return err
+		}
+		go func() {
+			receiver.microService.Receive(msg)
+		}()
+		reply.CompleteLog = "[" + receiver.thisNodeAddr + "] : pubMsg received"
+		//var msg PublishMsg
+		//err := json.Unmarshal(args.JsonMsg, &msg)
+		//if err != nil {
+		//	return err
+		//}
+		//
+		//go func() {
+		//	_, err := receiver.moscato.Receive(msg)
+		//	if err != nil {
+		//
+		//	}
+		//}()
+		//reply.CompleteLog = "PM received completely"
+	case SM:
+		//var msg SubscriptionMsg
+		//err := json.Unmarshal(args.JsonMsg, &msg)
+		//if err != nil {
+		//	return err
+		//}
+		//go func() {
+		//	_, err := receiver.moscato.Receive(msg)
+		//	if err != nil {
+		//
+		//	}
+		//}()
+		//reply.CompleteLog = "received completely"
+	case RM:
+		var msg RegisterMsg
+		err := json.Unmarshal(args.JsonMsg, &msg)
+		if err != nil {
+			return err
+		}
+		go func() {
+			receiver.microService.Receive(msg)
+		}()
+		reply.CompleteLog = "[" + receiver.thisNodeAddr + "] : ackRM received"
+	case WM:
+		//var msg WithdrawMsg
+		//err := json.Unmarshal(args.JsonMsg, &msg)
+		//if err != nil {
+		//	return err
+		//}
+		//go func() {
+		//	_, err := receiver.moscato.Receive(msg)
+		//	if err != nil {
+		//
+		//	}
+		//}()
+		//reply.CompleteLog = "received completely"
+	default:
+		return errors.New("message type Error: Not registered message type")
+	}
+	//reply.CompleteLog = "received completely"
+	return nil
+}
+
+func (microService MicroService) Receive(msg MsgUnit) {
+	logger := NewMyLogger()
+	logger.Sync()
+
+	var msg_type = msg.CheckType()
+	//메세지 타입에 따라 다르게 처리
+	switch msg_type {
+
+	case KSM: //Key share msg
+
+	case PM: //Publish msg
+		//PM print
+		fmt.Println("----- received PM ------")
+		DecryptionMsg(msg.(PublishMsg), microService.ShareKey, microService.PrivateKey)
+		fmt.Println("------------------------")
+
+	case SM: //Subscription msg
+
+	case RM: //Register msg
+
+		microService.IsConnected <- true
+		logger.Info("MM Registered this node Complete!")
+
+	case WM: //Withdraw msg
+		//moscato.MicroServiceManager.RemoveMicroservice(msg.(*WithdrawMsg).From)
+
+	default:
+		errors.New("message type Error: Not registered message type")
+	}
+
+	return
+}
+
+func (msg SubscriptionMsg) ConvertToJson() ([]byte, error) {
+	js := msg
+	jsonBytes, err := json.Marshal(js)
+	return jsonBytes, err
+}
+
+func (msg PublishMsg) ConvertToJson() ([]byte, error) {
+	js := msg
+	jsonBytes, err := json.Marshal(js)
+	return jsonBytes, err
+}
+
+func (msg RegisterMsg) ConvertToJson() ([]byte, error) {
+	js := msg
+	jsonBytes, err := json.Marshal(js)
+	return jsonBytes, err
+}
+
+func (msg WithdrawMsg) ConvertToJson() ([]byte, error) {
+	js := msg
+	jsonBytes, err := json.Marshal(js)
+	return jsonBytes, err
+}
+
+func (msg Message) CheckType() int {
+	return msg.Kind
+}
+
+func CreatePubMsg(msg Message, topic string, value string, content string) PublishMsg {
+	//toPubMsg := new(PublishMsg)
+	//toPubMsg.Message = msg
+
+	intArr := []rune(topic)
+	//fmt.Print("Topic length ")
+	//fmt.Println(len(intArr))
+	//fmt.Println(len(toPubMsg.Topic))
+	var topicInt []int64
+	for index := 0; index < len(intArr); index++ {
+		//toPubMsg.Topic = append(toPubMsg.Topic, int64(intArr[index]))
+		topicInt = append(topicInt, int64(intArr[index]))
+	}
+	//fmt.Println(len(toPubMsg.Topic))
+
+	intArr = []rune(value)
+	var valueInt []int64
+	strInt64, _ := strconv.ParseInt(value, 10, 64)
+	if unicode.IsDigit(intArr[0]) {
+		valueInt = append(valueInt, strInt64)
+	} else {
+		for index := 0; index < len(intArr); index++ {
+			//toPubMsg.Value = append(toPubMsg.Value, int64(intArr[index]))
+			valueInt = append(valueInt, int64(intArr[index]))
+		}
+	}
+
+	intArr = []rune(content)
+	var contentInt []int64
+	for index := 0; index < len(intArr); index++ {
+		//toPubMsg.content = append(toPubMsg.content, int64(intArr[index]))
+		contentInt = append(contentInt, int64(intArr[index]))
+	}
+
+	return PublishMsg{msg, topicInt, valueInt, contentInt}
+}
+
+func CreateSubMsg(msg Message, topic string, value string, operator string, isAlpha bool) SubscriptionMsg {
+	//toPubMsg := new(PublishMsg)
+	//toPubMsg.Message = msg
+
+	intArr := []rune(topic)
+	//fmt.Print("Topic length ")
+	//fmt.Println(len(intArr))
+	//fmt.Println(len(toPubMsg.Topic))
+	var topicInt []int64
+	for index := 0; index < len(intArr); index++ {
+		//toPubMsg.Topic = append(toPubMsg.Topic, int64(intArr[index]))
+		topicInt = append(topicInt, int64(intArr[index]))
+	}
+	//fmt.Println(len(toPubMsg.Topic))
+	var valueInt []int64
+	if isAlpha {
+		intArr = []rune(value)
+
+		for index := 0; index < len(intArr); index++ {
+			//toPubMsg.Value = append(toPubMsg.Value, int64(intArr[index]))
+			valueInt = append(valueInt, int64(intArr[index]))
+		}
+	} else {
+		stringSlice := strings.Split(value, " ")
+		for index := 0; index < len(stringSlice); index++ {
+			strInt64, _ := strconv.ParseInt(stringSlice[index], 10, 64)
+			valueInt = append(valueInt, strInt64)
+		}
+	}
+	var operatorSlice []string
+	operatorSlice = strings.Split(operator, " ")
+
+	//intArr = []rune(content)
+	//var contentInt [] int64
+	//for index := 0; index < len(intArr); index++ {
+	//	//toPubMsg.content = append(toPubMsg.content, int64(intArr[index]))
+	//	contentInt = append(contentInt, int64(intArr[index]))
+	//}
+
+	return SubscriptionMsg{msg, topicInt, valueInt, operatorSlice, isAlpha}
+}
+
+type Args struct { // 매개변수
+	JsonMsg []byte
+	Kind    int
+}
+
+type Reply struct { // 리턴값
+	CompleteLog string
+}
+
+func generateRanUint64() uint64 {
+	rand.Seed(time.Now().UnixNano())
+	//return uint64(rand.Uint32())<<32 + uint64(rand.Uint32())
+	return uint64(0 + uint64(rand.Uint32()))
+}
+
+func main() {
+	logger := NewMyLogger()
+	logger.Sync()
+
+	var argu string
+	for _, v := range os.Args {
+		if strings.Index(v, "-mma") == 0 {
+			argu = strings.Replace(v, "-mma=", "", -1)
+			break
+		}
+	}
+	MMAddress := argu
+	if argu == "" {
+		logger.Fatal("there is no Message Middleware address")
+		return
+	}
+
+	args := new(Args)
+	reply := new(Reply)
+
+	currentIP := getCurrentIPAddr()
+	const debugPK = 12345
+	privateKey := int64(generateRanUint64())
+	shareKey := int64(9999)
+
+	microService := MicroService{currentIP, privateKey, shareKey, make(chan bool), MMAddress}
+	receiver := Receiver{thisNodeAddr: currentIP, microService: microService}
+
+	logger.Info("current machine address : " + currentIP + " / MM address : " + MMAddress)
+	logger.Debug("private key : " + strconv.FormatUint(uint64(privateKey), 10))
+
+	errReg := rpc.Register(receiver)
+	if errReg != nil {
+		log.Println(errReg)
+		return
+	}
+
+	client, err := rpc.Dial("tcp", microService.MMAddress+":8160") // RPC 서버에 연결
+	if err != nil {
+		logger.Fatal(err.Error())
+		return
+	}
+	defer client.Close() // main 함수가 끝나기 직전에 RPC 연결을 닫음
+
+	go Listen()
+
+	// Register 메세지 생성
+	message := Message{From: microService.ClientAddr, Version: "1", Time: "1", Kind: RM}
+	regMsg := RegisterMsg{message, microService.PrivateKey}
+	RJsonMsg, _ := regMsg.ConvertToJson()
+	args.JsonMsg = RJsonMsg
+	args.Kind = RM
+	err = client.Call("Receiver.MmReceive", args, reply)
+	logger.Info("RM sent")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	logger.Debug("[MM] " + reply.CompleteLog)
+
+	sigs := make(chan os.Signal, 1)
+	done := make(chan bool, 1)
+
+	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
+
+	go func() {
+		sig := <-sigs
+		withDraw(message, client)
+		//fmt.Println(sig)
+		_ = sig
+		done <- true
+		fmt.Println("\nquit Moscato Successful and terminate microservice")
+		os.Exit(0)
+	}()
+
+	// 연결 되면 채널로 연결 확인이 되어야 다음 단계로 넘어감
+	checkConnect := <-microService.IsConnected
+	_ = checkConnect
+	fmt.Scanln()
+	logger.Info("sending Subscription messages")
+
+	/*
+		파일에서 subscription 읽어서 subscription 보내기
+		 **/
+	subFile, err := os.Open("subscription.txt")
+	if err != nil {
+		fmt.Println("sub")
+		log.Fatalf("Error when opening file: %s", err)
+	}
+	defer subFile.Close()
+	fileScanner := bufio.NewScanner(subFile)
+	var subscriptionText string
+	numSub := 0
+	file1, _ := os.Create("./subTimeLog.log")
+	defer file1.Close()
+	for fileScanner.Scan() {
+		subscriptionText = fileScanner.Text()
+		subscriptionTextSlice := strings.Split(subscriptionText, "/")
+		subTopic := subscriptionTextSlice[0]
+		subValue := subscriptionTextSlice[1]
+		subOperator := subscriptionTextSlice[2]
+		var subIsAlpha bool
+		if subscriptionTextSlice[3] == "true" {
+			subIsAlpha = true
+		} else if subscriptionTextSlice[3] == "false" {
+			subIsAlpha = false
+		} else {
+			println(numSub, "subscription isAlpha type error.")
+		}
+
+		numSub++
+		message = Message{From: microService.ClientAddr, Version: "1", Time: "1", Kind: SM}
+
+		// 메세지 생성시간 측정
+		subMakingStartTime := time.Now()
+
+		subMsg := CreateSubMsg(message, subTopic, subValue, subOperator, subIsAlpha)
+		logger.Debug("subMsg #" + strconv.Itoa(numSub) + " topic: " + subTopic + " / value: " + subValue + " / operator: " + subOperator)
+		logger.Debug("before enc subMsg #" + strconv.Itoa(numSub) + " topic: " + IntSlice2String(subMsg.Topic))
+
+		//subMsg := CreateSubMsg(message, "soccer", "player", "==", true)
+		//fmt.Println(pubMsg)
+		subMsg = EncryptionSubMsg(subMsg, microService.ShareKey, microService.PrivateKey)
+		logger.Debug("after enc subMsg #" + strconv.Itoa(numSub) + " topic: " + IntSlice2String(subMsg.Topic))
+		jsonMsg, _ := subMsg.ConvertToJson()
+		args.JsonMsg = jsonMsg
+		args.Kind = subMsg.Kind
+		//fmt.Println(subMsg)
+
+		//fmt.Println(string(args.JsonMsg))
+		subMakingElapsedTime := time.Since(subMakingStartTime)
+
+		// 메세지 생성 완료시간 측정
+		fmt.Printf("sub 생성시간: %d\n", subMakingElapsedTime.Nanoseconds())
+
+		fmt.Fprintln(file1, subMakingElapsedTime.Nanoseconds())
+
+		err = client.Call("Receiver.MmReceive", args, reply)
+		logger.Info("SM sent! #" + strconv.Itoa(numSub))
+
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+		//log.Println(reply.CompleteLog)
+		logger.Debug("[MM] " + reply.CompleteLog)
+
+	}
+
+	fmt.Scanln()
+	logger.Info("sending Publish messages")
+
+	pubFile, err := os.Open("publish.txt")
+	if err != nil {
+		log.Fatalf("Error when opening file: %s", err)
+	}
+	defer pubFile.Close()
+	fileScanner2 := bufio.NewScanner(pubFile)
+	var publishText string
+	numPub := 0
+	file2, _ := os.Create("./pubTimeLog.log")
+	defer file2.Close()
+
+	for fileScanner2.Scan() {
+		publishText = fileScanner2.Text()
+		publishTextSlice := strings.Split(publishText, "/")
+		//fmt.Println(publishTextSlice)
+		pubTopic := publishTextSlice[0]
+		pubValue := publishTextSlice[1]
+		pubContent := publishTextSlice[2]
+
+		numPub++
+		message = Message{From: microService.ClientAddr, Version: "1", Time: "1", Kind: PM}
+
+		pubMsg := CreatePubMsg(message, pubTopic, pubValue, pubContent)
+		logger.Debug("pubMsg #" + strconv.Itoa(numPub) + " topic: " + pubTopic + " / value: " + pubValue + " / content: " + pubContent)
+		logger.Debug("before enc pubMsg #" + strconv.Itoa(numPub) + " topic: " + IntSlice2String(pubMsg.Topic))
+
+		pubMakingStartTime := time.Now()
+		pubMsg = EncryptionPubMsg(pubMsg, microService.ShareKey, microService.PrivateKey)
+		pubMakingElapsedTime := time.Since(pubMakingStartTime)
+		fmt.Printf("pubMsg enc시간: %d\n\n", pubMakingElapsedTime.Nanoseconds())
+		fmt.Fprintln(file2,pubMakingElapsedTime.Nanoseconds())
+		logger.Debug("after enc pubMsg #" + strconv.Itoa(numPub) + " topic: " + IntSlice2String(pubMsg.Topic))
+		jsonMsg, _ := pubMsg.ConvertToJson()
+		args.JsonMsg = jsonMsg
+		args.Kind = pubMsg.Kind
+
+
+		err = client.Call("Receiver.MmReceive", args, reply)
+		logger.Info("PM sent! #" + strconv.Itoa(numPub))
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+
+		logger.Debug("[MM]: " + reply.CompleteLog)
+
+	}
+
+	<-done
+	return
+}
+
+func withDraw(msg Message, client *rpc.Client) {
+	msg.Kind = WM
+	wdMsg := WithdrawMsg{msg}
+	var args Args
+	args.JsonMsg, _ = wdMsg.ConvertToJson()
+	args.Kind = WM
+	var reply Reply
+	client.Call("Receiver.MmReceive", args, reply)
+}
+
+func EncryptionPubMsg(msg PublishMsg, gyKey int64, privateKey int64) PublishMsg {
+	for index := range msg.Topic {
+		msg.Topic[index] = msg.Topic[index] + gyKey + privateKey
+	}
+	for index := range msg.Value {
+		msg.Value[index] = msg.Value[index] + gyKey + privateKey
+	}
+	for index := range msg.Content {
+		msg.Content[index] = msg.Content[index] + gyKey + privateKey
+	}
+
+	return msg
+}
+
+func EncryptionSubMsg(msg SubscriptionMsg, gyKey int64, privateKey int64) SubscriptionMsg {
+	for index := range msg.Topic {
+		msg.Topic[index] = msg.Topic[index] + gyKey + privateKey
+	}
+	for index := range msg.Value {
+		msg.Value[index] = msg.Value[index] + gyKey + privateKey
+	}
+	return msg
+}
+
+func DecryptionMsg(msg PublishMsg, gyKey int64, privateKey int64) {
+	for index := range msg.Topic {
+		msg.Topic[index] = msg.Topic[index] - gyKey - privateKey
+	}
+	for index := range msg.Value {
+		msg.Value[index] = msg.Value[index] - gyKey - privateKey
+	}
+	for index := range msg.Content {
+		msg.Content[index] = msg.Content[index] - gyKey - privateKey
+	}
+
+	var runeArr []rune
+	for index := range msg.Topic {
+		runeArr = append(runeArr, rune(int(msg.Topic[index])))
+	}
+	fmt.Println("Topic is: " + string(runeArr))
+	runeArr = nil
+
+	for index := range msg.Value {
+		runeArr = append(runeArr, rune(int(msg.Value[index])))
+	}
+
+	if len(runeArr) == 1 {
+		fmt.Println("Value is: ", runeArr)
+	} else {
+		fmt.Println("Value is:", string(runeArr))
+	}
+
+	runeArr = nil
+
+	for index := range msg.Content {
+		runeArr = append(runeArr, rune(int(msg.Content[index])))
+	}
+	fmt.Println("Content is: " + string(runeArr))
+	runeArr = nil
+
+}
+
+func Listen() {
+	l, err1 := net.Listen("tcp", ":8150") //MM로 부터 받는거
+	if err1 != nil {
+		log.Fatal(fmt.Sprintf("Unable to listen on given port: %s", err1))
+	}
+	defer l.Close()
+
+	for {
+		conn, _ := l.Accept()
+		go rpc.ServeConn(conn)
+	}
+}
+
+func IntSlice2String(target []int64) string {
+	var targetString string
+	targetString = ""
+	for _, value := range target {
+		targetString += strconv.FormatInt(int64(value), 10) + " "
+	}
+	return targetString
+}

src/parseJson_test.go

@@ -0,0 +1,50 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"testing"
+)
+
+func parseJson(dat []byte) {
+	data := make(map[string]interface{})
+	err := json.Unmarshal([]byte(dat), &data)
+	if err != nil {
+		fmt.Println(err)
+	}
+	traverseCheck(data)
+}
+
+
+func traverseCheck(el map[string]interface{}) {
+	for key, val := range el{
+		_ = val
+		if key == "==" || key == ">=" || key == "<=" || key == "<" || key == ">"{
+			//fmt.Println("****************")
+			tmpMap := el[key].(map[string]interface{})
+			fmt.Println(key)
+			for k, v := range tmpMap{
+				fmt.Println(k, v)
+			}
+			//fmt.Println("****************")
+
+		} else if key == "||" || key == "&&"{
+			tmpSlice := el[key].([]interface{})
+			fmt.Println(key)
+			for _, obj := range tmpSlice{
+				data := obj.(map[string]interface{})
+				traverseCheck(data)
+			}
+		}
+	}
+}
+
+func TestParseJson(t *testing.T) {
+
+	dat, err := ioutil.ReadFile("./example.json")
+	if err != nil {
+		fmt.Println(err)
+	}
+	parseJson(dat)
+}

src/pubTimeLog.log

@@ -0,0 +1,5 @@
+0
+0
+0
+0
+0

src/publish.txt

@@ -0,0 +1,5 @@
+Age/5/(0, 'Kimjaehoon', '161114-4124400', 'Female', 5, '2019-10-26', '03:10:59', '2019-10-26', 'Acanthosis nigricans', 'Kimsinhye')
+Age/5/(1, 'Kimseunghwan', '160209-3070094', 'Male', 5, '2016-07-29', '15:24:19', '2016-07-29', 'Achalasia', 'Dongjaejun')
+Age/1/(2, 'Kimyoung', '200922-4732062', 'Female', 1, '2012-07-21', '02:50:22', '2012-07-21', 'Achilles tendon rupture', 'Parkjaemin')
+Age/1/(3, 'Kimhwanwoo', '201219-3330932', 'Male', 1, '2014-05-30', '14:45:31', '2014-05-30', 'Acute coronary syndrome', 'Seoinho')
+Age/3/(4, 'Kimyebin', '180805-4826819', 'Female', 3, '2000-01-25', '19:15:34', '2000-01-25', 'Adenomyosis', 'Sondahye')

src/subTimeLog.log

@@ -0,0 +1 @@
+536000

src/subscription.txt

@@ -0,0 +1 @@
+Age/1/==/false

test.log

@@ -0,0 +1,41 @@
+2022-01-02T15:43:21.444+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T15:43:21.445+0900	DEBUG	private key : 3547138460
+2022-01-02T15:43:21.447+0900	INFO	RM sent
+2022-01-02T15:43:21.447+0900	DEBUG	[MM] RM received
+2022-01-02T15:43:21.453+0900	INFO	MM Registered this node Complete!
+2022-01-02T15:46:14.173+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T15:46:14.174+0900	DEBUG	private key : 1652718355
+2022-01-02T15:46:14.175+0900	INFO	RM sent
+2022-01-02T15:46:14.175+0900	DEBUG	[MM] RM received
+2022-01-02T15:46:14.181+0900	INFO	MM Registered this node Complete!
+2022-01-02T15:46:25.988+0900	INFO	sending Subscription messages
+2022-01-02T15:48:06.443+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T15:48:06.443+0900	DEBUG	private key : 2580440694
+2022-01-02T15:48:06.445+0900	INFO	RM sent
+2022-01-02T15:48:06.445+0900	DEBUG	[MM] RM received
+2022-01-02T15:48:19.445+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T15:48:19.445+0900	DEBUG	private key : 2861559125
+2022-01-02T15:48:19.448+0900	INFO	RM sent
+2022-01-02T15:48:19.452+0900	DEBUG	[MM] RM received
+2022-01-02T15:48:19.458+0900	INFO	MM Registered this node Complete!
+2022-01-02T15:48:22.290+0900	INFO	sending Subscription messages
+2022-01-02T15:59:46.422+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T15:59:46.422+0900	DEBUG	private key : 1320653589
+2022-01-02T15:59:46.424+0900	INFO	RM sent
+2022-01-02T15:59:46.424+0900	DEBUG	[MM] RM received
+2022-01-02T15:59:46.437+0900	INFO	MM Registered this node Complete!
+2022-01-02T15:59:49.270+0900	INFO	sending Subscription messages
+2022-01-02T16:00:17.004+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T16:00:17.005+0900	DEBUG	private key : 560452067
+2022-01-02T16:00:17.006+0900	INFO	RM sent
+2022-01-02T16:00:17.006+0900	DEBUG	[MM] RM received
+2022-01-02T16:00:29.424+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T16:00:29.424+0900	DEBUG	private key : 213155866
+2022-01-02T16:00:29.426+0900	INFO	RM sent
+2022-01-02T16:00:29.426+0900	DEBUG	[MM] RM received
+2022-01-02T16:00:29.440+0900	INFO	MM Registered this node Complete!
+2022-01-02T16:00:32.131+0900	INFO	sending Subscription messages
+2022-01-02T16:08:17.494+0900	INFO	current machine address : 192.168.0.77 / MM address : 127.0.0.1
+2022-01-02T16:08:17.496+0900	INFO	RM sent
+2022-01-02T16:08:17.503+0900	INFO	MM Registered this node Complete!
+2022-01-02T16:08:20.647+0900	INFO	sending Subscription messages