โค้ทอินิกเตอร์ – PlusMagi's Blog By Pitt Phunsanit

ERR_CONTENT_DECODING_FAILED

ไปเปิด option บีบอัดข้อมูลใน CodeIgniter

$config['compress_output'] = true;

หลังเปิดเว็บก็ดูปกติดี จนเกือบจะเลิกเทสไปละ จนมาเจอว่า javaScript ที่เคยใช้ได้ปกติกับมี error เปิดไฟล์ออกมาดูใน chrome มันขึ้น error

หน้าเว็บใน http://xxx อาจหยุดให้บริการชั่วคราวหรืออาจถูกย้ายไปยังที่อยู่เว็บใหม่อย่างถาวร
ERR_CONTENT_DECODING_FAILED
เจอว่าเกิดได้จากหลายสาเหตุมากแต่เพราะเพิ่งไปเปิด zlib มาเลยเน้นมันเป็นพิเศษ จนเจอว่าไปแก้ php.ini เปลี่ยน
zlib.output_compression = On
ก็แก้ได้แล้ว

เวลาเขียน program อะไรเล็กๆ น้อยๆ ก็ทำให้ระบบเปลี่ยนแปลงได้เสมอ

Fixing ERR_CONTENT_DECODING_FAILED in Apache+PHP

CodeIgniter: php-amqplib

ลองเขียน custom driver สำหรับติดต่อกับ RabbitMQ / AMQP ยังไม่สมบูรณ์แต่ก็ดีกว่าการที่ต้องมา connect ผ่าน php-amqplib ทุกครั้งที่จะใช้ตามปกติ

config file ก่อนตามระเบียบ

<?php
defined('BASEPATH') or exit('No direct script access allowed');

/*
| -------------------------------------------------------------------
| RABBITMQ CONNECTIVITY SETTINGS
| -------------------------------------------------------------------
| This file will contain the settings needed to access your RabbitMQ.
|
| For complete instructions please consult the 'RabbitMQ Connection'
| page of the User Guide.
|
| -------------------------------------------------------------------
| EXPLANATION OF VARIABLES
| -------------------------------------------------------------------
|
|    ['connection_timeout'] => 3.0,
|    ['context'] => null,
|    ['heartbeat'] => 0
|    ['host'],
|    ['insist'] => false,
|    ['keepalive'] => false,
|    ['locale'] => 'en_US',
|    ['login_method'] => 'AMQPLAIN',
|    ['login_response'] => null,
|    ['password'],
|    ['port'],
|    ['read_write_timeout'] => 3.0,
|    ['user'],
|    ['vhost'] => '/',
 */
$config['RabbitMQ']['connects'] = [
    'default' => [
        'connection_timeout' => 3.0,
        'context' => null,
        'heartbeat' => 0,
        'host' => '127.0.0.1',
        'insist' => false,
        'keepalive' => false,
        'locale' => 'en_US',
        'login_method' => 'AMQPLAIN',
        'login_response' => null,
        'password' => 'guest',
        'port' => 5672,
        'read_write_timeout' => 3.0,
        'user' => 'guest',
        'vhost' => '/',
    ],
];

/*
| -------------------------------------------------------------------
| RABBITMQ DEBUG SETTINGS
| -------------------------------------------------------------------
|
 */
$config['RabbitMQ']['debug'] = false;

ถึงคิวไฟล์ driver ที่จะเป็นตัวกลางระหว่าง codeigniter และ php-amqplib

<?php
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class RabbitMQ extends AMQPStreamConnection
{

    public function __construct($config = array())
    {
        $this->CI = &get_instance();

        $this->config = $config['RabbitMQ'];

        if ($this->config['debug'] == true) {
            define('AMQP_DEBUG', true);
        }
    }

    public function connect($dsnId = 'default') {
        $dsn = $this->config['connects'][$dsnId];

        $this->connection = new AMQPStreamConnection($dsn['host'], $dsn['port'], $dsn['user'], $dsn['password'], $dsn['vhost'], $dsn['insist'], $dsn['login_method'], $dsn['login_response'], $dsn['locale'], $dsn['connection_timeout'], $dsn['read_write_timeout'], $dsn['context'], $dsn['keepalive'], $dsn['heartbeat']);

        $this->channel = $this->connection->channel();
    }

    public function disconnect()
    {
        $this->channel->close();
        $this->connection->close();
    }

    public function setMessageJson($datas)
    {
        $msg_body = json_encode($datas);

        $properties = [
            'content_type' => 'application/json',
            'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,
        ];

        return new AMQPMessage($msg_body, $properties);
    }

}

