Основу пользовательского интерфейса составляет главное окно клиентского приложения. Его вид представлен на рисунке 3.1.

Рисунок 3.1. Главное окно клиентского приложения

В центре главного окна располагается список пользователей, подключенных к конференции.

Вверху располагается меню. Вкладка «Конференция» имеет подпункты «Подключение», «Отключение» и «Выход». (см. Рисунок 3.2.).

Рисунок 3.2. Меню «Файл»

При нажатии на пункт «Подключение» появляется диалоговое окно «Подключение» (см. рисунок 3.3.), с помощью которого можно осуществить подключение к серверу. В этом диалоговом окне расположены поле для ввода имени компьютера, на котором располагается сервер, поля для ввода логина и пароля пользователя.

Рисунок 3.3. Диалоговое окно «Подключение»

Интерфейс серверного приложения крайне прост. Его вид представлен на рисунке 3.4.

Рисунок 3.4. Интерфейс серверного приложения

В центре окна располагаются поля выбора IP сервера из имеющихся (получаемых программно) и для ввода пароля для входа на сервер. Меню «Сервер» имеет подпункты «Включить», «Отключить» и «Выход» (см. Рисунок 3.5).

Рисунок 3.5. Меню «Файл»

3.5 Результаты тестирования разработанного средства

В результате выполнения курсового проекта был разработан протокол для реализации задачи аудиосвязи по локальной сети, а так же программный комплекс, реализующий его.

Программный комплекс состоит из:

1. Клиентского приложения;

2. Серверного приложения.

В ходе разработки данного программного комплекса были выполнены следующие требования:

1. Разработка протокола высокого уровня для организации взаимодействия клиент-сервер;

2. Разработка пользовательского интерфейса;

3. Организация аудиосвязи между клиентами.

Разработанный программный комплекс удовлетворяет всем требованиям, выдвинутым в техническом задании. Однако он обладает некоторыми недостстками. Например, остутствие связи один ко многим и многие ко многим.

Приложения

Клиент:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Windows.Forms;

namespace Client

