Write frame at init.go

Refer init.go operations for understading other funcs

main.go

@@ -1,7 +1,8 @@
 package main
 
-import "fmt"
+import "modules/Moscato_Messaging_Middleware/modules"
 
 func main() {
-	fmt.Printf("??")
+	moscato := modules.Moscato{}
+	moscato.Run()
 }

modules/init.go

@@ -1 +1,93 @@
 package modules
+
+import (
+	"errors"
+	"fmt"
+	"log"
+	"net"
+	"net/rpc"
+)
+
+//temporary type for matching manager
+type match_manager struct{}
+
+func (match_mng *match_manager) matching(queue *MsgQueue) {
+	//msg := queue.pop(true)
+	//Implement here ~~
+}
+
+func (match_mng *match_manager) add_subscription(msg MsgUnit) {
+
+}
+
+//temporary type for secure(key) manager
+type secure_manager struct{}
+
+type Moscato struct {
+	queue      MsgQueue
+	ms_mng     MStable
+	match_mng  match_manager
+	secure_mng secure_manager
+}
+
+// Send - rpc를 이용하여 msg전송
+func Send(ipaddr string, message MsgUnit) error {
+	return nil
+}
+
+// Recieve - rpc를 이용하여 msg전달 받음(rpc call)
+func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
+	msg_type := msg.CheckType()
+
+	//메세지 타입에 따라 다르게 처리
+	switch msg_type {
+
+	case KSM: //Key share msg
+
+	case PM: //Publish msg
+		moscato.queue.push(msg.(*PublishMsg))
+
+	case SM: //Subscription msg
+		moscato.match_mng.add_subscription(msg.(*SubscriptionMsg))
+
+	case RM: //Register msg
+		//var newmsg RegisterMsg
+		var newmsg = msg.(*RegisterMsg)
+		newNode := MSnode{newmsg.from, newmsg.from}
+		moscato.ms_mng.add_microservice(newNode)
+
+	case WM: //Withdraw msg
+		moscato.ms_mng.remove_microservice(msg.(*WithdrawMsg).from)
+
+	default:
+		return nil, errors.New("Message type Error: Not registered message type")
+	}
+
+	return msg, nil
+}
+
+func (moscato *Moscato) Run() {
+	//모스카토 구조체 변수 초기화
+	moscato.queue.queue_init()
+
+	//go routine -> matching 동작
+	go moscato.match_mng.matching(&moscato.queue)
+
+	//rpc 등록 -> Receive함수
+	rpc.Register(moscato)
+	moscato.Listen()
+}
+
+func (moscato *Moscato) Listen() {
+	l, err := net.Listen("tcp", fmt.Sprintf(":%v", 8160))
+
+	if err != nil {
+		log.Fatal(fmt.Sprintf("Unable to listen on given port: %s", err))
+	}
+	defer l.Close()
+
+	for {
+		conn, _ := l.Accept()
+		go rpc.ServeConn(conn)
+	}
+}

modules/message.go

@@ -42,7 +42,7 @@ type KeyGenMsg struct {
 //Key공유 메세지
 type KeyShareMsg struct {
 	Message
-	base32 string
+	key string
 }
 
 //전달할 내용을 담은 메세지

modules/queue.go

@@ -3,7 +3,7 @@ package modules
 import "errors"
 
 type MsgQueue struct {
-	queue     chan Message
+	queue     chan MsgUnit
 	QueueFunc QueueOperate
 }
 
@@ -20,29 +20,29 @@ func (mq *MsgQueue) queue_init() error {
 	if mq.queue != nil && len(mq.queue) != 0 {
 		return errors.New("Queue Hadlerer Error: Already initialized.")
 	} else if mq.queue == nil {
-		mq.queue = make(chan Message, 1000)
+		mq.queue = make(chan MsgUnit, 1000)
 		return nil
 	} else {
 		close(mq.queue)
-		mq.queue = make(chan Message)
+		mq.queue = make(chan MsgUnit)
 		return nil
 	}
 }
 
-func (mq *MsgQueue) push(msg Message) bool {
+func (mq *MsgQueue) push(msg MsgUnit) bool {
 	mq.queue <- msg
 	return true
 }
 
-func (mq *MsgQueue) pop(wait bool) (Message, error) {
+func (mq *MsgQueue) pop(wait bool) MsgUnit {
 	if wait == true {
 		if len(mq.queue) == 0 {
-			return Message{}, errors.New("Queue Handler Alert: Queue is Empty")
+			return nil
 		} else {
-			return <-mq.queue, nil
+			return <-mq.queue
 		}
 	} else {
 		//queue에 데이터가 들어올 때까지 block
-		return <-mq.queue, nil
+		return <-mq.queue
 	}
 }