NginxとgolangでAPIサーバー

golangもNginxも始めたばかりなので、他のブログの記事を参考にしつつ試験中

Nginxのconfにlocation追加

location /app1 {
    fastcgi_pass 127.0.0.1:8000;
    include fastcgi_params;
}

location /app1 {

fastcgi_pass 127.0.0.1:8000;

include fastcgi_params;

}

golang

package main

import(
    "net"
    "net/http"
    "net/http/fcgi"
    "text/template"
)

type Html struct{
    Title string
    Get string
}

func handler(w http.ResponseWriter, r *http.Request){

    tmp := r.FormValue("word")

    t, err := template.ParseFiles("base.html")
    if err != nil{
        return
    }
    err = t.Execute(w, &Html{
        Title: "boom",
        Get: tmp,
    })

}

func main(){

    l, err := net.Listen("tcp", "127.0.0.1:8000")
    if err != nil{
        return
    }

    http.HandleFunc("/", handler)
    fcgi.Serve(l, nil)

}

package main

import(

"net"

"net/http"

"net/http/fcgi"

"text/template"

)

type Html struct{

Title string

Get string

}

func handler(w http.ResponseWriter, r *http.Request){

tmp := r.FormValue("word")

t, err := template.ParseFiles("base.html")

if err != nil{

return

}

err = t.Execute(w, &Html{

Title: "boom",

Get: tmp,

})

}

func main(){

l, err := net.Listen("tcp", "127.0.0.1:8000")

if err != nil{

return

}

http.HandleFunc("/", handler)

fcgi.Serve(l, nil)

}

ちょっと違う書き方

upstream app2 {
  server 127.0.0.1:8000;
}

...

location /app2 {
  proxy_pass http://app2/;
}

upstream app2 {

server 127.0.0.1:8000;

}

...

location /app2 {

proxy_pass http://app2/;

}

package main

import(
  "net/http"
)

func main(){

//NewServeMux.Handle(パターン, Handler)となっている
//ServeMuxとはパスごとの処理を登録する構造体
//HandlerFunc(パターン、ハンドラ)が用意されている

  m := http.NewServeMux()
  h := new(MyHandler)
  m.Handle("/", h)

  //ServerはHTTPサーバーのパラメータを指定できる

  s := http.Server{
    Addr: ":8000",
    Handler: m,
  }

  s.ListenAndServe()

}

//MyHandlerはServeHTTPを実装している
//ServeHTTPはHandler Interfaceに定義されている

type MyHandler struct{

}

func (h *MyHandler) ServeHTTP (w http.ResponseWriter, r *http.Request){
  w.Write([]byte("app2!!"))
}

package main

import(

"net/http"

)

func main(){

//NewServeMux.Handle(パターン, Handler)となっている

//ServeMuxとはパスごとの処理を登録する構造体

//HandlerFunc(パターン、ハンドラ)が用意されている

m := http.NewServeMux()

h := new(MyHandler)

m.Handle("/", h)

//ServerはHTTPサーバーのパラメータを指定できる

s := http.Server{

Addr: ":8000",

Handler: m,

}

s.ListenAndServe()

}

//MyHandlerはServeHTTPを実装している

//ServeHTTPはHandler Interfaceに定義されている

type MyHandler struct{

}

func (h *MyHandler) ServeHTTP (w http.ResponseWriter, r *http.Request){

w.Write([]byte("app2!!"))

}

VPS(ConoHa)設定

VPS契約したので設定。
Ubuntu入れたと思ったけど、CentOSが入ってる模様。

過去記事参考

VirtualBoxにUbuntu 16.04を入れる(通常のインストール含む)

・vimシンタックス

手元のWSHに入ってたので流用
/usr/share/vim/vim74/syntax/go.vim
同パスにコピー

.vimrcに追加
autocmd BufNewFile,BufRead *.go setfiletype go

・サーバーにSSHで接続する

root@IPアドレス
パスワードは設定済みのrootパスワード

・ユーザー作成

過去記事参考

Ubuntu ユーザーの追加、設定、パーミッション

とりあえずrootで作業中。

・SSHの設定

過去記事参考

Ubuntu セキュリティ関連設定

設定ファイル
/etc/ssh/sshd_config

ポート変える(49152 – 65535辺り)

再起動
systemctl restart sshd

ちなみに

状態
systemctl status

自動起動有効
systemctl enable

自動起動無効
systemctl disable

・独自ドメイン設定

以前、MuuMuuで取得したドメインがあって、
NSをXserverに指定したまま放置していたのでこのドメインを活用する。

メールはそのままXserverで、wwwのみvpsに回す。

xserverのサーバパネルのDNSレコードの設定から編集。

MXはホスト名と内容が同じになっているので、
ホスト名をそのまま独自ドメインで、内容をxserverのドメイン(xxx.xsrv.jp)にする。

