java Android中的Signalr连接事件手柄

Question

我正在使用SignalR来制作两人在线游戏。到目前为止，一切都很好。但是，当一个玩家的互联网被切断（以几毫秒为单位）或由于任何原因切断服务器时，该程序将不再起作用。如何通知连接事件？ 如何自动重新连接？

我已经研究了很长时间，但是我还没有找到解决方案

ASP.NET Core 5.0服务器端：

    public class ChatHub : Hub
    {
        LogHelper logHelper = new LogHelper("hub");

        public async Task Move(float x, float y)
        {
                await Clients.Others.SendAsync("ReceivePosition", x, y);
        }
}

客户端Java Android Studio：

public class MainActivity extends AppCompatActivity {


    private static final String TAG = "qazwsx";
    Button btnStart;
    View viewMove;

    HubConnection hubConnection;

    @SuppressLint({"ClickableViewAccessibility", "CheckResult"})
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        hubConnection = HubConnectionBuilder.create("http://192.168.1.10:45455/notification").build();

        hubConnection.on("ReceivePosition", (x, y) -> {

            runOnUiThread(() -> {
                viewMove.setX(x);
                viewMove.setY(y);

                Log.i(TAG, String.format("onCreate: x:%s  y:%s", x, y));
            });

        }, Float.class, Float.class);

        btnStart = findViewById(R.id.bntStart);
        viewMove = findViewById(R.id.viewMove);


        btnStart.setOnClickListener(view -> {
            Log.i(TAG, "onCreate > btnStart.setOnClickListener > status:" + hubConnection.getConnectionState());
            if (btnStart.getText().toString().equals("START")) {
                if (hubConnection.getConnectionState() == HubConnectionState.DISCONNECTED) {
                    btnStart.setText("STOP");
                }
            } else {
                if (hubConnection.getConnectionState() == HubConnectionState.CONNECTED) {
                    hubConnection.stop();

                }
            }
        });

        final float[] dX = new float[1];
        final float[] dY = new float[1];
        viewMove.setOnTouchListener((view, event) -> {

            switch (event.getAction()) {
                //this is your code
                case MotionEvent.ACTION_DOWN:
                    dX[0] = view.getX() - event.getRawX();
                    dY[0] = view.getY() - event.getRawY();
                    break;
                case MotionEvent.ACTION_MOVE:
                    view.animate()
                            .x(event.getRawX() + dX[0])
                            .y(event.getRawY() + dY[0])
                            .setDuration(0)
                            .start();
                    if (hubConnection.getConnectionState() == HubConnectionState.CONNECTED) {
                        hubConnection.send("Move", event.getRawX() + dX[0], event.getRawY() + dY[0]);
                        Log.i(TAG, String.format("move: x:%s  y:%s", dX[0], dY[0]));

                    }
                    break;
                default:
                    return false;
            }
            return true;

        });
    }


}

Answer 1

经过大量研究，我设法解决了这个问题。我正在写解决这个问题的解决方案。我希望它能解决别人的问题

处理信号连接关闭：

hubConnection.onClosed(exception -> {
            //do something
            //attemt to connect
            //note: exception is null when the user stop connection
        });

处理信号连接开始：

    hubConnection.start()
                            .doOnError(throwable -> {
                                Log.e(TAG, "doInBackground > doOnError: ", throwable);
//start fail , try again    
//note: the start function need try chach when we use this function
                            })
                            .doOnComplete(() -> {
                                Log.i(TAG, "doInBackground > doOnComplete.");
                                //start complated
                            })
                            .blockingAwait();//you must write this function ,else other function not worck