Пояснительная записка (1231620), страница 6

Просмтор этого файла доступен только зарегистрированным пользователям. Но у нас супер быстрая регистрация: достаточно только электронной почты!

Текст из файла (страница 6)

}

s=AES.decrypt(readFile.readLine(),"coding");

}

readFile.close();

}

catch(IOException ex){

if(ex.getMessage().contains("Не удается найти указанный

файл")){

send.sendSingleRequest("$toServer$ 201");

}

}

Из кода видно, что файл, содержащий текст переписки, закодирован при помощи алгоритма AES.

AES (Advanced Encryption Standard) – симметричный алгоритм блочного шифрования, принятый в качестве стандарта шифрования правительством США. Алгоритм является надёжным, чтобы использовать его для защиты сведений, составляющих государственную тайну [40].

Рисунок 17 – Чат между сотрудниками

При нажатии на кнопку «Отправить» сообщение, набранное в текстовом поле, отправляется на сервер в следующем порядке:

– отправка на сервер кода «$toID$ id», где id – ID номер клиента, которому предназначается сообщение;

– отправка текста сообщения;

– отправка кода «$end$», который сигнализирует серверу о том, что сообщения закончены.

Код данных действий представлен ниже:

public void sendMassege(int id, String text){

out.println("$toID$ "+id);

out.println(text);

out.println("$end$");

}

Клиентское приложение постоянно прослушивает поток с данными от сервера, и при поступлении кодового значения «$fromID$» считывает значения ID пользователя, от которого пришло сообщение, а также последовательность строк с отправленными сервером данными. При получении финального кода «$end$», сообщение сохраняется в общий список, а приложение сигнализирует соответствующей иконкой пользователю, о том, что поступили новые данные (рисунок 18).

Рисунок 18 – Реакция приложения на новое сообщение

Процедура общения с клиентами компании организуется вышесказанным образом, за исключением того, что данные переписки с клиентами, не хранятся на сервера, а постоянно загружаются с сервера. Чат с клиентами показан на рисунке 19.

Код добавления входящего сообщения от клиента компании представлен ниже:

try{

String input;

while ((input=in.readLine())!=null){

System.out.println(input);

switch(input){

case "$fromClientID$":{

int from=Integer.parseInt(in.readLine());

String what = "";

while (!(input = in.readLine()).equals("$end$")){

what+=input+"\r\n";

}

what=what.substring(0, what.length()-2);

GUI.MainFrames.AddClientMassege(what, from, false);

GUI.MainFrames.UpdateStatMessages(from, 1);

break;

}

default: System.out.println(input); break;

}

}

System.out.println("close");

} catch(Exception e){

e1.printStackTrace();

}

}

Рисунок 19 – Чат с клиентами компании

Далее будет реализация модуля сайта.

4.2 Реализация модуля для сайта

Для решения главной задачи ВКР – написания приложения «Онлайн-консультант», не обойтись без универсального Web-модуля, через которое будет осуществляться обмен сообщениями между консультантом и гостем сайта.

Модуль для сайта представлен на рисунке 20.

Рисунок 20 – Web-модуль онлайн-консультанта

Модуль состоит из надписи, содержащей имя консультанта, окна с текстом переписки, поля для ввода текста и кнопки отправить.

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

После нажатия на диалоговое облако, оно скрывается и вместо него появляется модуль. Web-модуль можно скрыть нажав на соответствующую клавишу слева от чата.

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

Реализация проводится на языке JavaScript и представлена ниже:

var socket;

window.onload = function() {

socket = new WebSocket("ws://192.168.1.141:5555");

socket.onmessage = get_massage;

};

function get_massage(event){

var str = event.data;

if(str.substring(0,15)=="&NameConsulter&"){

document.getElementById('cons_name').innerHTML=

str.substring(16);

} else if(str.substring(0,15)=="&PostConsulter&"){

document.getElementById('cons_post').innerHTML=

str.substring(16);

} else{

var outDiv = document.createElement('div');

outDiv.className = 'from';

outDiv.innerHTML = "<div></div><div>"+ str+"</div>";

document.getElementById('dialog').appendChild(outDiv);

}

};

function send_massage(){

var str = document.getElementById('massageToSend').value;

if(str!=""){

socket.send(str);

var outDiv = document.createElement('div');

outDiv.className = 'to';

outDiv.innerHTML = "<div></div><div>"+str+"</div>";

document.getElementById('dialog').appendChild(outDiv);

}

document.getElementById('massageToSend').value="";

};

Функции выполняют следующие действия:

– socket = new WebSocket("ws://192.168.1.141:5555"). Объявление переменной socket и создание подключения с сервером;