Aタイプの3つはIPアドレスをVPSのアドレスに変更する。
(あるいはサブドメインとwww付きを消して1つにしてしまう)

これでしばらく待つと独自ドメインからSSHアクセスできる

・Nginx

今回はphp使わないので、初めてのNginxにて。
yum install nginx

基本のルート
/usr/share/nginx/html

コンフィグ
/etc/nginx/nginx.conf

コンフィグの中にincludeがあり、
conf.d以下を読み込んでいる。

・firewalld

定義されているサービス
firewall-cmd –get-services

許可されているサービス
firewall-cmd –list-service –zone=public
–list-all
–list-services
–list-port

リロード
firewall-cmd –reload

サービスを許可する
firewall-cmd –add-service=http –zone=public –permanent

許可したサービスを削除
firewall-cmd –remove-service=http –zone=public –permanent

許可するポートの追加
firewall-cmd –add-port=22/tcp –zone=public –permanent

許可するポートの削除
firewall-cmd –remove-port=22/tcp –zone=public –permanent

定義済みサービス(編集はしない)
/usr/lib/firewalld/services

定義済みゾーンの確認
firewall-cmd –list-all-zones

アクティブなゾーンの確認
firewall–cmd —get–active–zones

Nicに対するデフォルトゾーンの確認
firewall-cmd –get-default-zone

NICのゾーンを変える(permanetが不要という記事ある要確認)
firewall-cmd –change-interface=lo –zone=public

NICをゾーンから削除(permanetが不要という記事ある要確認)
firewall-cmd –remove-interface=lo

だいたいの流れ。本来サービス登録なんだろうけど。

登録済みのサービスを消す。
firewall-cmd –remove-service=http –zone=public –permanent
firewall-cmd –remove-service=ssh –zone=public –permanent
firewall-cmd –remove-service=dhcpv6-client –zone=public –permanent

必要なポート追加。
firewall-cmd –add-port=54424/tcp –zone=public –permanent
firewall-cmd –add-port=80/tcp –zone=public –permanent

・MongoDB

とりあえずDBも初めてのMongoで

インストール

/etc/yum.repos.d/mongodb-org-4.0.repo

[mongodb-org-4.0]
name=MongoDB Repository
baseurl=https://repo.mongodb.org/yum/redhat/$releasever/mongodb-org/4.0/x86_64/
gpgcheck=1
enabled=1
gpgkey=https://www.mongodb.org/static/pgp/server-4.0.asc

を記載し、

yum install -y mongodb-org

起動
systemctl start mongod

停止
systemctl stop mongod

再起動
systemctl restart mongod

自動起動
systemctl enable mongod

シェル起動
mongo

シェル終了
exit

・Mongoシェルコマンド

db作成・切り替え
use DB

db削除
db.dropDatabase()

利用中db
db

db一覧
show dbs

コレクション一覧
show collections

コレクション作成
db.createCollection(コレクション名)

コレクション削除
db.コレクション名.drop()

ユーザー一覧
db.system.users.find()

ユーザ作成

use admin

db.createUser({
user:”owner”,
pwd:”damz7nfb”,
roles:[{ role: “userAdminAnyDatabase”, db: “admin” }]
})

ユーザー削除
db.dropUser(ユーザー名)

認証有効化

/etc/mongod.conf

security:
authorization: enabled

ログイン方法

> mongo
> use admin
> db.auth(“owner”, “damz7nfb”)

golang テストで小さいプログラム

golangはじめて間もないので調べつつ色々試験中

標準入力から日付判断

package main

import (
	"bufio"
	"fmt"
	"os"
	"time"
)

func main() {

	today := time.Now().Format("2")

	if today == "29" {
		fmt.Println("hit")
		s := bufio.NewScanner(os.Stdin)
		s.Scan()
	}
}

package main

import (

"bufio"

"fmt"

"os"

"time"

)

