การใช้งาน HTTP Server และ HTTP Client ในภาษา Dart เบื้องต้น

import 'dart:io';

void main() async {

  // กำหนด server ที่สามารถเชื่อมต่อผ่าน internet ทาง
  // IP address และ หมายเลข port ที่กำหนด
  // โดย server เป็นข้อมูล stream ประเภทหนึ่ง
  var server = await HttpServer.bind(
    InternetAddress.loopbackIPv4,
    4040,
  );

  // เมื่อกำหนด server เรียบร้อยแล้ว ตัว server ก็จะคอยสังเกต
  // คอยรับ request จาก client ถ้ามี ผ่าน host และ port ที่กำหนด
  print('Listening on localhost:${server.port}');

  // รอหากมีข้อมูล events ที่เป็น HttpRequest เกิดขึ้นใน server
  // กล่าวคือรอจนกว่า server จะได้รับการ request เข้ามา
  await for (HttpRequest request in server) {
    // ตอบกลับการ request ถ้ามีด้วย HttpResponse Object
    // โดยแสดงคำว่า "Hello, world!" 
    request.response.write('Hello, world!');
    await request.response.close(); // จบการทำงาน response object
  }

}

  // รอหากมีข้อมูล events ที่เป็น HttpRequest เกิดขึ้นใน server
  // กล่าวคือรอจนกว่า server จะได้รับการ request เข้ามา
  await for (HttpRequest request in server) {
    // ตอบกลับการ request (ถ้ามี) ด้วย HttpResponse Object
    // โดยแสดงคำว่า "Hello, world!" 
    request.response.write('Hello, world!');
    await request.response.close(); // จบการทำงาน response object
  }

  // เมื่อ HttpRequest ถูกเพิ่มเข้าไปใน server stream
  // เราก็สามารถเรียกใช้งานโดยใช้ await for เรียกใช้ข้อมูล request
  await for (HttpRequest request in server) {
    // ตอบกลับการ request ถ้ามีด้วย HttpResponse Object
    // โดยแสดงคำว่า "Hello, world!" 
    request.response.write('Hello, world!');
    await request.response.close(); // จบการทำงาน response object
  }

var res = req.response;
// HttpResponse response = request.response;

  var utf8HexBytes = [
    0x41, 0x42, 0x43
  ];

  await for (HttpRequest req in server) {
    print(req.uri);
    print(req.method);
    print(req.headers);
    req.response.write('Hello, world!');
    await req.response.close(); // จบการทำงาน response object
  }

/
GET
user-agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/79.0.3945.88 Safari/537.36 Edg/79.0.309.56
connection: keep-alive
cache-control: max-age=0
accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9
accept-language: en-US,en;q=0.9,th;q=0.8
sec-fetch-mode: navigate
accept-encoding: gzip, deflate, br
sec-fetch-user: ?1
host: localhost:4040
sec-fetch-site: none
upgrade-insecure-requests: 1

  await for (HttpRequest req in server) {
    if (req.method == 'GET') {
      final action = req.uri.queryParameters['q'];
      final place = req.uri.queryParameters['to'];
      final formSubmit = '''
      <br>
      <form action="http://localhost:4040/" method="POST">
      <button type="submit">GO</button>
      </form>
      ''';
      await req.response.headers
        ..add(HttpHeaders.contentTypeHeader, 'text/html');
      await req.response
        ..write('${action} to ${place}')
        ..write('${formSubmit}')
        ..close();
    } else {
      await req.response
        ..statusCode = HttpStatus.methodNotAllowed
        ..write('Unsupported request: ${req.method}.')
        ..close();
    }    
  }

      await req.response.headers
        .add(HttpHeaders.contentTypeHeader, 'text/html');

  await for (HttpRequest req in server) {
    var res = req.response; // return HttpResponse object
    final dataList = ['Hello','World'];
    final dataString = 'Hello World';
    final dataCharCode = 65; // เป็นตัวเลขฐาน 16 หรือฐาน 10
    // ตัวแปร res ใช้งาาน .. operator ตัวดำเนินการที่ทำงานต่อเนื่อง
    res
      ..writeAll(dataList,' | ') // เขียนจาก List แล้วมีตัวคั่น
      ..write(dataString) // เขียนแสดงข้อมูลทั่วไป
      ..writeCharCode(dataCharCode) // ตัวอักษณ A
      ..writeln(dataList); // เขียนข้อมูลพร้อมขึ้นบรรทัดใหม่ ไม่ใช่ <br>
     await res.close();
  }

  await for (HttpRequest req in server) {
    var res = req.response;
    var urlReditrect = 'https://www.ninenik.com';
    await res.redirect(Uri.parse(urlReditrect));
    await res.close();
  }

  await for (HttpRequest req in server) {
    var res = req.response;
    var headers = res.headers; // return HttpHeaders object
    var jsonData = '''
    {
      "name": "Ebiwayo",
      "address": {
          "street": "My St.",
          "city": "New York"
      }
    }
    ''';
/*     headers.contentType 
      = ContentType('application', 'json', charset: 'utf-8'); */
    headers
      ..add(HttpHeaders.contentTypeHeader,ContentType.json.toString());
    await res.write(jsonData);
    await res.close();
  }

    headers
      ..add('Content-Type','application/json; charset=utf-8')
      ..add('Access-Control-Allow-Origin','*');

  await for (HttpRequest req in server) {
    var res = req.response;
    var headers = res.headers; // return HttpHeaders object
    var statusDataOk = '''
    {
      "message": "successful",
      "code": 200
    }
    ''';
    var statusDataFail = '''
    {
      "message": "fail",
      "code": 404
    }
    ''';    
    headers.add(
      HttpHeaders.contentTypeHeader,ContentType.json.toString());    
    if(req.method == 'GET'){
      await res
          ..statusCode = HttpStatus.notFound
          ..write(statusDataFail);
    }else{
      await res
          ..statusCode = HttpStatus.ok
          ..write(statusDataOk);
    }
    await res.close();
  }

