[add] log4go 에서 zap으로 로그 라이브러리 변경

src/broker/modules/init.go

@@ -128,9 +128,12 @@ func (receiver Receiver) MmReceive(args Args, reply *Reply) error { //
 	//reply.CompleteLog = "received completely"
 	return nil
 }
+
 //Recieve - MM가 MS로부터 메세지 전달받음
 func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
-	l4g.LoadConfiguration("modules/logConfig.json")
+	var logger = newLogger()
+	defer logger.Sync()
+
 	//rpc call
 	var msg_type = msg.CheckType()
 	//메세지 타입에 따라 다르게 처리
@@ -140,12 +143,12 @@ func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
 
 	case PM: //Publish msg
 		//log.Println("PM received")
-		l4g.LOGGER("Test").Info("PM received")
+		logger.Info("PM received")
 		moscato.queue.push(moscato.preProcessMsg(msg))
 
 	case SM: //Subscription msg
 		//log.Println("SM received")
-		l4g.LOGGER("Test").Info("SM received")
+		logger.Info("SM received")
 		err := moscato.SubscriptionManager.addSubscription(moscato.preProcessMsg(msg))
 		if err != nil {
 			println(err)
@@ -153,9 +156,7 @@ func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
 		}
 
 	case RM: //Register msg
-		//log.Println("RM received")
-		l4g.LOGGER("Test").Info("RM received")
-		l4g.LOGGER("Test").Debug("RM received")
+		logger.Info("RM received")
 		var newMsg RegisterMsg
 		newMsg = msg.(RegisterMsg)
 
@@ -210,7 +211,6 @@ MM→MS
 */
 
 func (moscato *Moscato) Send2MS(ipaddress string, msg MsgUnit) {
-	l4g.LoadConfiguration("logConfig.json")
 	client, err := rpc.Dial("tcp", ipaddress+":8150")
 	if err != nil {
 		fmt.Println(err)
@@ -232,7 +232,7 @@ func (moscato *Moscato) Send2MS(ipaddress string, msg MsgUnit) {
 	//log.Println(reply.CompleteLog) //잘 받았는지 확인 해줌
 	// 마이크로 서비스에게 받은 메시지는 노란색으로 출력
 	//log.Println(reply.CompleteLog)
-	l4g.LOGGER("Test").Info(reply.CompleteLog)
+	//l4g.LOGGER("Test").Info(reply.CompleteLog)
 }
 
 //Matching을 용이하게 하기위한 메세지 가공 과정
@@ -319,9 +319,9 @@ func (moscato *Moscato) Run() {
 
 func Listen() {
 	/*
-	MS→MM일때 ⇒ port : 8160으로 열기
+		MS→MM일때 ⇒ port : 8160으로 열기
 
-	(MM이 Server, MS가 Client)
+		(MM이 Server, MS가 Client)
 	*/
 
 	l, err1 := net.Listen("tcp", ":8160")