– socket.onmessage = get_massage. Функция в первую очередь обновляет информацию об имени консультанта и его должности, а также отображает поступление сообщений со стороны сервера;

– function send_massage(). Данная функция позволяет отправить произвольное сообщение серверу. Сообщение от пользователя поступает на сервер, а блок с перепиской обновляется. Также в этом блоке производится проверка на пустое сообщение, если такое присутствует, то данные не отправляются;

4.3 Реализация сервера приложения

Клиентское приложение и модуль для сайта не могут работать без ядра – серверного приложения.

Серверный модуль онлайн-консультанта запускается либо на web-сервере предприятия, который имеет статический IP адрес, который выделяется провайдером в глобальной сети интернет, либо на любом компьютере с предварительной переадресацией на его IP.

Серверная программа, как и клиентская, имеет разделение графического пользовательского интерфейса и основного потока выполнения и базу данных. Порядок работы программы следующий:

– запускается графическая оболочка программы (рисунок 21), которая представлена в виде значка в системном лотке операционной системы;

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

– создание сервера сокетного подключения с заранее предустановленным статическим IP адресом и номером порта;

– бесконечное ожидание подключения пользователей.

Рисунок 21 – Иконка активного сервера

База данных состоит из трех таблиц:

– таблица «users» (рисунок 22), содержащая ID, идентификатор, ФИО, должность и пароль сотрудника компании, его права доступа;

Рисунок 22 – Таблица «users»

– таблица «UsersMassages» (рисунок 23), содержащая чат сотрудников. Данная таблица содержит только дошедшие до пункта назначения сообщения;

Рисунок 23 – Таблица «UsersMassages»

– таблица «NotSend» (рисунок 24), содержащая недошедшие до своих адресатов сообщения, вследствие таких причин, как отсутствия в сети пользователя или обрыв соединения;

Рисунок 24 – Таблица «NotSend»

– таблица «ClientsMassages» (рисунок 25), содержащая чат операторов и клиентов;

Рисунок 25 – Таблица «ClientsMassages»

Сервер распознают два вида пользователей: клиентов сайта и пользовательские приложения. Это происходит благодаря тому, что при совершении соединения по технологии WebSocket, сервер получает от клиента набор заголовков, которые отсутствуют во время подключения приложения при помощи сокетов. Код программы можно увидеть ниже:

private static int readInputHeaders(Socket socket) throws

Throwable {

BufferedReader br = new BufferedReader(new

InputStreamReader(socket.getInputStream()));

int type = 0;

while(true) {

s = br.readLine();

System.out.println(s);

if(s.contains("Sec-WebSocket-Key")){

type=2;

s=s.split(":")[1].substring(1)+"258EAFA5-E914-47DA-95CA-

C5AB0DC85B11";

MessageDigest code = MessageDigest.getInstance("sha");

code.update(s.getBytes());

byte[] digest = code.digest();

s=Base64.encode(digest);

String response="HTTP/1.1 101 Switching Protocols\r\n" +

"Upgrade: websocket\r\n"+

"Connection: Upgrade\r\n"+

"Sec-WebSocket-Accept: "+s+"\r\n\r\n";

socket.getOutputStream().write(response.getBytes());

WebSocketConnection WebSocket=new

WebSocketConnection(socket);

} else if(s.contains("$desktopClient$"))

type=1;

if(s == null || s.trim().length() == 0) {

break;

}

}

return type;

}

Все соединения заносятся в два списка клиентов сервера соответственно их типу, кроме пользовательских приложений. Они попадают в массив, только после успешной процедуры авторизации на сервере.

Авторизация пользователя происходит следующим образом:

– на сервер от клиента приходит ключевое слово с кодом «$toServer$ 100», после которого приходит имя пользователя и пароль. При помощи SQL запроса совершается выборка данных по полям имя/пароль. Если результат запроса не пустой, то сервер отправляет клиенту информацию о том, что авторизация прошла успешно (код «$accept$»), и добавляет в массив клиентов, иначе отправляется сообщение об отклонении запроса на авторизацию (код «$notaccept$»). Код процедуры авторизации представлен ниже:

try{

String input;

while ((input = in.readLine())!=null) {

if(input.contains("$toServer$")){

switch (Integer.parseInt(input.split(" ")[1])){

case 100: {

sendAutorizeAnswer(in.readLine(),in.readLine());

break;

}

}

} else {

System.out.println(":"+input);

}

}

System.out.print("Closer\n");

in.close();

} catch(Exception e){

System.out.println("init error get1: "+e);

};

public void sendAutorizeAnswer(String log, String pass) throws

ClassNotFoundException, SQLException{

int id;

Характеристики

Список файлов ВКР