func main() {

today := time.Now().Format("2")

if today == "29" {

fmt.Println("hit")

s := bufio.NewScanner(os.Stdin)

s.Scan()

}

SQLite接続

package main

import(
	_ "os"
	"fmt"
	"database/sql"

	_ "github.com/mattn/go-sqlite3"
)

func main(){

	fmt.Println("start")

	db, err := sql.Open("sqlite3", "./test.d")
	if err != nil{
		fmt.Println(err)
		return
	}

	defer db.Close()
	defer fmt.Println("db close")

	_, err = db.Exec("create table t1 (id int)")
	if err != nil{
		fmt.Println(err)
		//return
	}

	_, err = db.Exec("insert into t1 (id) values (2)")
	if err != nil{
		fmt.Println(err)
		return
	}

	var c int
	rows, err := db.Query("select count(*) as c from sqlite_master where name = 't1'")
	if err != nil{
		fmt.Println(err)
		return
	}
	defer rows.Close()
	defer fmt.Println("rows close")

	for rows.Next(){
		err := rows.Scan(&c)
		if err != nil{
			return
		}
		fmt.Println(c)
	}
	fmt.Println("end")
}

package main

import(

_ "os"

"fmt"

"database/sql"

_ "github.com/mattn/go-sqlite3"

)

func main(){

fmt.Println("start")

db, err := sql.Open("sqlite3", "./test.d")

if err != nil{

fmt.Println(err)

return

}

defer db.Close()

defer fmt.Println("db close")

_, err = db.Exec("create table t1 (id int)")

if err != nil{

fmt.Println(err)

//return

}

_, err = db.Exec("insert into t1 (id) values (2)")

if err != nil{

fmt.Println(err)

return

}

var c int

rows, err := db.Query("select count(*) as c from sqlite_master where name = 't1'")

if err != nil{

fmt.Println(err)

return

}

defer rows.Close()

defer fmt.Println("rows close")

for rows.Next(){

err := rows.Scan(&c)

if err != nil{

return

}

fmt.Println(c)

}

fmt.Println("end")

}

サーバー

package main
import (
	"fmt"
	"net/http"
)

type Str string
func (s Str) ServeHTTP(w http.ResponseWriter, r *http.Request){
	fmt.Fprint(w, s)
}

func main() {

	fmt.Println("server is running")

	/* HandleFunc */
	http.HandleFunc("/", handler)

	http.HandleFunc("/b", func(w http.ResponseWriter, r *http.Request){
		fmt.Fprint(w, "Hello b")
	})

	http.HandleFunc("/e", Rec)

	/* Handle */
	http.Handle("/c", Str("hello c"))//ServeHTTPを持った構造体を渡せばOK

	//ファイル配信
	http.Handle("/d", http.StripPrefix("/d", http.FileServer(http.Dir("file"))))
	http.ListenAndServe(":8000", nil)
}

func Rec(w http.ResponseWriter, r *http.Request){
	if r.Method == http.MethodGet{
		fmt.Fprint(w, r.URL.RawQuery)
	}
}

func handler(w http.ResponseWriter, r *http.Request){
	fmt.Fprint(w, "Hello a")
	//fmt.Fprint(w, &url.URL)
}

package main

import (

"fmt"

"net/http"

)

type Str string

func (s Str) ServeHTTP(w http.ResponseWriter, r *http.Request){

fmt.Fprint(w, s)

}

func main() {

fmt.Println("server is running")

/* HandleFunc */

http.HandleFunc("/", handler)

http.HandleFunc("/b", func(w http.ResponseWriter, r *http.Request){

fmt.Fprint(w, "Hello b")

})

http.HandleFunc("/e", Rec)

/* Handle */

http.Handle("/c", Str("hello c"))//ServeHTTPを持った構造体を渡せばOK

//ファイル配信

http.Handle("/d", http.StripPrefix("/d", http.FileServer(http.Dir("file"))))

http.ListenAndServe(":8000", nil)

}

func Rec(w http.ResponseWriter, r *http.Request){

if r.Method == http.MethodGet{

fmt.Fprint(w, r.URL.RawQuery)

}

func handler(w http.ResponseWriter, r *http.Request){

fmt.Fprint(w, "Hello a")

//fmt.Fprint(w, &url.URL)

}

SSH接続

package main
import(
	"io/ioutil"
	"golang.org/x/crypto/ssh"
)

func main(){
	ip := "xxx"
	port := "xxx"
	user := "xxx"

buf, err := ioutil.ReadFile("t.pem")
if err != nil{
	return
}
key, err := ssh.ParsePrivateKey(buf)
if err != nil{
	return
}

config := &ssh.ClientConfig{
	User: user,
	Auth: []ssh.AuthMethod{
		ssh.PublicKeys(key),
	},
	HostKeyCallback: ssh.InsecureIgnoreHostKey(),
}

conn, err := ssh.Dial("tcp", ip + ":" + port, config)
if err != nil{
	return
}
defer conn.Close()

session, err := conn.NewSession()
if err != nil{
	return
}
defer session.Close()

session.Run("echo -n > a.txt")

}

package main

import(

"io/ioutil"

"golang.org/x/crypto/ssh"

)

func main(){

ip := "xxx"

port := "xxx"

user := "xxx"

buf, err := ioutil.ReadFile("t.pem")

if err != nil{

return

}

key, err := ssh.ParsePrivateKey(buf)

if err != nil{

return

}

config := &ssh.ClientConfig{

User: user,

Auth: []ssh.AuthMethod{

ssh.PublicKeys(key),

HostKeyCallback: ssh.InsecureIgnoreHostKey(),

}

conn, err := ssh.Dial("tcp", ip + ":" + port, config)

if err != nil{

return

}

defer conn.Close()

session, err := conn.NewSession()

if err != nil{

return

}

defer session.Close()

session.Run("echo -n > a.txt")

}

他言語で言うクラス

package main

import(
  "fmt"
)

type greeting struct{
  words string
}

func (g *greeting) sayHello(){
  fmt.Println(g.words)
}

func main(){

  s := &greeting{
    words : "hello world",
  }

  s.sayHello() //hello world

}

package main

import(

"fmt"

)

type greeting struct{

words string

}

func (g *greeting) sayHello(){

fmt.Println(g.words)

}

func main(){

s := &greeting{

words : "hello world",

}

s.sayHello() //hello world

}

json読み込み

package main

import(
  "fmt"
  "io/ioutil"
  "encoding/json"
)

type Personal struct{
  Name string `json:"addr"`
  Age int
}

//こう書くとjsonのaddrキーがマッピングされる

func main(){

  b, err := ioutil.ReadFile("./data.json")
  if err != nil{
    panic(err)
  }

  //直接書く場合
  //b := []byte(`{ "name":"taro", "age":20 }`)

  var p Personal
  if err := json.Unmarshal(b, &p); err != nil{
    panic(err)
  }

  fmt.Println(p.Name)
}

package main

import(

"fmt"

"io/ioutil"

"encoding/json"

)

type Personal struct{

Name string `json:"addr"`

Age int

}

//こう書くとjsonのaddrキーがマッピングされる

func main(){

b, err := ioutil.ReadFile("./data.json")

if err != nil{

panic(err)

}

//直接書く場合

//b := []byte(`{ "name":"taro", "age":20 }`)

var p Personal

if err := json.Unmarshal(b, &p); err != nil{

panic(err)

}

fmt.Println(p.Name)

}

時間

package main

import(
  "time"
  "math/rand"
)

func main(){

  //日付取得
  println(time.Now().Format("2006-01-02"))

  //UNIXタイム
  println(time.Now().Unix())

  //乱数
  println(rand.Int63())

  //時刻Seed
  rand.Seed(time.Now().UnixNano())

  for i := 1; i <= 2; i++{
    //63bit
    println(rand.Int63())
    //n付きは範囲
    println(rand.Intn(10))
  }
}

package main

import(

"time"

"math/rand"

)

func main(){

//日付取得

println(time.Now().Format("2006-01-02"))

//UNIXタイム

println(time.Now().Unix())

//乱数

println(rand.Int63())

//時刻Seed

rand.Seed(time.Now().UnixNano())

for i := 1; i <= 2; i++{

//63bit

println(rand.Int63())

//n付きは範囲

println(rand.Intn(10))

}

golang インストールメモ

最近golangをはじめたので。

WSLインストール

sudo apt-get update
sudo apt-get install golang

バージョン確認
go version

> 1.6.2

環境確認
go env

.bashrcに追加
export GOPATH=”$HOME/go”
export PATH=”$GOPATH/bin:$PATH”

Db(SQLite)を使ってみる

go get github.com/mattn/go-sqlite3

package context: unrecognized import path “context”
というエラーがでる。

1.7ではcontextパッケージとして標準パッケージに仲間入りする。
とのことなのでアップデート

sudo apt-get install golang-1.9
sudo mv /usr/bin/go /usr/bin/go.old
sudo mv /usr/bin/gofmt /usr/bin/gofmt.old
sudo ln -s /usr/lib/go-1.9/bin/go /usr/bin/go
sudo ln -s /usr/lib/go-1.9/bin/gofmt /usr/bin/gofmt

これで入った。

Windows用にクロスコンパイル

WSLからだと通常こうなっているので、
GOOS=linux
以下の用にしてビルド
GOOS=windows go build hello.go

VBS 起動にちょっとアラート

普通Gカレンダとか使うんだけど。

today = Day(Now())

'必要に応じて日を追加
If today = 1 Then MsgBox "何か書く"

'月末用
monthAdded = DateAdd("m", 1, Now)
nextMonth = DateValue(Year(monthAdded) & "/" & Month(monthAdded) & "/" & "1")
lastDay = Day(DateAdd("d", -1, nextMonth))

If today = lastDay Then MsgBox "何か書く"

today = Day(Now())

'必要に応じて日を追加

If today = 1 Then MsgBox "何か書く"

'月末用

monthAdded = DateAdd("m", 1, Now)

nextMonth = DateValue(Year(monthAdded) & "/" & Month(monthAdded) & "/" & "1")

lastDay = Day(DateAdd("d", -1, nextMonth))

If today = lastDay Then MsgBox "何か書く"

VBA シート間のコピー

シート間のコピー

Sub Excute()

Set w = Sheets("マスタ登録用")

Dim hayStack As Range: Set hayStack = Sheets("品目マスタ").Range("D15:D8462")

For r = 3 To 3592
  
  If (r Mod 5) = 0 Then DoEvents
  
  productName = x(w.Cells(r, 1).Text)
  productNote = x(w.Cells(r, 4).Text)
  productItem = x(w.Cells(r, 5).Text)
  productKg = x(w.Cells(r, 24).Text)
  productLength = x(w.Cells(r, 25).Text)
  productWidth = x(w.Cells(r, 26).Text)
  productHeight = x(w.Cells(r, 27).Text)

  If productName <> "" Then Call Pour(hayStack, productName, productNote, productItem, productKg, productLength, productWidth, productHeight)

  Application.StatusBar = r

Next r

Application.StatusBar = False
MsgBox "done"

End Sub

Function x(target)
target = Replace(target, vbCrLf, "")
target = Replace(target, vbCr, "")
target = Replace(target, vbLf, "")
x = target
End Function

Sub Pour(hayStack, productName, productNote, productItem, productKg, productLength, productWidth, productHeight)

Set w = Sheets("品目マスタ")

For Each c In hayStack

  If (c.Text = productName) Then
    w.Cells(c.Row, 187) = productNote
    If productItem <> "" Then t = "1"
    w.Cells(c.Row, 179) = t
    w.Cells(c.Row, 180) = productKg
    w.Cells(c.Row, 181) = productLength
    w.Cells(c.Row, 182) = productWidth
    w.Cells(c.Row, 183) = productHeight
  End If

Next

End Sub

Sub Excute()

Set w = Sheets("マスタ登録用")

Dim hayStack As Range: Set hayStack = Sheets("品目マスタ").Range("D15:D8462")

For r = 3 To 3592

If (r Mod 5) = 0 Then DoEvents

productName = x(w.Cells(r, 1).Text)

productNote = x(w.Cells(r, 4).Text)

productItem = x(w.Cells(r, 5).Text)

productKg = x(w.Cells(r, 24).Text)

productLength = x(w.Cells(r, 25).Text)

productWidth = x(w.Cells(r, 26).Text)

productHeight = x(w.Cells(r, 27).Text)

If productName <> "" Then Call Pour(hayStack, productName, productNote, productItem, productKg, productLength, productWidth, productHeight)

Application.StatusBar = r

Next r

Application.StatusBar = False

MsgBox "done"

End Sub

Function x(target)

target = Replace(target, vbCrLf, "")

target = Replace(target, vbCr, "")

target = Replace(target, vbLf, "")

x = target

End Function

Sub Pour(hayStack, productName, productNote, productItem, productKg, productLength, productWidth, productHeight)

Set w = Sheets("品目マスタ")

For Each c In hayStack

If (c.Text = productName) Then

w.Cells(c.Row, 187) = productNote

If productItem <> "" Then t = "1"

w.Cells(c.Row, 179) = t

w.Cells(c.Row, 180) = productKg

w.Cells(c.Row, 181) = productLength

w.Cells(c.Row, 182) = productWidth

w.Cells(c.Row, 183) = productHeight

End If

End Sub

C# Xamarin サンプル色々

Xamarinを少し触り始めたので。サンプル色々。

ボタンでアラート

var button = new Button()
{
    Text = "BUTTON"
};
button.Clicked += async (sender, e) =>
{
    var result = await DisplayAlert("タイトル", "本文", "YES", "NO");
};
Content = button;

var button = new Button()

{

Text = "BUTTON"

};

button.Clicked += async (sender, e) =>

{

var result = await DisplayAlert("タイトル", "本文", "YES", "NO");

};

Content = button;

ピッカー(選択リスト)

var piker = new Picker
{
    Title = "選択",
    VerticalOptions = LayoutOptions.Start
};
var ar = Enumerable.Range(0, 100).Select(n => string.Format("item{00}", n));
foreach (var a in ar)
{
    piker.Items.Add(a);
}
Content = piker;

var piker = new Picker

{

Title = "選択",

VerticalOptions = LayoutOptions.Start

};

var ar = Enumerable.Range(0, 100).Select(n => string.Format("item{00}", n));

foreach (var a in ar)

{

piker.Items.Add(a);

}

Content = piker;

タイマーとプログレスバー

var pbar = new ProgressBar
{
    WidthRequest = 300,
    HorizontalOptions = LayoutOptions.Center,
    VerticalOptions = LayoutOptions.CenterAndExpand
};
Device.StartTimer(TimeSpan.FromSeconds(0.1), () =>
{
    pbar.Progress += 0.01;
    return pbar.Progress != 1;
});
Content = pbar;

var pbar = new ProgressBar

{

WidthRequest = 300,

HorizontalOptions = LayoutOptions.Center,

VerticalOptions = LayoutOptions.CenterAndExpand

};

Device.StartTimer(TimeSpan.FromSeconds(0.1), () =>

{

pbar.Progress += 0.01;

return pbar.Progress != 1;

});

Content = pbar;

サーチバー(インプットボックス)

var sbar = new SearchBar
{
    Placeholder = "input",
    VerticalOptions = LayoutOptions.Start
};

sbar.SearchButtonPressed += (s, e) =>
{
    DisplayAlert("入力!", sbar.Text, "ClickMe!");
};
Content = sbar;

var sbar = new SearchBar

{

Placeholder = "input",

VerticalOptions = LayoutOptions.Start

};

sbar.SearchButtonPressed += (s, e) =>

{

DisplayAlert("入力!", sbar.Text, "ClickMe!");

};

Content = sbar;

リストビュー

ListView listView = new ListView
{
    ItemsSource = Enumerable.Range(1, 10).Select(x => string.Format("No{00}", x)).ToList()
};
//アタッチ
listView.ItemSelected += new EventHandler<SelectedItemChangedEventArgs>((object sender, SelectedItemChangedEventArgs e) =>
{

});
//アタッチ簡略
listView.ItemSelected += (s, e) =>
{
    DisplayAlert("", ((ListView)s).SelectedItem.ToString(), "OK");
};
Content = listView;

ListView listView = new ListView

{

ItemsSource = Enumerable.Range(1, 10).Select(x => string.Format("No{00}", x)).ToList()

};

//アタッチ

listView.ItemSelected += new EventHandler<SelectedItemChangedEventArgs>((object sender, SelectedItemChangedEventArgs e) =>

{

});

//アタッチ簡略

listView.ItemSelected += (s, e) =>

{

DisplayAlert("", ((ListView)s).SelectedItem.ToString(), "OK");

};

Content = listView;

C# 定期的にコマンド実行

定期的にtracertを実行したかったので。

using System;
using System.Drawing;
using System.IO;
using System.Text.RegularExpressions;
using System.Diagnostics;
using System.Windows.Forms;

namespace Tracert
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            WindowState = FormWindowState.Minimized;
            ShowInTaskbar = false;

            Bitmap bitmap = new Bitmap(32, 32);
            Graphics graphics = Graphics.FromImage(bitmap);
            graphics.FillRectangle(Brushes.Green, graphics.VisibleClipBounds);

            NotifyIcon notifyIcon = new NotifyIcon();
            notifyIcon.Icon = Icon.FromHandle(bitmap.GetHicon());
            notifyIcon.Visible = true;
            notifyIcon.Click += new EventHandler((object sender, EventArgs e) => {
                MessageBox.Show("終了します。");
                Application.Exit();
            });

            Timer timer = new Timer();
            timer.Interval = 3600000;

            timer.Tick += new EventHandler((object sender, EventArgs e)=> {
                Execute();
            });
            timer.Start();
        }

        private void Execute()
        {
            using (Process process = new Process())
            {
                process.StartInfo.RedirectStandardOutput = true;
                process.StartInfo.CreateNoWindow = true;
                process.StartInfo.UseShellExecute = false;
                process.StartInfo.FileName = "tracert";
                process.StartInfo.Arguments = "192.168.5.1";
                process.Start();

                string result = "";
                using (StringReader sr = new StringReader(process.StandardOutput.ReadToEnd()))
                {
                    Regex regex = new Regex(@"ms");
                    while (sr.Peek() > -1)
                    {
                        string ln = sr.ReadLine();
                        if (regex.IsMatch(ln)) result += ln;
                    }
                }
                process.WaitForExit();
                result = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " " + result;

                using (StreamWriter sw = new StreamWriter(Application.StartupPath + @"\dat.txt", true, System.Text.Encoding.UTF8))
                {
                    sw.Write(result + "\r\n");
                }
            }
        }
    }
}

using System;

using System.Drawing;

using System.IO;

using System.Text.RegularExpressions;

using System.Diagnostics;

using System.Windows.Forms;

namespace Tracert

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

WindowState = FormWindowState.Minimized;

ShowInTaskbar = false;

Bitmap bitmap = new Bitmap(32, 32);

Graphics graphics = Graphics.FromImage(bitmap);

graphics.FillRectangle(Brushes.Green, graphics.VisibleClipBounds);

NotifyIcon notifyIcon = new NotifyIcon();

notifyIcon.Icon = Icon.FromHandle(bitmap.GetHicon());

notifyIcon.Visible = true;

notifyIcon.Click += new EventHandler((object sender, EventArgs e) => {

MessageBox.Show("終了します。");

Application.Exit();

});

Timer timer = new Timer();

timer.Interval = 3600000;

timer.Tick += new EventHandler((object sender, EventArgs e)=> {

Execute();

});

timer.Start();

}