{

public delegate void NeedListRedraw();

public delegate void EmptyHandler();

class Client

{

frmClient form;

String nickName;

String password;

Socket socket;

Thread mainThread;

public String connectedUser = "";

public List<String> connectedUsers;

AudioTransceiver audiotransceiver;

bool isTransfering;

public Client(String _nickName, String _password, frmClient _form)

{

nickName = _nickName;

password = _password;

form = _form;

socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream,

ProtocolType.Tcp);

connectedUsers = new List<string>();

}

public String GetUserName()

{

return nickName;

}

public void Connect(String hostName)

{

//Подключаемся к серверу

socket.Connect(hostName, 11000);

int port = ((IPEndPoint)socket.LocalEndPoint).Port - 1000;

IPAddress ipAddress = ((IPEndPoint)socket.LocalEndPoint).Address;

audiotransceiver = new AudioTransceiver(ipAddress, port);

byte messageType = (byte)Messages.AuthorizationRequest;

SocketWriter.WriteType(socket, (byte)messageType);

SocketWriter.WriteString(socket, password);

User userToWrite = new User(nickName, new IPEndPoint(ipAddress, 11100));

SocketWriter.WriteUserRecord(socket, userToWrite);

audiotransceiver.AudioEndHandler = new EmptyHandler(AudioEnd);

mainThread = new Thread(MainThread);

mainThread.IsBackground = true;

mainThread.Start();

}

void AudioEnd()

{

}

public void Stop()

{

try

{

SocketWriter.WriteType(socket, (byte)Messages.IQuit);

socket.Disconnect(false);

if (audiotransceiver != null)

audiotransceiver.Dispose();

mainThread.Abort();

}

catch { }

}

void MainThread()

{

try

{

while (true)

{

byte messageType = SocketReader.ReadType(socket);

switch (messageType)

{

case (byte)Messages.AuthorizationFailed:

{

messageType = SocketReader.ReadType(socket);

if (messageType == (byte)Messages.WrongPassword)

{

MessageBox.Show("Неверный пароль");

form.Invoke(form.disconnect);

}

else if (messageType == (byte)Messages.WrongName)

{

MessageBox.Show("Пользователь с таким именем уже есть

в сети");

form.Invoke(form.disconnect);

}

break;

}

case (byte)Messages.AuthorizationSuccess:

{

int userNum = SocketReader.ReadInt(socket);

for (int i = 0; i < userNum; i++)

{

connectedUsers.Add(SocketReader.ReadString(socket));

}

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.ClientConnected:

{

NewClientConnected();

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.ClientDisconnected:

{

ClientDisconnected();

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.ConnectToClientRequest:

{

ConnectToClientRequest();

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.ConnectToClientSuccess:

{

ConnectToClientSuccess();

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.ConnectToClientFailed:

{

ConnectToClientFailed();

form.Invoke(form.redrawList);

break;

}

case (byte)Messages.DisconnectRequest:

{

connectedUser = "";

form.Invoke(form.redrawList);

DisconnectAudio();

break;

}

case (byte)Messages.ServerClose:

{

MessageBox.Show("Сервер отключен. Соединение прервано.");

DisconnectAudio();

form.Invoke(form.disconnect);

return;

}

catch (ThreadAbortException e)

{

catch (Exception e)

{

MessageBox.Show("Соединение будет закрыто." + e.Message);

Stop();

}

void ConnectToClientRequest()

{

User requestingUser = SocketReader.ReadUserRecord(socket);

if (MessageBox.Show("Пользователь " + requestingUser.nickName + " хочет осуществить подключение к вам. Одобрить подключение?", "Запрос на подключение", MessageBoxButtons.YesNo) == DialogResult.Yes)

{

SocketWriter.WriteType(socket, (byte)Messages.ConnectToClientSuccess);

SocketWriter.WriteUserRecord(socket, requestingUser.nickName,

audiotransceiver.GetEndPoint().Address.ToString(),

audiotransceiver.GetEndPoint().Port);

connectedUser = requestingUser.nickName;

audiotransceiver.Connect(requestingUser.ipEndPoint);

audiotransceiver.BeginTransceiving();

}

else

{

SocketWriter.WriteType(socket, (byte)Messages.ConnectToClientFailed);

SocketWriter.WriteString(socket, requestingUser.nickName);

}

}

void ConnectToClientSuccess()

{

User user = SocketReader.ReadUserRecord(socket);

audiotransceiver.Connect(user.ipEndPoint);

audiotransceiver.BeginTransceiving();

connectedUser = user.nickName;

}

void ConnectToClientFailed()

{

MessageBox.Show("Пользователь отверг подключение");

}

public void DisconnectAudio()

{

try

{

if (audiotransceiver != null)

{

audiotransceiver.EndTransceiving();

//audiotransceiver.Dispose();

}

}

catch

{

}

// }

}

void NewClientConnected()

{

User user = SocketReader.ReadUserRecord(socket);

connectedUsers.Add(user.nickName);

form.Invoke(form.redrawList);

}

void ClientDisconnected()

{

//Читаем имя отсоединившегося пользователя

String name = SocketReader.ReadString(socket);

//Удаляем его из списка

connectedUsers.Remove(name);

}

public void SendConnectRequest(String userName)

{

SocketWriter.WriteType(socket, (byte)Messages.ConnectToClientRequest);

SocketWriter.WriteUserRecord(socket, userName,

audiotransceiver.GetEndPoint().Address.ToString(), audiotransceiver.GetEndPoint().Port);

}

public void SendDisconnectRequest(String userName)

{

SocketWriter.WriteType(socket, (byte)Messages.DisconnectRequest);

SocketWriter.WriteString(socket, userName);

//EndTranslation1();

}

public void EndTranslation1()

{

connectedUser = "";

}

}

}

Сервер:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Windows.Forms;

namespace Server

{

class Server

{

private Socket socket;

private IPAddress ipAddress;

private int port;

private Thread mainThread;

private LogWriter logWriter;

private List<User> users;

private List<Connection> connections;

private string password;

public Server(String _ipAddress, int _port, String _logFileName, String _password)

{

ipAddress = IPAddress.Parse(_ipAddress);

port = _port;

logWriter = new LogWriter(_logFileName);

users = new List<User>();

connections = new List<Connection>();

password = _password;

}

public void Start()

{

//Устанавливаем локальную конечную точку

IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, port);

//Создаем сокет, привязываем его к конечной точке и начинаем прослушивание

socket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

socket.Bind(ipEndPoint);

socket.Listen(10);

//Создаем поток для приема соединений от клиентов

mainThread = new Thread(MainThread);

mainThread.IsBackground = true;

mainThread.Start();

// сообщаем об этом логу

logWriter.WriteToLogFile("Сервер запущен. IP-адрес: " + ipAddress.ToString() +

" Порт: " + port.ToString());

}

public void Stop()

{

//Посылаем всем сообщения что сервер остановлен

foreach (Connection connection in connections)

SendMessage(connection, Messages.ServerClose);

//Удаляем соединения

connections.Clear();

//Закрываем сокет, завершаем поток

socket.Close();

mainThread.Abort();

// пишем об этом в лог

logWriter.WriteToLogFile("Сервер остановлен");

}

private void MainThread()

{

try

{

while (true)

{

//Ждем соединения

Socket connectionSocket = socket.Accept();

//Принимаем соединение

Connection connection = new Connection();

connection.socket = connectionSocket;

logWriter.WriteToLogFile("Новое соединение. " +

connectionSocket.RemoteEndPoint.ToString());

//Создаем поток соединения

connection.thread = new Thread(ConnectionThread);

connection.thread.IsBackground = true;

connection.thread.Start(connection);

//Добавляем соединение в список

connections.Add(connection);

}

}

catch (ThreadAbortException e)

{

}

catch (Exception e)

{

Stop();

}

}

private void ConnectionThread(object param)

{

//Параметр в поток - объект соединения

Connection connection = (Connection)param;

try

{

while (true)

{

//Читаем тип сообщения

byte messageType = SocketReader.ReadType(connection.socket);

//Делаем что требуют

switch (messageType)

{

case (byte)Messages.AuthorizationRequest:

{

if(!Authorization(connection))

return;

break;

}

case (byte)Messages.ConnectToClientRequest:

{

ConnectToClientRequest(connection);

break;

}

case (byte)Messages.ConnectToClientSuccess:

{

ConnectToClientSuccess(connection);

break;

}

case (byte)Messages.ConnectToClientFailed:

{

ConnectToClientFailed(connection);

break;

}

case (byte)Messages.DisconnectRequest:

{

DisconnectRequest(connection);

break;

}

case (byte)Messages.IQuit:

{

DisconnectUser(connection);

return;

}

catch (Exception e)

{

logWriter.WriteToLogFile("Исклчение: " + e.Message);

//MessageBox.Show("Exception: " + e.Message);

}

finally

{

//DisconnectUser(connection);

}

}

//Клиент хочет подключиться

private void ConnectToClientRequest(Connection connection)

{

User requestedUser = SocketReader.ReadUserRecord(connection.socket);

logWriter.WriteToLogFile("Запрос на подключение от пользователя " +

connection.userNickName + " пользователю " + requestedUser.nickName);

foreach (Connection _connection in connections)

{

if (_connection.userNickName == requestedUser.nickName)

{

SendMessage(_connection, Messages.ConnectToClientRequest);

//SocketWriter.WriteString(_connection.socket,

connection.userNickName);

SocketWriter.WriteUserRecord(_connection.socket,

connection.userNickName,

requestedUser.ipEndPoint.Address.ToString(),

requestedUser.ipEndPoint.Port);

return;

}

//Клиент одобрил подключение

private void ConnectToClientSuccess(Connection connection)

{

User requestingUser = SocketReader.ReadUserRecord(connection.socket);

foreach (Connection _connection in connections)

{

if (_connection.userNickName == requestingUser.nickName)

{

SendMessage(_connection, Messages.ConnectToClientSuccess);

SocketWriter.WriteUserRecord(_connection.socket,

connection.userNickName,

requestingUser.ipEndPoint.Address.ToString(),

requestingUser.ipEndPoint.Port);

return;

}

//Клиент не одобрил подключение

private void ConnectToClientFailed(Connection connection)

{

String requestingUser = SocketReader.ReadString(connection.socket);

foreach (Connection _connection in connections)

{

if (_connection.userNickName == requestingUser)

{

SendMessage(_connection, Messages.ConnectToClientFailed);

return;

}

private void DisconnectRequest(Connection connection)

{

String requestingUser = SocketReader.ReadString(connection.socket);

logWriter.WriteToLogFile("Запрос на отключение от пользователя " +

connection.userNickName + " пользователю " + requestingUser);

foreach (Connection _connection in connections)

{

if (_connection.userNickName == requestingUser || _connection.userNickName

== connection.userNickName)

{

SendMessage(_connection, Messages.DisconnectRequest);

//return;

}

//Клиент прислал запрос авторизации

private bool Authorization(Connection connection)

{

String userPassword = SocketReader.ReadString(connection.socket);

User user = SocketReader.ReadUserRecord(connection.socket);

logWriter.WriteToLogFile("Авторизация пользователя " + user.nickName);

//Проверяем пароль

if (userPassword != password)

{

SendMessage(connection, Messages.AuthorizationFailed);

SendMessage(connection, Messages.WrongPassword);

logWriter.WriteToLogFile("Авторизация пользователя " + user.nickName + "

неуспешна. Неправильный пароль.");

connections.Remove(connection);

return false;

}

//Проверяем на наличие такого имени

foreach (User _user in users)

{

if (_user.nickName == user.nickName)

{

SendMessage(connection, Messages.AuthorizationFailed);

SendMessage(connection, Messages.WrongName);

logWriter.WriteToLogFile("Авторизация пользователя " + user.nickName +

" неуспешна. Неправильное имя пользователя.");

connections.Remove(connection);

return false;

}

//Если все удачно, добавляем пользователя

users.Add(user);

SendMessage(connection, Messages.AuthorizationSuccess);

logWriter.WriteToLogFile("Авторизация пользователя " + user.nickName + "

прошла успешно");

connection.userNickName = user.nickName;

//Передаем список имен

SocketWriter.WriteInt(connection.socket, connections.Count);

foreach (Connection _connection in connections)

{

SocketWriter.WriteString(connection.socket, _connection.userNickName);

}

//Посылаем всем пользовтелям сообщение об авторизации нового пользователя

foreach (Connection _connection in connections)

{

if (connection != _connection)

{

SendMessage(_connection, Messages.ClientConnected);

SocketWriter.WriteUserRecord(_connection.socket, user);

}

return true;

}

//Отключение пользователя

private void DisconnectUser(Connection connection)

{

//Удаляем пользователя из списка

foreach (User user in users)

{

if (connection.userNickName == user.nickName)

{

users.Remove(user);

logWriter.WriteToLogFile("Пользователь " + connection.userNickName + "

отключился");

break;

}

//Всем пользователям отправляем сообщение об отключении пользователя

foreach (Connection _connection in connections)

{

if (_connection != connection)

{

SendMessage(_connection, Messages.ClientDisconnected);

SocketWriter.WriteString(_connection.socket, connection.userNickName);

}

//connection.socket.Shutdown(SocketShutdown.Both);

connection.socket.Close();

connections.Remove(connection);

}

private void SendMessage(Connection connection, Messages messageType)

{

SocketWriter.WriteType(connection.socket, (byte)messageType);

}

Размещено на Allbest.ru