Dotaz do mysql – PHP – Fórum – Programujte.com

Dobrý den,
mám takový dotaz, na který si nedokážu odpovědět a rád bych se poradil s vyšší kapacitou.

Aplikace se skládá ze tří částí.

První část -> seznam (tabulka) "výzev" a jquery sahá do Mysql každých 5 sekund, aby seznam byl pořád aktuální.

Druhá čast -> Vkládání nových "výzev".

Třetí část -> Otevírá "výzvu" ze seznamu na opravení určitých informací, jenomže zde je Jquery, které hlídá každou změnu a následně posílá znovu do Mysql.

Otázka zní -> Můžu takhle řešit neustále ukládání do mysql ? I když tuhle aplikaci bude používat například čtyři uživatelé najednou ?

Moc děkuji za každý názor či poznatek

#1 Ellke
Použít to můžeš, databáze se přitom zřejmě bude nudit. Ovšem to opakované dotazování každých 5 sekund dobré není. Zkus se podívat, jak funguje WebSocket. Zjednodušeně ti server pošle zprávu, až když se na něm něco změní. Šetří to přenosovou kapacitu a přitom je reakce na změnu téměř okamžitá.

Moc děkuji za odpověď       

rychle jsem se na to mrkl, a takže takhlem se to třeba používá u chatů ?

Nějak se tím proplétám, ale moc tomu nerozumím jak přesně to funguje   

#3 Ellke
Přesně tohle se používá v chatech hlavně kvůli té svižnosti. Prostě si z Javascriptu otevřeš komunikační kanál se serverem, objednáš si typ dat, které chceš sledovat (vzor Observer). Když na serveru dojde ke změně, tak si projde seznam abonentů a tu změnu jim rozešle. Javascript na klientovi to zachytí a zobrazí na stránce. Běží to prakticky v reálném čase, hrají se přes to i MMORPG.

Děkuji moc, určitě to použiji a pokud by to nevadilo tak sem potom hodím i hotový script.

Všechny weby a fora, která jsem nějak prošel mě nasměrovali na tuhle stránku:

http://socketo.me/docs/install

Já jsem to pochopil špatně ja myslel že xampp tuhle funkci už vlastní což jsem se asi zpletl že?

#7 Ellke
Ratchet je jen jedna z možných nadstaveb.

Co je to xampp? :-) Pronajmi si server.

xampp -> https://www.apachefriends.org/index.html

#9 Ellke
Zatím jsem to nezkoušel. Zřejmě v tom bude Apache, PHP a MySQL.

Ano přesně tak

#11 Ellke
Apache je tam vcelku zbytečný, PHP se dá spustit i jako server. Mívám jich takto spuštěných třeba i pět současně.

Můžeš mě trochu zasvětit? Odkázat na nějakou stránku jak spustit php jako server ?

#13 Ellke
Udělej si zástupce, do kterého v kolonce "Cíl" napíšeš: 

C:\PHP\php.exe -S localhost:8080 -t C:\project\www

Do kolonky "Spustit v" dáš:

C:\PHP

Když na to klikneš, tak se ten PHP server spustí v adresáři C:\project\www\.

Do prohlížeče zadáš adresu http://localhost:8080

Je to popsáno v dokumentaci PHP, ale kdo by ji četl, že...

Velkou výhodou tohoto řešení je, že se ti chyby zobrazují přímo v tom okně terminálu. Najdeš tam třeba i status 404 na favicon.ico apod.

Moc děkujííííí,

rozběhl jsem to, skvělé je na tom to, že člověk má plnou kontrolu což je parádní.

Trochu, hodně se v tom strácím. Nikdy jsem nevěděl, že to php jde spustit takhle jednoduše.

Trochu se vrátím k tomu Websocetu.

Nechce se mi moc používat nějaká nadstavba, nebo nemám na výběr? 

Pročítal jsem tuhle stránku: http://php.net/manual/en/book.sockets.php

Ale skoro vubec tomu nerozumím.

Myslel jsem si že to budou nějaké jednoduché syntaxe.

Na youtube používají ještě socet.io ale to je také nadstavba.