private void Execute()

{

using (Process process = new Process())

{

process.StartInfo.RedirectStandardOutput = true;

process.StartInfo.CreateNoWindow = true;

process.StartInfo.UseShellExecute = false;

process.StartInfo.FileName = "tracert";

process.StartInfo.Arguments = "192.168.5.1";

process.Start();

string result = "";

using (StringReader sr = new StringReader(process.StandardOutput.ReadToEnd()))

{

Regex regex = new Regex(@"ms");

while (sr.Peek() > -1)

{

string ln = sr.ReadLine();

if (regex.IsMatch(ln)) result += ln;

}

process.WaitForExit();

result = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " " + result;

using (StreamWriter sw = new StreamWriter(Application.StartupPath + @"\dat.txt", true, System.Text.Encoding.UTF8))

{

sw.Write(result + "\r\n");

}

C# TCPを使ったサンプル

using System;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Windows.Forms;

namespace TestChat
{
    public partial class Form2 : Form
    {
        public Form2()
        {
            InitializeComponent();

            new Server().Go(textBox1);

            button2.Click += new EventHandler((object sender, EventArgs e) => {
                button2.Enabled = false;
                new Client().Go(textBox3,textBox2,button2);
            });

        }
    }

    //public class Client
    //{
    //    public async void Go(TextBox address, TextBox message, Button button)
    //    {
    //        await Task.Run(()=> {
    //            try
    //            {
    //                using (var tcpClient = new TcpClient(address.Text, 2001))
    //                {
    //                    tcpClient.ReceiveTimeout = 100;
    //                    using (NetworkStream networkStream = tcpClient.GetStream())
    //                    {
    //                        byte[] buffer = Encoding.UTF8.GetBytes(message.Text);
    //                        networkStream.Write(buffer, 0, buffer.Length);
    //                    }
    //                }
    //            }
    //            catch(Exception e)
    //            {
    //                MessageBox.Show(e.Message);
    //            }
    //            button.BeginInvoke(new Action(()=> { button.Enabled = true; }));
    //        });
    //    }
    //}

    public class Client
    {
        public async void Go(TextBox address, TextBox message, Button button)
        {
            using (var tcpClient = new TcpClient())
            {
                await tcpClient.ConnectAsync(address.Text, 2001);

                using (NetworkStream networkStream = tcpClient.GetStream())
                {
                    byte[] buffer = Encoding.UTF8.GetBytes(message.Text);
                    networkStream.Write(buffer, 0, buffer.Length);
                }
            }
            button.Enabled = true;
        }
    }

    public class Server
    {
        public async void Go(TextBox textBox)
        {
            TcpListener tcpListener = new TcpListener(IPAddress.Any, 2001);
            tcpListener.Start();

            using (var tcpClient = await tcpListener.AcceptTcpClientAsync())
            {
                tcpListener.Stop();

                using (NetworkStream networkStream = tcpClient.GetStream())
                {
                    byte[] buffer = new byte[1024];
                    string message = "";

                    do
                    {
                        int byteSize = networkStream.Read(buffer, 0, buffer.Length);
                        message += Encoding.UTF8.GetString(buffer, 0, byteSize);

                    } while (networkStream.DataAvailable);
                    textBox.Text += message + "\r\n";
                }
            }
            Go(textBox);
        }
    }
}

using System;

using System.Text;

using System.Net;

using System.Net.Sockets;

using System.Windows.Forms;

namespace TestChat

{

public partial class Form2 : Form

{

public Form2()

{

InitializeComponent();

new Server().Go(textBox1);

button2.Click += new EventHandler((object sender, EventArgs e) => {

button2.Enabled = false;

new Client().Go(textBox3,textBox2,button2);

});

}

//public class Client

//{

// public async void Go(TextBox address, TextBox message, Button button)

// {

// await Task.Run(()=> {

// try

// {

// using (var tcpClient = new TcpClient(address.Text, 2001))

// {

// tcpClient.ReceiveTimeout = 100;

// using (NetworkStream networkStream = tcpClient.GetStream())

// {

// byte[] buffer = Encoding.UTF8.GetBytes(message.Text);

// networkStream.Write(buffer, 0, buffer.Length);

// }

// catch(Exception e)

// {

// MessageBox.Show(e.Message);

// }

// button.BeginInvoke(new Action(()=> { button.Enabled = true; }));

// });

// }

//}

public class Client

{

public async void Go(TextBox address, TextBox message, Button button)

{

using (var tcpClient = new TcpClient())

{

await tcpClient.ConnectAsync(address.Text, 2001);

using (NetworkStream networkStream = tcpClient.GetStream())

{

byte[] buffer = Encoding.UTF8.GetBytes(message.Text);

networkStream.Write(buffer, 0, buffer.Length);

}

button.Enabled = true;

}

public class Server

{

public async void Go(TextBox textBox)

{

TcpListener tcpListener = new TcpListener(IPAddress.Any, 2001);

tcpListener.Start();

using (var tcpClient = await tcpListener.AcceptTcpClientAsync())

{

tcpListener.Stop();

using (NetworkStream networkStream = tcpClient.GetStream())

{

byte[] buffer = new byte[1024];

string message = "";

{

int byteSize = networkStream.Read(buffer, 0, buffer.Length);

message += Encoding.UTF8.GetString(buffer, 0, byteSize);

} while (networkStream.DataAvailable);

textBox.Text += message + "\r\n";

}

Go(textBox);

}

C# UDPを使ったメッセージ交換

UDPを使ったテストプログラム。

using System;
using System.Text;
using System.Linq;
using System.Collections.Generic;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;

namespace TestChat
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            StartReceive();
            button1.Click += new EventHandler(SendMessage);
        }

        public class UdpState
        {
            public UdpClient UdpClient;
            public IPEndPoint IPEndPoint;
            public UdpState(UdpClient udpClient, IPEndPoint endPoint)
            {
                UdpClient = udpClient;
                IPEndPoint = endPoint;
            }
        }

        public class Message
        {
            private List<string> TextList = new List<string>();
            private static Message Instance = null;

            public static Message GetInstance()
            {
                if(Instance == null)
                {
                    Instance = new Message();
                }
                return Instance;
            }

            public void SetMessage(string text)
            {
                TextList.Add(text);
            }

            public string GetMessage()
            {
                return string.Join("\r\n", TextList.ToArray().Reverse());
            }

        }

        private void StartReceive()
        {
            IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 2002);
            UdpClient udpClient = new UdpClient(endPoint);
            udpClient.BeginReceive(ReceiveCallback, new UdpState(udpClient, endPoint));
        }

        private void ReceiveCallback(IAsyncResult ar)
        {
            UdpClient udpClient = ((UdpState)ar.AsyncState).UdpClient;
            IPEndPoint endPoint = ((UdpState)ar.AsyncState).IPEndPoint;

            byte[] receiveByte = udpClient.EndReceive(ar,ref endPoint);
            string receiveString = Encoding.UTF8.GetString(receiveByte);
            textBox1.BeginInvoke(new Action<string>(ShowReceive), receiveString);

            udpClient.BeginReceive(ReceiveCallback, new UdpState(udpClient, endPoint));
        }

        private void ShowReceive(string s)
        {
            Message message = Message.GetInstance();
            message.SetMessage(s);
            textBox1.Text = message.GetMessage();
        }

        private async void SendMessage(object sender, EventArgs e)
        {
            UdpClient udpClient = new UdpClient();
            udpClient.Connect(new IPEndPoint(IPAddress.Parse("192.168.11.18"), 2002));

            byte[] sendByte = Encoding.UTF8.GetBytes(textBox2.Text);
            await udpClient.SendAsync(sendByte, sendByte.Length);
            udpClient.Close();
        }
    }
}

using System;

using System.Text;

using System.Linq;

using System.Collections.Generic;

using System.Windows.Forms;

using System.Net;

using System.Net.Sockets;

namespace TestChat

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

StartReceive();

button1.Click += new EventHandler(SendMessage);

}

public class UdpState

{

public UdpClient UdpClient;

public IPEndPoint IPEndPoint;

public UdpState(UdpClient udpClient, IPEndPoint endPoint)

{

UdpClient = udpClient;

IPEndPoint = endPoint;

}

public class Message

{

private List<string> TextList = new List<string>();

private static Message Instance = null;

public static Message GetInstance()

{

if(Instance == null)

{

Instance = new Message();

}

return Instance;

}

public void SetMessage(string text)

{

TextList.Add(text);

}

public string GetMessage()

{

return string.Join("\r\n", TextList.ToArray().Reverse());

}

private void StartReceive()

{

IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 2002);

UdpClient udpClient = new UdpClient(endPoint);

udpClient.BeginReceive(ReceiveCallback, new UdpState(udpClient, endPoint));

}

private void ReceiveCallback(IAsyncResult ar)

{

UdpClient udpClient = ((UdpState)ar.AsyncState).UdpClient;

IPEndPoint endPoint = ((UdpState)ar.AsyncState).IPEndPoint;

byte[] receiveByte = udpClient.EndReceive(ar,ref endPoint);

string receiveString = Encoding.UTF8.GetString(receiveByte);

textBox1.BeginInvoke(new Action<string>(ShowReceive), receiveString);

udpClient.BeginReceive(ReceiveCallback, new UdpState(udpClient, endPoint));

}

private void ShowReceive(string s)

{

Message message = Message.GetInstance();

message.SetMessage(s);

textBox1.Text = message.GetMessage();

}

private async void SendMessage(object sender, EventArgs e)

{

UdpClient udpClient = new UdpClient();

udpClient.Connect(new IPEndPoint(IPAddress.Parse("192.168.11.18"), 2002));

byte[] sendByte = Encoding.UTF8.GetBytes(textBox2.Text);

await udpClient.SendAsync(sendByte, sendByte.Length);

udpClient.Close();

}

テックメモ

当ブログは自分用のメモです。昔のメモをそのまま移行しただけの記事もあり一部不正確な記述もあります。

NginxとgolangでAPIサーバー

VPS(ConoHa)設定

golang テストで小さいプログラム

golang インストールメモ

WSLインストール

Db(SQLite)を使ってみる

Windows用にクロスコンパイル

VBS 起動にちょっとアラート

VBA シート間のコピー

C# Xamarin サンプル色々

C# 定期的にコマンド実行

C# TCPを使ったサンプル

C# UDPを使ったメッセージ交換