PROTOCOL_LOGIN_ACK

[Boris2105]

Programmator не мог бы ты еще немного помочь.
Я начал писать подключение к БД и возник вопрос.
После отправки пакета PROTOCOL_LOGIN_ACK, мне надо что то вызывать чтобы подключиться к БД и пошла загрузка инф из БД в PROTOCOL_BASE_GET_USER_INFO_ACK?

И не мог бы подсказать что нужно для написание BattleServer с UDP 3?


Ошибка так и осталась, хоть я и изменил

ClientConnection:

Свернуть ↑
public void BeginRead(IAsyncResult asyncResult)
{
try
{
int received = Stream.EndRead(asyncResult);
if (received != 0)
{
while (received >= 6)
{
int length = BitConverter.ToUInt16(buffer, 0) & 0x7FFF;

byte[] temp = new byte[length + 2];
Array.Copy(buffer, 2, temp, 0, temp.Length);

int bits = Id % 7 + 1;
BitShift.Unshift(temp, bits);

byte[] opcode = new byte[] { temp[0], temp[1] };
RecvOpcode packet = (RecvOpcode)BitConverter.ToUInt16(opcode, 0);
Type t = Type.GetType("PiercingBlow.Login.Network.Recv." + packet.ToString());

if (t != null)
{
ClientPacket clientpacket = (ClientPacket)Activator.CreateInstance(t);
clientpacket.Client = this;
clientpacket.Process(temp);
}
else
{
Log.Info("PacketId = {0}", BitConverter.ToUInt16(opcode, 0), buffer.Length);
Log.Trace(temp.ToHex());
}
received -= length + 4;
Array.Copy(buffer, length + 4, buffer, 0, received);
}
Stream.BeginRead(buffer, 0, buffer.Length, BeginRead, Stream);
}
else
{
OnDisconnected(this);
}
}
catch (IOException)
{
OnDisconnected(this);
}
catch (Exception ex)
{
OnDisconnected(this);

Log.Error("Disconnect",ex);
}
}

Свернуть ↑Развернуть ↓

[Awiion]

Boris2105, Для udp3 сервера надо,
Пакет подключения игрока, вот Connect
Пакет о комнате,
Пакет о состояние боя,
И структуру динамического боя.
Это все есть тут
______________________________

Сообщение от Boris2105

Programmator не мог бы ты еще немного помочь.
Я начал писать подключение к БД и возник вопрос.
После отправки пакета PROTOCOL_LOGIN_ACK, мне надо что то вызывать чтобы подключиться к БД и пошла загрузка инф из БД в PROTOCOL_BASE_GET_USER_INFO_ACK?

А что там такого?

Пишешь коннектор, создаешь таблицу и указываешь аккаунт ид.
потом потом ее кидаешь в цикл, получится типо такого

private Player player;
player = PlayerTable.Players[account.AccountID];

[PROGRAMMATOR]

Boris2105, предположу, что MySQL? Через NuGet ставишь MySql.Data, и по примеру Awiion пишешь примерно следующее:

using (var reader = MySqlHelper.ExecuteReader(ConnectionString, "SELECT * FROM `accounts`"))
{
	while (reader.Read())
	{
		var account = new Account()
		{
			Id = reader.GetUInt64("Id"),
			Name = reader.GetString("Name"),
			Password = reader.GetString("Password"),
			Email = reader.GetString("Email"),
			// ...
		};
 
		accounts.Add(account);
	}
}
 
Code: C#

Или доставить ещё Dapper и тогда можно так:

using (var connection = Cached.GetConnection) // connection = MySqlConnection
{
    var accounts = SqlMapper.Query<AccountModel>(connection, "SELECT * FROM `accounts`");
 
    return accounts;
}
 
Code: C#

И выбираешь при авторизации по логину (токену если нужно):

var account = accounts.FirstOrDefault(x => x.Login == login);
 
Code: C#

ConnectionString имеет следующий вид:

$"server={server};port={port};database={database};Character Set={encoding};User Id={user};password={password}"

[Boris2105]

Сообщение от PROGRAMMATOR

Boris2105, предположу, что MySQL? Через NuGet ставишь MySql.Data, и по примеру Awiion пишешь примерно следующее:

using (var reader = MySqlHelper.ExecuteReader(ConnectionString, "SELECT * FROM `accounts`"))
{
	while (reader.Read())
	{
		var account = new Account()
		{
			Id = reader.GetUInt64("Id"),
			Name = reader.GetString("Name"),
			Password = reader.GetString("Password"),
			Email = reader.GetString("Email"),
			// ...
		};
 
		accounts.Add(account);
	}
}
 
Code: C#

Или доставить ещё Dapper и тогда можно так:

using (var connection = Cached.GetConnection) // connection = MySqlConnection
{
    var accounts = SqlMapper.Query<AccountModel>(connection, "SELECT * FROM `accounts`");
 
    return accounts;
}
 
Code: C#

И выбираешь при авторизации по логину (токену если нужно):

var account = accounts.FirstOrDefault(x => x.Login == login);
 
Code: C#

ConnectionString имеет следующий вид:

$"server={server};port={port};database={database};Character Set={encoding};User Id={user};password={password}"

Спасибо , а вот на счет этого?