import 'dart:convert';
import 'dart:io';

void main() async {

  // กำหนด url ของ API ที่ต้องการเรียกดูข้อมูล
  var url = 'https://jsonplaceholder.typicode.com/users';
  var clientRequest = await HttpClient().getUrl(Uri.parse(url));
  var clientResponse = await clientRequest.close();

  // แปลงข้อมูล Stream ถอดรหัส utf8 และแปลง JSON String data
  var jsonData = utf8.decoder.bind(clientResponse)
                .transform(JsonDecoder());

  try {
    // ใช้งานข้อมูล Stream
    await for (var data in jsonData) {
      print(data.runtimeType); // List<dynamic>
      var userList = ListUser.fromJson(data); // สร้าง ListUser object
      print(userList.runtimeType); // ListUser
      for(var user in userList.users){ // วนลูปแสดงชื่อ user
        print('User ID: ${user.id} Nmae: ${user.name}');
      }
    }
  } catch (e) {
    print(e);
  }  
  

}

class ListUser{
  List<User> users;
  ListUser({this.users});

  factory ListUser.fromJson(List<dynamic> json) {
    return ListUser(
        users: json
            .map((e) => User.fromJson(e as Map<String, dynamic>))
            .toList());
  }

}

class User {
  int id;
  String name;
  String username;
  String email;
  Address address;
  String phone;
  String website;
  Company company;

  User(
      {this.id,
      this.name,
      this.username,
      this.email,
      this.address,
      this.phone,
      this.website,
      this.company});

  User.fromJson(Map<String, dynamic> json) {
    id = json['id'];
    name = json['name'];
    username = json['username'];
    email = json['email'];
    address =
        json['address'] != null ? new Address.fromJson(json['address']) : null;
    phone = json['phone'];
    website = json['website'];
    company =
        json['company'] != null ? new Company.fromJson(json['company']) : null;
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['id'] = this.id;
    data['name'] = this.name;
    data['username'] = this.username;
    data['email'] = this.email;
    if (this.address != null) {
      data['address'] = this.address.toJson();
    }
    data['phone'] = this.phone;
    data['website'] = this.website;
    if (this.company != null) {
      data['company'] = this.company.toJson();
    }
    return data;
  }
}

class Address {
  String street;
  String suite;
  String city;
  String zipcode;
  Geo geo;

  Address({this.street, this.suite, this.city, this.zipcode, this.geo});

  Address.fromJson(Map<String, dynamic> json) {
    street = json['street'];
    suite = json['suite'];
    city = json['city'];
    zipcode = json['zipcode'];
    geo = json['geo'] != null ? new Geo.fromJson(json['geo']) : null;
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['street'] = this.street;
    data['suite'] = this.suite;
    data['city'] = this.city;
    data['zipcode'] = this.zipcode;
    if (this.geo != null) {
      data['geo'] = this.geo.toJson();
    }
    return data;
  }
}

class Geo {
  String lat;
  String lng;

  Geo({this.lat, this.lng});

  Geo.fromJson(Map<String, dynamic> json) {
    lat = json['lat'];
    lng = json['lng'];
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['lat'] = this.lat;
    data['lng'] = this.lng;
    return data;
  }
}

class Company {
  String name;
  String catchPhrase;
  String bs;

  Company({this.name, this.catchPhrase, this.bs});