Děkuji, že se mnou máš takovou trpělivost 

http://php.net/manual/en/sockets.examples.php

Server pro socket funguje tak,
- nastavis si php ne konenecny time_limit
- vytvoris si server (pripojis ho na port a tak) a pripojis na nej socket (jakoze hlavni socket - server pro uzivatele)
- vytvoris si nekonecnou smycku, ve ktere poslouchas, co se deje na socketech, a) hlavnim (1), b) ostatnich (0)
- pokud prijde neco na hlavni, zjistis, co to je. Pokud je to zadost o pripojeni, ta spustis vyvoreni dalsiho socket a odesles na novy socket handshake. Pokud to druha strana potvrdi, tak nechas socket otevreny. Pokud nee, socket odpojis a smazes ze seznamu ostatnich )
- a pak proveris vsechny otevrene sockety, zda jeste reaguji (druha strana je drzi otevrene) a kdyz ne, zavres je.
- a nebo z nich prectes message

Pri testovani si nastav limit jen tak na 5s.
Pokud server neukoncis, je nutne pak uplne vypnout php. Jinak ti bude blokovat na pc port, na kterem jsi server spustil. Je to takove hodne neprijemne, kdyz nevis, proc ti php odmita spustit stejny program, ktery jeste pred chvili bez problem spustil :)

Je to trochu veda. Bohuzel nemam nikde jednoduchy kod. Mam uz do nej primichane vselijake slozitosti pro lepsi ovladani, ukoncovani serveru a tak.

Asi nejlepe pouzitelny by mohl byt ten posl. example
http://php.net/…examples.php
-97 / Anonymous / 4 years ago
Aby bylo jasne, tak to odesial obecnou message. Ta byva typu ping, connect, disconnect, text (handshake, reply-handshake, text). Jako text si pak muzes odesilat zpravicky typu "tonda->all Ahoj". Anebo pouzit json a posilat slozitejsi konstrukce. Neresi to uzivatele, to musis resit dalsim systemem. Tohle prijme obecne zpravu. Neco jako na poste, spadne to do krabicky, tu krabicku si system preda pani postacce (dalsimu programu) a pani postatcka si precte adresy a teprve s tim neco dela. Ale to neni problem, zavolat dalsi sluzbu s logovanim uzivatelu, s databazi jmen a tak. Uzivatel ti jako text posle sve jmeno pri prihlaseni...
 

<?php

class MySocketServer
{
    protected $socket;
    protected $clients = [];
    protected $changed;
   
    function __construct($host = 'localhost', $port = 9000)
    {
        set_time_limit(0);
        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);

        //bind socket to specified host
        socket_bind($socket, 0, $port);
        //listen to port
        socket_listen($socket);
        $this->socket = $socket;
    }
   
    function __destruct()
    {
        foreach($this->clients as $client) {
            socket_close($client);
        }
        socket_close($this->socket);
    }
   
    function run()
    {
        while(true) {
            $this->waitForChange();
            $this->checkNewClients();
            $this->checkMessageRecieved();
            $this->checkDisconnect();
        }
    }
   
    function checkDisconnect()
    {
        foreach ($this->changed as $changed_socket) {
            $buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
            if ($buf !== false) { // check disconnected client
                continue;
            }
            // remove client for $clients array
            $found_socket = array_search($changed_socket, $this->clients);
            socket_getpeername($changed_socket, $ip);
            unset($this->clients[$found_socket]);
            $response = 'client ' . $ip . ' has disconnected';
            $this->sendMessage($response);
        }
    }
   
    function checkMessageRecieved()
    {
        foreach ($this->changed as $key => $socket) {
            $buffer = null;
            while(socket_recv($socket, $buffer, 1024, 0) >= 1) {
                $this->sendMessage(trim($buffer) . PHP_EOL);
                unset($this->changed[$key]);
                break;
            }
        }
    }
   
    function waitForChange()
    {
        //reset changed
        $this->changed = array_merge([$this->socket], $this->clients);
        //variable call time pass by reference req of socket_select
        $null = null;
        //this next part is blocking so that we dont run away with cpu
        socket_select($this->changed, $null, $null, null);
    }
   
    function checkNewClients()
    {
        if (!in_array($this->socket, $this->changed)) {
            return; //no new clients
        }
        $socket_new = socket_accept($this->socket); //accept new socket
        $first_line = socket_read($socket_new, 1024);
        $this->sendMessage('a new client has connected' . PHP_EOL);
        $this->sendMessage('the new client says ' . trim($first_line) . PHP_EOL);
        $this->clients[] = $socket_new;
        unset($this->changed[0]);
    }
   
   
    function sendMessage($msg)
    {
        foreach($this->clients as $client)
        {
            @socket_write($client,$msg,strlen($msg));
        }
        return true;
    }
}

