[fin]init.go rpc

src/microservice/modules/init.go

@@ -10,12 +10,40 @@ import (
 type Microservice struct {
 }
 
-func (microservice *Microservice) Send2MM() {
+type Moscato struct {
+}
+
+type Reply struct {
+	receivemsg MsgUnit
+}
 
+func (microservice *Microservice)MS_Receive(msg MsgUnit, reply *Reply)error{
+	go microservice.Receive(msg)
+	return nil
 }
 
-func (microservice *Microservice) Send2client() {
+//Receive - MicroService가 msg 받음// MS.go들어가야할 함수
+func (microservice *Microservice)Receive(msg MsgUnit)error{
+	msg_type:=msg.CheckType()
+
+	switch msg_type{
+	case KGM://Key Gen Msg
+
+	case KSM://Key Share Msg
+
+	case SM://Subscription Msg
+
+	}
+	return nil
+}
 
+func (microservice *Microservice) Send2MM(client *rpc.Client,msg MsgUnit) {
+	reply:=new(Reply)
+	err:=client.Call("Moscato.MM_Receive", msg,reply)
+	if err !=nil{
+		fmt.Println(err)
+		return
+	}
 }
 
 func (microservice *Microservice) Listen() {
@@ -32,6 +60,70 @@ func (microservice *Microservice) Listen() {
 	}
 }
 
+
+func handleSum(ln net.Listener){
+	for {
+		conn, err := ln.Accept() // 클라이언트가 연결되면 TCP 연결을 리턴
+		if err != nil {
+			continue
+		}
+
+		defer func(conn net.Conn) {
+			err := conn.Close()
+			if err != nil {
+
+			}
+		}(conn)             // main 함수가 끝나기 직전에 TCP 연결을 닫음
+
+		go rpc.ServeConn(conn) // RPC를 처리하는 함수를 고루틴으로 실행
+	}
+}
+
+func callRPC(client *rpc.Client, msg MsgUnit, err error){
+	reply := new(MsgUnit)
+	err = client.Call("Moscato.MM_Receive", msg, reply) // Calc.Sum 함수 호출
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+}
+
 func (microservice *Microservice) Run() {
+	err := rpc.Register(new(Microservice))
+	if err != nil {
+		return
+	} // Calc 타입의 인스턴스를 생성하여 RPC 서버에 등록
+	ln, err := net.Listen("tcp", ":6000") // TCP 프로토콜에 6000번 포트로 연결을 받음 local 나중에 8150
+	ln1, err1 := net.Listen("tcp", ":6001") // TCP 프로토콜에 6000번 포트로 연결을 받음 나중에 8160
+
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	if err1 != nil {
+		fmt.Println(err)
+		return
+	}
+	defer func(ln net.Listener) {
+		err := ln.Close()
+		if err != nil {
+
+		}
+	}(ln)             // main 함수가 종료되기 직전에 연결 대기를 닫음
+	defer func(ln1 net.Listener) {
+		err := ln1.Close()
+		if err != nil {
+
+		}
+	}(ln1) // main 함수가 종료되기 직전에 연결 대기를 닫음
+
+	/*client1, err := rpc.Dial("tcp", "127.0.0.1:6000") // RPC 서버에 연결
+	if err != nil {
+		fmt.Println(err)
+		return
+	}*/
 
+	go handleSum(ln)
+	go handleSum(ln1)
+	fmt.Scanln() // main 함수가 종료되지 않도록 대기=
 }