  Company.fromJson(Map<String, dynamic> json) {
    name = json['name'];
    catchPhrase = json['catchPhrase'];
    bs = json['bs'];
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['name'] = this.name;
    data['catchPhrase'] = this.catchPhrase;
    data['bs'] = this.bs;
    return data;
  }
}

  // กำหนด url ของ API ที่ต้องการเรียกดูข้อมูล
  var url = 'https://jsonplaceholder.typicode.com/users';
  // client เริ่มเชื่อมต่อกับ Network ไปยัง server ผ่าน Url ที่กำหนด
  // เมื่อใช้คำส่ัง getUrl() และเมื่อเชื่อมสำเร็จจะคืนค่า เป็น HttpClientRequest object
  // เราสามารถกำหนดค่าให้กับ HttpClientRequest เพิ่มเติมได้ถ้ามี เช่น contentType
  // หรือข้อมูลอื่นๆ ที่เป็น HttpHeaders ด้วยคำสั่ง set() หรือ add() เช่นเดียวกับ HttpRequest ฝั่ง server
  var clientRequest = await HttpClient().getUrl(Uri.parse(url));
  // เมื่อใช้คำส่ัง close() client ส่งคำขอ หรือ request ไปยัง server 
  // server คืนค่ากลับเป็น HttpClientResponse object ซึ่งมีข้อมูลต่างๆ
  var clientResponse = await clientRequest.close();

  // แปลงข้อมูล Stream จาก HttpClientResponse object ให้พร้อมใช้งาน
  // โดยถอดรหัส utf8 และแปลง JSON String data
  var jsonData = utf8.decoder.bind(clientResponse)
                .transform(JsonDecoder());

import 'dart:convert';
import 'dart:io';

void main() async {

  var host = 'www.w3.org';
  var textFile = '/TR/PNG/iso_8859-1.txt';
  var clientRequest = await HttpClient().get(host, 80, textFile);
  var clientResponse = await clientRequest.close();
  var lines = utf8.decoder.bind(clientResponse)
                .transform(LineSplitter());

  try {
    await for (var line in lines) {
      print(line); 
    }
  } catch (e) {
    print(e);
  }  
  
}

import 'dart:convert';
import 'dart:io';

void main() async {

  // เตรียมข้อมูลที่จะส่งไปยัง server ในรูปแบบ Map<String, dynamic>
  var jsonData = {
    'name': 'Ebiwayo',
    'username': 'ebiwayo',
    'email': 'demo@example.com'
  };
  // กำหนด URL ของ API 
  var url = 'https://jsonplaceholder.typicode.com/users';

  // ใช้คำส่ัง posUrl() โดยเพิ่ม headers ให้กับ Header และ data ให้กับ
  // HttpClientRequest object
  var clientRequest = await HttpClient().postUrl(Uri.parse(url))
          ..headers.contentType = ContentType.json // เพิ่ม header
          ..write(jsonEncode(jsonData)); // เพิ่ม data ่แปลงเป็น json string
  var clientResponse = await clientRequest.close();
  // แปลงข้อมูลที่ได้กลับมา จะเป็นข้อมูล ที่เราเพิ่งเพิ่มเข้าไป
  var dataAdded = utf8.decoder.bind(clientResponse)
                .transform(JsonDecoder());

  try {
    await for (var data in dataAdded) {
      print(data.runtimeType); 
      print(data); 
    }
  } catch (e) {
    print(e);
  }  
  
}

import 'dart:convert';
import 'dart:io';

void main() async {

  var server = await HttpServer.bind(
    InternetAddress.loopbackIPv4,
    4040,
  );

  print('Listening on localhost:${server.port}');

  await for (HttpRequest req in server) {
    var contentType = req.headers.contentType; // เก็บค่า contentType
    var res = req.response; // HttpResponse obect
    var headers = res.headers; // HttpHeaders Object    

    // กำหนด header รูปแบบการตอบกลับเป็นข้อมูล jSON
    headers
      ..add('Content-Type','application/json; charset=utf-8')
      ..add('Access-Control-Allow-Origin','*');

    // ตรวจสอบเงื่อนไข ถ้าเป็นการส่งข้อมูลแบบ POST และเป็นแบบ json
    if (req.method == 'POST' &&
        contentType?.mimeType == 'application/json' ) {

      try {
        // ถอดรหัส utf8 และ รวมข้อมูล json เป็น String ข้อความเดียว
        var content = await utf8.decoder.bind(req).join();
        var data = jsonDecode(content) as Map; // แปลง JSON เป็น Dart object
        print(content);
        res
          ..write(jsonEncode(data));
      } catch (e) {
        var simpleError = {'msg': '${e}'};
        res
          ..write(jsonEncode(simpleError));
      }
    } else {
      var simple = {'msg': 'Hello World'};
      res
        ..write(jsonEncode(simple));
    }
    await res.close(); // จบการทำงาน response object
  }

}

var data = { username: 'example' };

fetch('http://localhost:4040/', {
  method: 'POST', 
  headers: {
    'Content-Type': 'application/json',
  },
  body: JSON.stringify(data),
})
.then((response) => response.json())
.then((data) => {
  console.log(JSON.stringify(data));
})
.catch((error) => {
  console.error(JSON.stringify(error));
});