新手指南

package main

import (
    cfacade "github.com/actorgo-game/actorgo/facade"
    cactor "github.com/actorgo-game/actorgo/net/actor"
)

const HelloMethodID uint32 = 1001

type HelloRequest struct {
    Name string `json:"name"`
}

type HelloResponse struct {
    Greeting string `json:"greeting"`
}

type HelloActor struct { cactor.Base }

func (*HelloActor) AliasID() string { return "hello" }

func (a *HelloActor) OnInit() {
    a.Methods().Register(HelloMethodID, a.hello)
}

func (a *HelloActor) hello(
    _ *cfacade.RequestContext,
    req *HelloRequest,
) (*HelloResponse, error) {
    return &HelloResponse{Greeting: "Hello, " + req.Name}, nil
}

{
  "env": "local",
  "debug": true,
  "print_level": "debug",
  "node": {
    "3": [{
      "node_id": "0.0.3.1",
      "enabled": true,
      "address": "127.0.0.1:9080"
    }]
  }
}

package main

import "github.com/actorgo-game/actorgo"

func main() {
    app := actorgo.Configure(
        "profile.json",
        "0.0.3.1",
        actorgo.Standalone,
    )
    app.AddActors(&HelloActor{})
    app.Startup()
}

import httpactor "github.com/actorgo-game/actorgo/net/httpactor"

app := actorgo.Configure("profile.json", "0.0.3.1", actorgo.Standalone)
app.AddActors(&HelloActor{})
app.Register(httpactor.NewComponent("actor-api", app.Address()))
app.Startup()

import (
    cfacade "github.com/actorgo-game/actorgo/facade"
    "github.com/actorgo-game/actorgo/net/connector"
    "github.com/actorgo-game/actorgo/net/parser"
)

app.Register(parser.New("client", []cfacade.IConnector{
    connector.NewTCP(":9000"),
    connector.NewWS(":9001"),
}))

const LoginMethodID uint32 = 1001

func (a *PlayerActor) OnInit() {
    a.Methods().Register(LoginMethodID, a.Login)
}

func (a *PlayerActor) Login(
    ctx *facade.RequestContext,
    request *playerv1.LoginRequest,
) (*playerv1.LoginResponse, error) {
    return &playerv1.LoginResponse{}, nil
}

ctx := facade.NewRequestContext(context.Background())
ctx.Codec = facade.CodecProtobuf

// 本节点顶层方法
result := app.ActorSystem().Invoke(ctx, methodID, req)

// 指定远端节点；底层可选择 NATS 或 RabbitMQ
result = app.ActorSystem().InvokeNode(
    ctx, "center-1", methodID, req,
)