ที่นี้ก็ controller ที่จะทำงานให้

<?php
defined('BASEPATH') or exit('No direct script access allowed');

class Messaging extends CI_Controller
{
    public function __construct()
    {
        parent::__construct();

        $this->load->driver('RabbitMQ');
    }

    public function receive()
    {
        set_time_limit(0);

        $this->rabbitmq->connect();

        $exchange_name = 'customers';
        $queue_name = 'invoices';

/**
 * Declares exchange
 *
 * @param string $exchange_name
 * @param string $type
 * @param bool $passive
 * @param bool $durable
 * @param bool $auto_delete
 * @param bool $internal
 * @param bool $nowait
 * @param array $arguments
 * @param int $ticket
 * @return mixed|null
 */
        $this->rabbitmq->channel->exchange_declare($exchange_name, 'fanout', false, true, false);

/**
 * Declares queue, creates if needed
 *
 * @param string $queue
 * @param bool $passive
 * @param bool $durable
 * @param bool $exclusive
 * @param bool $auto_delete
 * @param bool $nowait
 * @param array $arguments
 * @param int $ticket
 * @return mixed|null
 */
        list($queueName, $message_count, $consumer_count) = $this->rabbitmq->channel->queue_declare('', false, false, true, false);
        $this->rabbitmq->channel->queue_bind($queue_name, $exchange_name);

        $callback = function ($msg) {

            $datas = json_decode($msg->body, true);
            fwrite(fopen('RabbitMQReceive.txt', 'a+'), print_r($datas, true));

            sleep(substr_count($msg->body, '.'));

            /* delete message */
            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        };

/**
 * Starts a queue consumer
 *
 * @param string $queue_name
 * @param string $consumer_tag
 * @param bool $no_local
 * @param bool $no_ack
 * @param bool $exclusive
 * @param bool $nowait
 * @param callback|null $callback
 * @param int|null $ticket
 * @param array $arguments
 * @return mixed|string
 */
        $this->rabbitmq->channel->basic_consume($queue_name, '', false, false, false, false, $callback);

        while (count($this->rabbitmq->channel->callbacks)) {
/**
 * Wait for some expected AMQP methods and dispatch to them.
 * Unexpected methods are queued up for later calls to this PHP
 * method.
 *
 * @param array $allowed_methods
 * @param bool $non_blocking
 * @param int $timeout
 * @throws \PhpAmqpLib\Exception\AMQPOutOfBoundsException
 * @throws \PhpAmqpLib\Exception\AMQPRuntimeException
 * @return mixed
 */
            $this->rabbitmq->channel->wait();
        }

        $this->rabbitmq->channel->close();
        $connection->close();
    }

    public function send()
    {
        $this->rabbitmq->connect();

        $exchange_name = 'customers';
        $queue_name = 'invoices';

/**
 * Declares exchange
 *
 * @param string $exchange_name
 * @param string $type
 * @param bool $passive
 * @param bool $durable
 * @param bool $auto_delete
 * @param bool $internal
 * @param bool $nowait
 * @param array $arguments
 * @param int $ticket
 * @return mixed|null
 */
        $this->rabbitmq->channel->exchange_declare($exchange_name, 'fanout', false, true, false);

/**
 * Declares queue, creates if needed
 *
 * @param string $queue
 * @param bool $passive
 * @param bool $durable
 * @param bool $exclusive
 * @param bool $auto_delete
 * @param bool $nowait
 * @param array $arguments
 * @param int $ticket
 * @return mixed|null
 */
        list($queueName, $message_count, $consumer_count) = $this->rabbitmq->channel->queue_declare($queue_name, false, true, false, false);

        $datas = [
            'rand' => rand(0, 100),
            'time' => date('Y-m-d H:m:s'),
        ];

/**
 * Declares message
 *
 * @param array $datas
 * @return string
 */
        $msg = $this->rabbitmq->setMessageJson($datas);

/**
 * Publishes a message
 *
 * @param AMQPMessage $msg
 * @param string $exchange
 * @param string $routing_key
 * @param bool $mandatory
 * @param bool $immediate
 * @param int $ticket
 */
        $this->rabbitmq->channel->basic_publish($msg, $exchange_name, $queue_name);

        echo '<br><pre>' . print_r($datas, true), '</pre>';

        $this->rabbitmq->disconnect();

    }

}

