Rmessage

Selamat datang di dokumentasi Rmessage

tumpukan teknologi

Rmessage adalah API push pesan real-time yang dibangun pada proyek jaringan reaktor menggunakan Reactor3.

• Apa itu Reactor3?

  Reactor adalah kerangka pemrograman reaktif yang sepenuhnya non-pemblokiran untuk JVM, dengan kemampuan manajemen permintaan yang efisien (yaitu, kontrol "tekanan balik"). Ini terintegrasi langsung dengan API fungsional Java 8 seperti CompletableFuture, Stream, dan Duration. Ini menyediakan API Flux urutan asinkron (untuk elemen [N]) dan Mono (untuk elemen [0|1]), dan sepenuhnya mengikuti dan mengimplementasikan "Spesifikasi Ekstensi Reaktif".

• Apa keuntungan menggunakan Reaktor?

  Sangat mudah untuk membuat kode asinkron murni dengan throughput tinggi, dan dapat mengintegrasikan proyek spring5 [webflux] dengan mulus.

Pengenalan proyek

Untuk menggunakan Rmessage, Anda perlu mengelola hubungan pengguna grup secara eksternal dan penyimpanan pesan offline. Rmessage tidak menyediakan persistensi. Keseluruhan proyek dikembangkan menggunakan ide pemrograman asinkron murni, yang bertujuan untuk mempelajari pemrograman reaktif.

• alamat kode cloud
• alamat github

Fitur yang didukung saat ini

1. Obrolan pribadi
2. obrolan grup
3. Pendaratan dan penarikan pesan offline
4. Manajemen notifikasi offline dan online
5. Detak jantung, mekanisme otentikasi koneksi
6. Manajemen hubungan kelompok
7. Mendukung multi-terminal online
8. Saat ini, protokol TCP didukung, dan perluasan multi-protokol dipertimbangkan saat merancang proyek.
9. Mendukung intersepsi pesan khusus sisi server
10. Mekanisme QOS pesan (belum diimplementasikan)

mulai cepat

• pelayan

Rmessage tidak mengatur hubungan antar kelompok pengguna dan mengekspos bagian luar melalui antarmuka.

 ServerStart
   . builder ()
   . tcp ()
   . ip ( "127.0.0.1" )
   . port ( 1888 )
   . onReadIdle ( 10000l ) //设置读心跳时间
   . onWriteIdle ( 10000l ) //设置写心跳时间
   . option ( ChannelOption . SO_RCVBUF , 1023 )
   . interceptor ( frame -> frame , frame -> frame ) // 拦截所有message
   . setAfterChannelInit ( channel -> { //  channel设置
      })
   . connect ()
   . cast ( TcpServerSession . class )
   . subscribe ( session ->{
                    session . addGroupHandler ( groupId -> null ). subscribe ();
                    session . addOfflineHandler ( new DefaultOffMessageHandler ()). subscribe ();
                    session . addUserHandler ( new DefaultUserTransportHandler ());
  });

Untuk definisi metode antarmuka tertentu, silakan lihat komentar antarmuka.

1. Antarmuka UserHandler menangani verifikasi login pengguna, dll.
2. OfflineHandler adalah antarmuka untuk memproses penyimpanan pesan offline dan menarik pesan offline.
3. GroupHandler adalah antarmuka untuk mendapatkan semua pengguna di bawah grup

• klien

 ClientStart
     . builder ()
     . tcp ()
     . ip ( "127.0.0.1" )
     . port ( 1888 )
     . userId ( "21344" )  //设置用户名
     . password ( "12312" ) //设置密码
     . onReadIdle ( 10000l ,()->()-> System . out . println ( "心跳了" )) //设置读心跳,以及设置回调runner
     . setClientType ( ClientType . Ios ) //设置客户端类型
     . setAfterChannelInit ( channel -> {
                    //  channel设置
      })
     . connect ()
     . cast ( TcpClientSession . class )
     . subscribe ( session ->{
      session . sendPoint ( "123" , "测试一下哦" ). subscribe (); //发送单聊消息
                    session . sendGroup ( "group1" , "123" ). subscribe ();  // 发送群聊消息
                    session . accept ( message -> {
    }); // 接受所有消息
  });

Desain protokol

• Ngobrol sendiri dan ngobrol lebih banyak

PerbaikiHeader 【1 byte】

tipe_klien	tipe_pesan
4bit tinggi	4bit rendah

Topik 【n byte】

dari panjang	menjadi panjang	dari	ke
1bita	1bita	n byte	n byte

Isi [n byte]

panjang tubuh	tubuh
2 byte	n byte

cap waktu
8 byte

• Pesan daring

PerbaikiHeader 【1 byte】

tipe_klien	tipe_pesan
4bit tinggi	4bit rendah

Status Koneksi [n byte]

panjang pengguna	panjang kata sandi	pengguna	kata sandi
1bita	1bita	n byte	n byte

• Pesan luring

PerbaikiHeader 【1 byte】

tipe_klien	tipe_pesan
4bit tinggi	4bit rendah

Status Koneksi [n byte]

panjang pengguna	pengguna
1bita	n byte

• Pesan ping/pesan Pong

PerbaikiHeader 【1 byte】

tipe_klien	tipe_pesan
4bit tinggi	4bit rendah