26 lines
825 B
C#
26 lines
825 B
C#
using UnityEngine;
|
|
using System.Collections.Generic;
|
|
using System.Collections.Concurrent;
|
|
using Newtonsoft.Json;
|
|
|
|
public class MQTTDataBase : MonoBehaviour
|
|
{
|
|
public static MQTTDataBase Instance;
|
|
public ConcurrentDictionary<string, ConcurrentQueue<Dictionary<string, object>>> mqttDataBase;
|
|
|
|
private void Awake()
|
|
{
|
|
mqttDataBase = new ConcurrentDictionary<string, ConcurrentQueue<Dictionary<string, object>>>();
|
|
Instance = this;
|
|
}
|
|
|
|
public void AddDict(string key, string value)
|
|
{
|
|
var dicts = JsonConvert.DeserializeObject<Dictionary<string, object>>(value);
|
|
|
|
// 해당 key가 없으면 새 큐를 생성하고, 이미 있으면 기존 큐를 반환
|
|
var queue = mqttDataBase.GetOrAdd(key, _ => new ConcurrentQueue<Dictionary<string, object>>());
|
|
queue.Enqueue(dicts);
|
|
}
|
|
}
|