ทดสอบโดยเรียก http://localhost/CodeIgniter-3.1.3/messaging/send และ http://localhost/CodeIgniter-3.1.3/messaging/receive

CodeIgniter: Composer

โดยปกติ composer จะเก็บไฟล์โดยสร้าง folder vendor ใน folder เดียวกับไฟล์ composer.json

ใน codeinigter ว่างไฟล์ composer.json ไว้นอกสุดแต่ในไฟล์ \application\config\config.php กลับเขียน

/*
  |--------------------------------------------------------------------------
  | Composer auto-loading
  |--------------------------------------------------------------------------
  |
  | Enabling this setting will tell CodeIgniter to look for a Composer
  | package auto-loader script in application/vendor/autoload.php.
  |
  |    $config['composer_autoload'] = TRUE;
  |
  | Or if you have your vendor/ directory located somewhere else, you
  | can opt to set a specific path as well:
  |
  |    $config['composer_autoload'] = '/path/to/vendor/autoload.php';
  |
  | For more information about Composer, please visit http://getcomposer.org/
  |
  | Note: This will NOT disable or override the CodeIgniter-specific
  |    autoloading (application/config/autoload.php)
  */

คือ พี่แกให้เก็บไฟล์ไว้ที่ application/vendor ไม่ใช่ /vendor

ปัญหานี้แก้ได้โดยเพิ่ม

{
  ...
  "config": {
  "vendor-dir": "application/vendor"
  },
  ...
}

หลังจากนั้นก็ไปเปิด auto-load โดยเปลี่ยน

$config['composer_autoload'] = false;

เป็น

$config['composer_autoload'] = true;

แล้วทดลองใช้ command

composer update

จะเห็นว่าไฟล์เข้าไปที่ application/vendor แล้ว

ถ้า composer โหลดไฟล์มาไม่ได้เพราะติด proxy อ่าน

อ่านเพิ่มเติม

CodeIgniter: แยก config

การดึงค่าคอนฟิกของโค้ทอินิกเตอร์สามารถทำได้โดย ใช้คำสั่ง

$this->config->item(' ตัวแปร ');

โดยจะดึงมาจากไฟล์ \application\config\config.php เป็นหลัก แต่ถ้าต้องการแยก config ออกมาเป็นส่วนๆ เพื่อความง่ายในการจัดการ สามารถสร้างไฟล์ ขึ้นมาใน application\config ได้

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

$config['caching']['adapter'] = 'memcached';
$config['caching']['backup']  = 'file';

จากนั้นเราจะอ่าน configuration เข้ามาในระบบของเราสามารถทำได้ 2 วิธีคือ

เป็นค่าที่เราต้องใช้บ่อยๆแทบทุกหน้า เพิ่มเข้าไปใน Auto-loading เปิดไฟล์ \application\config\autoload.php เพิ่มชื่อไฟล์ลงไปใน
```
$autoload['config']
```
เช่น
```
...
$autoload['config'] = ['caching'];
...
```
ถ้าต้องการใช้เฉพาะบางไฟล์ ทำได้โดยการ load ใน controller ที่ต้องการโดยใช้คำสั่ง
```
...
$this->config->load('caching');
...
```

ผมใช้หน้าแรกแสดงตัวอย่างการใช้

<?php
defined('BASEPATH') or exit('No direct script access allowed');

class Welcome extends CI_Controller
{
    public function __construct()
    {
        parent::__construct();

        echo 'charset = ' . $this->config->item('charset');

        //$this->config->load('caching');

        echo '<pre>', print_r($this->config->item('caching'), true), '</pre>';
    }
...

อ่านเพิ่มเติม

PlusMagi's Blog By Pitt Phunsanit

Tag Archive โค้ทอินิกเตอร์

ERR_CONTENT_DECODING_FAILED

CodeIgniter: php-amqplib

CodeIgniter: Composer

CodeIgniter: แยก config