Ошибка так и осталась, хоть я и изменил

ClientConnection:

Свернуть ↑
public void BeginRead(IAsyncResult asyncResult)
{
try
{
int received = Stream.EndRead(asyncResult);
if (received != 0)
{
while (received >= 6)
{
int length = BitConverter.ToUInt16(buffer, 0) & 0x7FFF;

byte[] temp = new byte[length + 2];
Array.Copy(buffer, 2, temp, 0, temp.Length);

int bits = Id % 7 + 1;
BitShift.Unshift(temp, bits);

byte[] opcode = new byte[] { temp[0], temp[1] };
RecvOpcode packet = (RecvOpcode)BitConverter.ToUInt16(opcode, 0);
Type t = Type.GetType("PiercingBlow.Login.Network.Recv." + packet.ToString());

if (t != null)
{
ClientPacket clientpacket = (ClientPacket)Activator.CreateInstance(t);
clientpacket.Client = this;
clientpacket.Process(temp);
}
else
{
Log.Info("PacketId = {0}", BitConverter.ToUInt16(opcode, 0), buffer.Length);
Log.Trace(temp.ToHex());
}
received -= length + 4;
Array.Copy(buffer, length + 4, buffer, 0, received);
}
Stream.BeginRead(buffer, 0, buffer.Length, BeginRead, Stream);
}
else
{
OnDisconnected(this);
}
}
catch (IOException)
{
OnDisconnected(this);
}
catch (Exception ex)
{
OnDisconnected(this);

Log.Error("Disconnect",ex);
}
}

Свернуть ↑Развернуть ↓

[PROGRAMMATOR]

Тебе виднее, я же не вижу, как себя ведёт клиент.
Может после подключения он валится от какой-то ошибки.

[Boris2105]

При попытке войти , клиент сразу отключает.

ClientPacket:

Свернуть ↑
public string ReadS(int length)
{
string text = "";
try
{
text = Encoding.Default.GetString(_buffer, _offset, length);
int _length = text.IndexOf(char.MinValue);
if (_length != -1)
{
text = text.Substring(0, _length);
}
_offset += length;
}
catch (Exception e)
{
Log.Error(e.ToString());
}
return text;
}

Свернуть ↑Развернуть ↓

PROTOCOL_LOGIN_REQ:

Свернуть ↑
public override void ReadImpl()
{
ReadB(100);
PasswordLength = ReadC();
Password = ReadS(PasswordLength);
LoginLength = ReadC();
Login = ReadS(LoginLength);
}

public override void RunImpl()
{
var manager = AccountManager.Instance;
Client.Account = manager.GetAccount(Login);
Client.SendPacket(new PROTOCOL_LOGIN_ACK(manager.IsValidAccount(Login, Password), Client.Account));
}

Свернуть ↑Развернуть ↓

PROTOCOL_LOGIN_ACK:

Свернуть ↑
WriteB(new byte[15]);
string id = account.Id.ToString();
WriteC(0);
WriteS(id, id.Length);
WriteC(0);
WriteC(account.Login.Length);
WriteS(account.Login);
WriteQ(account.Id);
WriteD((int)state);

Свернуть ↑Развернуть ↓

[PROGRAMMATOR]

Открой для себя BinaryReader и BinaryWriter и не нужно будет париться об офсетах.

int _length = text.IndexOf(char.MinValue);
if (_length != -1)
{
text = text.Substring(0, _length);
}

Это не длина, а индекс (IndexOf как бы намекает).

int index = text.IndexOf('\0');
 
if (index != -1)
{
    text = text.Remove(index);
}
 
Code: C#

P.S. Незачем новую тему создавать, ты же пару дней назад с таким же названием создал.

[Boris2105]

Сообщение от PROGRAMMATOR

Открой для себя BinaryReader и BinaryWriter и не нужно будет париться об офсетах.

int _length = text.IndexOf(char.MinValue);
if (_length != -1)
{
text = text.Substring(0, _length);
}

Это не длина, а индекс (IndexOf как бы намекает).

int index = text.IndexOf('\0');
 
if (index != -1)
{
    text = text.Remove(index);
}
 
Code: C#

P.S. Незачем новую тему создавать, ты же пару дней назад с таким же названием создал.

ты имеешь ввиду что-то типа такого?

private BinaryReader reader;
private byte[] _buffer;
private int _offset;
public int Remaining { get { return (int)(_buffer - _offset); } }
public int ReadInt()
        {
            if (Remaining < 4)
                throw new IndexOutOfRangeException();
            return reader.ReadInt32();
        }

[PROGRAMMATOR]

Типа такого:

public class PacketReader
{
    MemoryStream stream;
    BinaryReader reader;
 
    /// <summary>
    /// 
    /// </summary>
    /// <param name="buffer"></param>
    public void Init(byte[] buffer)
    {
        stream = new MemoryStream(buffer);
        reader = new BinaryReader(stream);
    }
 
    /// <summary>
    /// 
    /// </summary>
    /// <returns></returns>
    protected int ReadInt() => reader.ReadInt();
 
    /// ...
}
 
Code: C#

[Boris2105]

то есть вместо ReadD будет использоваться protected int ReadInt() => reader.ReadInt(); ?