Хотя автор вопроса уже сделал свой выбор не дождавшись других вариантов. Я все-таки попробую составить конкуренцию :)
Дамы и господа, вашему вниманию предлагается модный и молодежный Firebase
от известнейшей корпорации добра! Шутка :)
Все хипстеры, попивая смузи в Жан-Жаке, мечтают таки написать свой собственный кошерный (с шахматами и девочками) чатик для Айфона. Ну, и конечно, ничего кроме Firebase
ими просто не берется в расчет. Потому, если вы даже почти шепотом посмеете сказать или даже намекнуть про какой-нибудь мускул или подобное, то в ответ вы услышите лишь презрительное фи, хлопок закрывающегося макбука и досвидос. Опять была шутка :)
Работает это так
Зарегистрируйтесь, зайдите в консоль управления, добавьте новый проект
Слева в меню перейдите к разделу БД
Зайдите в правила
Измените на открытый доступ так
Да, я знаю, что это страшно и небезопасно. Но, мы же только учимся...
1) Создание библиотеки для работы с Firebase
Создайте проект библиотеки, и в нем класс Пакета такой
public class Package
{
public DateTime Date { get; set; }
public string Content { get; set; }
//ctor
public Package()
{
Date = DateTime.Now;
Content = "<?>";
}
public override string ToString()
{
return $"{Date.ToLongTimeString()}: {Content}";
}
public override bool Equals(object obj)
{
var package = obj as Package;
return package != null &&
Date == package.Date &&
Content == package.Content;
}
public override int GetHashCode()
{
var hashCode = -165655869;
hashCode = hashCode * -1521134295 + Date.GetHashCode();
hashCode = hashCode * -1521134295 + EqualityComparer<string>.Default.GetHashCode(Content);
return hashCode;
}
}
Для работы с сабжем создадим класс FirebaseClient
public class FirebaseClient
{
private enum HttpVerb
{
GET,
POST,
PATCH,
DELETE
}
private const string _CONTENT_TYPE = "application/json";
private const string _CONTENT_TYPE_WITH_CHARSET = "application/json: charset=utf-8";
private const string _EMPTY_ANSWER_FIREBASE = "null";
private readonly string _path;
private WebRequest _webRequest;
//ctor
public FirebaseClient(string path)
{
if (String.IsNullOrEmpty(path)) throw new ArgumentNullException(nameof(path));
_path = path;
}
/// <summary>
/// Добавление новых данных
/// </summary>
/// <param name="json">текст в формате Json</param>
/// <returns></returns>
public string Insert(string json)
{
if (String.IsNullOrEmpty(json)) throw new ArgumentNullException(nameof(json));
SetWebRequest(HttpVerb.POST);
WriteJsonToStream(json);
return GetResultAfterPostOrPatch();
}
/// <summary>
/// Обновление данных
/// </summary>
/// <param name="json">текст в формате Json</param>
/// <returns></returns>
public string Update(string json)
{
if (String.IsNullOrEmpty(json)) throw new ArgumentNullException(nameof(json));
SetWebRequest(HttpVerb.PATCH);
WriteJsonToStream(json);
return GetResultAfterPostOrPatch();
}
private void SetWebRequest(HttpVerb httpVerb)
{
_webRequest = WebRequest.CreateHttp(_path);
switch (httpVerb)
{
case HttpVerb.GET:
_webRequest.Method = HttpVerb.GET.ToString();
_webRequest.ContentType = _CONTENT_TYPE_WITH_CHARSET;
break;
case HttpVerb.POST:
_webRequest.Method = HttpVerb.POST.ToString();
_webRequest.ContentType = _CONTENT_TYPE;
break;
case HttpVerb.PATCH:
_webRequest.Method = HttpVerb.PATCH.ToString();
_webRequest.ContentType = _CONTENT_TYPE;
break;
case HttpVerb.DELETE:
_webRequest.Method = HttpVerb.DELETE.ToString();
_webRequest.ContentType = _CONTENT_TYPE;
break;
default:
throw new ArgumentException(nameof(httpVerb));
}
}
private void WriteJsonToStream(string json)
{
byte[] buffer = Encoding.UTF8.GetBytes(json);
_webRequest.ContentLength = buffer.LongLength;
_webRequest.GetRequestStream().Write(buffer, 0, buffer.Length);
}
private string GetResultAfterPostOrPatch()
{
string result = String.Empty;
var response = _webRequest.GetResponse();
result = (new StreamReader(response.GetResponseStream())).ReadToEnd();
_webRequest = null;
return result;
}
/// <summary>
/// Получение данных
/// </summary>
/// <returns></returns>
public string Get()
{
string result = String.Empty;
SetWebRequest(HttpVerb.GET);
using (HttpWebResponse response = (HttpWebResponse)_webRequest.GetResponse())
{
if (response.StatusCode == HttpStatusCode.OK)
{
result = GetStringResponse(response);
}
}
//если в базе нет данных в ответ приходит текст:"null"
if (result == _EMPTY_ANSWER_FIREBASE)
{
result = String.Empty;
}
_webRequest = null;
return result;
}
private string GetStringResponse(HttpWebResponse response)
{
using (Stream responseStream = response.GetResponseStream())
{
if (responseStream == null) return String.Empty;
using (StreamReader reader = new StreamReader(responseStream, Encoding.UTF8))
{
return reader.ReadToEnd();
}
}
}
/// <summary>
/// Удаление данных
/// </summary>
public void Remove()
{
SetWebRequest(HttpVerb.DELETE);
var response = _webRequest.GetResponse();
_webRequest = null;
}
}
Установите нугет пакет Newtonsoft.Json
в нашу библиотеку, напишем класс для отправки сообщений
public class SenderService
{
private readonly FirebaseClient _service;
//ctor
public SenderService(FirebaseClient service)
{
_service = service ?? throw new ArgumentNullException(nameof(service));
}
public string SendPackage(Package package)
{
if (package == null) throw new ArgumentNullException(nameof(package));
string json = Newtonsoft.Json.JsonConvert.SerializeObject(package);
return _service.Insert(json);
}
public string UpdatePackage(Package package)
{
if (package == null) throw new ArgumentNullException(nameof(package));
string json = Newtonsoft.Json.JsonConvert.SerializeObject(package);
return _service.Update(json);
}
}
А это класс для получения сообщений
public class ReceiverService
{
private readonly FirebaseClient _service;
//ctor
public ReceiverService(FirebaseClient service)
{
_service = service ?? throw new ArgumentNullException(nameof(service));
}
public IEnumerable<Package> ReceivePackage()
{
List<Package> result = new List<Package>();
string answer = _service.Get();
if (String.IsNullOrEmpty(answer)) return result;
//парсинг ответа
JObject jObject = JObject.Parse(answer);
var children = jObject.Children().ToArray();
foreach (var token in children)
{
var package = token.Children()
.First()
.ToObject<Package>();
result.Add(package);
}
return result;
}
}
2) Приложение для отправки сообщений
Я написал WPF, приведу только ViewModel
public class MainViewModel : INotifyPropertyChanged
{
public event PropertyChangedEventHandler PropertyChanged;
/// <summary>
/// Внимание! Этот адрес через пару дней я удалю.
/// Создайте свой собственный с правилами:
/// {
/// "rules": {
/// ".read": true,
/// ".write": true
/// }
/// }
/// И не забудьте в конце адреса дописать .json
/// </summary>
private readonly string _firebase = "https://testtodo-8d83d.firebaseio.com/.json";
private int _sendIndex = 1;
//ctor
public MainViewModel()
{
}
private string _InputText = "Сообщение";
public string InputText
{
get { return _InputText; }
set
{
_InputText = value;
PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(nameof(InputText)));
}
}
private string _OutputText;
public string OutputText
{
get { return _OutputText; }
set
{
_OutputText = value;
PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(nameof(OutputText)));
}
}
private bool _IsIndexed = true;
public bool IsIndexed
{
get { return _IsIndexed; }
set
{
_IsIndexed = value;
PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(nameof(IsIndexed)));
}
}
public void SendOnePackage()
{
if (String.IsNullOrEmpty(InputText))
{
OutputText = "Невозможно отправить пустое сообщение";
return;
}
if (IsIndexed)
{
var chars = InputText.ToCharArray()
.Where(c => !char.IsDigit(c))
.ToArray();
InputText = new string(chars) + _sendIndex.ToString();
_sendIndex++;
}
Package package = new Package { Content = InputText };
SenderService service = new SenderService(new FirebaseClient(_firebase));
var answer = service.SendPackage(package);
answer = answer.Substring(9, answer.Length - 11);
OutputText = $"Получен и сохранен с именем: {answer}";
}
}
3) Приложение получатель
Тоже только ViewModel
public class MainViewModel : INotifyPropertyChanged
{
public event PropertyChangedEventHandler PropertyChanged;
/// <summary>
/// Внимание! Этот адрес через пару дней я удалю.
/// Создайте свой собственный с правилами:
/// {
/// "rules": {
/// ".read": true,
/// ".write": true
/// }
/// }
/// И не забудьте в конце адреса дописать .json
/// </summary>
private readonly string _firebase = "https://testtodo-8d83d.firebaseio.com/.json";
private readonly IMainWindow _mainWindow;
private volatile bool _shouldHearing;
private SynchronizationContext _context = SynchronizationContext.Current;
private HashSet<Package> _hashSet;
private int _countElements;
//ctor
public MainViewModel(IMainWindow mainWindow)
{
_mainWindow = mainWindow ?? throw new ArgumentNullException(nameof(mainWindow));
}
private ObservableCollection<Package> _Messages;
public ObservableCollection<Package> Messages
{
get { return _Messages; }
set
{
_Messages = value;
PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(nameof(Messages)));
}
}
/// <summary>
/// Начать слушать
/// </summary>
public void DoHear()
{
_shouldHearing = true;
_hashSet = new HashSet<Package>();
_countElements = 0;
Task.Run(() => Hearing());
}
private void Hearing()
{
while (_shouldHearing)
{
var service = new ReceiverService(new FirebaseClient(_firebase));
IEnumerable<Package> packages = service.ReceivePackage();
if (packages.Count() == 0) continue;
_context.Post(delegate { AddPackages(packages); }, null);
}
}
private void AddPackages(IEnumerable<Package> packages)
{
foreach (var package in packages)
{
_hashSet.Add(package);
}
if (_countElements < _hashSet.Count)
{
Messages = new ObservableCollection<Package>(_hashSet);
_countElements = _hashSet.Count;
}
}
/// <summary>
/// Остановка
/// </summary>
public void StopHearing()
{
_shouldHearing = false;
if (Messages?.Count > 0)
{
_mainWindow.ChangeStateControls(StateControls.MessagesExists);
}
else
{
_mainWindow.ChangeStateControls(StateControls.Startup);
}
}
/// <summary>
/// Удаление ранее отправленных
/// </summary>
public void RemovePackages()
{
if (Messages.Count == 0) return;
var client = new FirebaseClient(_firebase);
client.Remove();
Messages.Clear();
_mainWindow.ChangeStateControls(StateControls.Startup);
}
}
Весь пример лежит здесь.