(new MySocketServer())->run();
?>

Tak tohle bude ještě zajimavé. Moc děkuji za informace a teď mi už nezbývá než jenom zkoušet   

 

Moc děkuji nakonec jsem Websocet vyřešil přes nadstavbu Ratchet.

<?php
set_time_limit(0);

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
require_once 'D:\project\code\www\vendor\autoload.php';

class Chat implements MessageComponentInterface {
	protected $clients;
	protected $users;

	public function __construct() {
		$this->clients = new \SplObjectStorage;
	}

	public function onOpen(ConnectionInterface $conn) {
		$this->clients->attach($conn);
		// $this->users[$conn->resourceId] = $conn;
	}

	public function onClose(ConnectionInterface $conn) {
		$this->clients->detach($conn);
		// unset($this->users[$conn->resourceId]);
	}

	public function onMessage(ConnectionInterface $from,  $data) {
		$data = json_decode($data);
		$type = $data->type;
		switch ($type) {
			case 'refresh':
				
				$response_from = "<span style='color:#999'><b>zkouksa:</b> odpoved </span><br><br>";
			
				// Output
				$from->send(json_encode(array("type"=>$type,"msg"=>$response_from)));
				foreach($this->clients as $client)
				{
					if($from!=$client)
					{
						$client->send(json_encode(array("type"=>$type)));
					}
				}
				break;
		}
	}

	public function onError(ConnectionInterface $conn, \Exception $e) {
		$conn->close();
	}
}
$server = IoServer::factory(
	new HttpServer(new WsServer(new Chat())),
	1024
);
$server->run();
?>

 Proměná $response_from je tam vlastně už k ničemu, použival jsem to jako chat abych to celkově pochopil.

$response_from = "<span style='color:#999'><b>zkouksa:</b> odpoved </span><br><br>";

A client

<textarea id="chat_input" placeholder="Deine Nachricht..."></textarea>
		<script type="text/javascript">
		jQuery(function($){
			// Websocket
			var websocket_server = new WebSocket("ws:\\localhost:1024/");
			websocket_server.onopen = function(e) {
				websocket_server.send(
					JSON.stringify({
						'type':'socket',
						'user_id':<?php echo $session; ?>
					})
				);
			};
			websocket_server.onerror = function(e) {
				// Errorhandling
			}
			websocket_server.onmessage = function(e)
			{
				var json = JSON.parse(e.data);
				switch(json.type) {
					case 'refresh':
						alert("Hello! I am an alert box!");
						break;
				}
			}
			// Events
			$('#chat_input').on('keyup',function(e){
				if(e.keyCode==13 && !e.shiftKey)
				{
					var chat_msg = $(this).val();
					websocket_server.send(
						JSON.stringify({
							'type':'refresh',
							'user_id':<?php echo $session; ?>,
							'chat_msg':chat_msg
						})
					);
					$(this).val('');
				}
			});
		});
		</script>

ale nemám to dořešené pořádně. Ale jsem nadšený že to funguje. 

Děkuji za všechny rady, které jsem tu dostal ten php server je parádní.

Potom jsem se tu přiučil používat https://www.mysql.com/ , ale to bylo vcelku jednoduché.

Měl bych ještě jednu otázku.

PHP jak štak zvládám, ale když bych vzal tuhle aplikaci a udělal jí v c# nebude to lepší než přes webový prohlížeč ?